org.forgerock.opendj.ldif

Class ConnectionChangeRecordWriter

java.lang.Object

org.forgerock.opendj.ldif.ConnectionChangeRecordWriter

All Implemented Interfaces:

Closeable, Flushable, AutoCloseable, ChangeRecordWriter

public final class ConnectionChangeRecordWriter
extends Object
implements ChangeRecordWriter

A ConnectionChangeRecordWriter is a bridge from Connections to ChangeRecordWriters. A connection change record writer writes change records by sending appropriate update requests (Add, Delete, Modify, or ModifyDN) to an underlying connection.

All update requests are performed synchronously, blocking until an update result is received. If an update result indicates that an update request has failed for some reason then the error result is propagated to the caller using an LdapException.

Note: comments are not supported by connection change record writers. Attempts to write comments will be ignored.

Constructor Summary

Constructors

Constructor and Description
ConnectionChangeRecordWriter(Connection connection) Creates a new connection change record writer whose destination is the provided connection.

Method Summary

Modifier and Type	Method and Description
void	close() Closes this connection change record writer, including the underlying connection.
void	flush() Connection change record writers do not require flushing, so this method has no effect.
ConnectionChangeRecordWriter	writeChangeRecord(AddRequest change) Writes the provided Add request to the underlying connection, blocking until the request completes.
ConnectionChangeRecordWriter	writeChangeRecord(ChangeRecord change) Writes the provided change record to the underlying connection, blocking until the request completes.
ConnectionChangeRecordWriter	writeChangeRecord(DeleteRequest change) Writes the provided Delete request to the underlying connection, blocking until the request completes.
ConnectionChangeRecordWriter	writeChangeRecord(ModifyDnRequest change) Writes the provided ModifyDN request to the underlying connection, blocking until the request completes.
ConnectionChangeRecordWriter	writeChangeRecord(ModifyRequest change) Writes the provided Modify request to the underlying connection, blocking until the request completes.
ConnectionChangeRecordWriter	writeComment(CharSequence comment) Connection change record writers do not support comments, so the provided comment will be ignored.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ConnectionChangeRecordWriter

public ConnectionChangeRecordWriter(Connection connection)

Creates a new connection change record writer whose destination is the provided connection.

Parameters:

connection - The connection to use.

Throws:

NullPointerException - If connection was null.

Method Detail

close

public void close()

Closes this connection change record writer, including the underlying connection. Closing a previously closed change record writer has no effect.

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Specified by:

close in interface ChangeRecordWriter

flush

public void flush()

Connection change record writers do not require flushing, so this method has no effect.

Specified by:

flush in interface Flushable

Specified by:

flush in interface ChangeRecordWriter

writeChangeRecord

public ConnectionChangeRecordWriter writeChangeRecord(AddRequest change)
                                               throws LdapException

Writes the provided Add request to the underlying connection, blocking until the request completes.

Specified by:

writeChangeRecord in interface ChangeRecordWriter

Parameters:

change - The AddRequest to be written.

Returns:

A reference to this connection change record writer.

Throws:

LdapException - If the result code indicates that the request failed for some reason.

NullPointerException - If change was null.

writeChangeRecord

public ConnectionChangeRecordWriter writeChangeRecord(ChangeRecord change)
                                               throws LdapException

Writes the provided change record to the underlying connection, blocking until the request completes.

Specified by:

writeChangeRecord in interface ChangeRecordWriter

Parameters:

change - The change record to be written.

Returns:

A reference to this connection change record writer.

Throws:

LdapException - If the result code indicates that the request failed for some reason.

NullPointerException - If change was null.

writeChangeRecord

public ConnectionChangeRecordWriter writeChangeRecord(DeleteRequest change)
                                               throws LdapException

Writes the provided Delete request to the underlying connection, blocking until the request completes.

Specified by:

writeChangeRecord in interface ChangeRecordWriter

Parameters:

change - The DeleteRequest to be written.

Returns:

A reference to this connection change record writer.

Throws:

LdapException - If the result code indicates that the request failed for some reason.

NullPointerException - If change was null.

writeChangeRecord

public ConnectionChangeRecordWriter writeChangeRecord(ModifyDnRequest change)
                                               throws LdapException

Writes the provided ModifyDN request to the underlying connection, blocking until the request completes.

Specified by:

writeChangeRecord in interface ChangeRecordWriter

Parameters:

change - The ModifyDNRequest to be written.

Returns:

A reference to this connection change record writer.

Throws:

LdapException - If the result code indicates that the request failed for some reason.

NullPointerException - If change was null.

writeChangeRecord

public ConnectionChangeRecordWriter writeChangeRecord(ModifyRequest change)
                                               throws LdapException

Writes the provided Modify request to the underlying connection, blocking until the request completes.

Specified by:

writeChangeRecord in interface ChangeRecordWriter

Parameters:

change - The ModifyRequest to be written.

Returns:

A reference to this connection change record writer.

Throws:

LdapException - If the result code indicates that the request failed for some reason.

NullPointerException - If change was null.

writeComment

public ConnectionChangeRecordWriter writeComment(CharSequence comment)

Connection change record writers do not support comments, so the provided comment will be ignored.

Specified by:

writeComment in interface ChangeRecordWriter

Parameters:

comment - The CharSequence to be written as a comment.

Returns:

A reference to this connection change record writer.

Throws:

NullPointerException - If comment was null.