public class ReactiveHandlersUtils extends Object
Modifier and Type | Field and Description |
---|---|
static int |
LDAP_PROTOCOL_VERSION_3
Version 3 of the LDAP protocol.
|
static String |
NO_BACKEND
Backend id value to use for an operation when there is no backend selected.
|
static String |
REACTIVE_OUT
Label for reactive out operation attachment.
|
static String |
REQUEST
Label for the request operation attachment.
|
static String |
REQUEST_CONTEXT
Label for the request context operation attachment.
|
Modifier and Type | Method and Description |
---|---|
static void |
addAttachmentsToOperation(Operation op,
RequestDJContext requestContext,
org.forgerock.opendj.ldap.messages.Request request,
io.reactivex.FlowableEmitter<org.forgerock.opendj.ldap.messages.Response> out)
Add to operation the attachments needed for correct behavior of the reactive handlers.
|
static void |
emitResult(org.forgerock.opendj.ldap.messages.Result result,
io.reactivex.FlowableEmitter<org.forgerock.opendj.ldap.messages.Response> out)
Emits a result to the provided reactive emitter, to signal completion of a request.
|
static io.reactivex.FlowableEmitter<org.forgerock.opendj.ldap.messages.Response> |
getFlowableEmitter(Operation operation)
Returns the reactive emitter attached to the provided operation.
|
static InternalModificationsRequestControl |
getInternalModificationControl(org.forgerock.opendj.ldap.messages.Request request)
Returns the internal modification control from the provided request.
|
static ReplicatedRequestControl |
getReplicationContextControl(org.forgerock.opendj.ldap.messages.Request request)
Returns the replication context control from the provided request.
|
static org.forgerock.opendj.ldap.messages.Result |
operationToResult(Operation operation,
int ldapVersion,
long connectionId,
org.forgerock.opendj.ldap.SslOptions sslOptions)
Generates a result from the provided operation.
|
static Operation |
requestToOperation(org.forgerock.opendj.ldap.messages.Request request,
ClientConnection clientConn,
long opId,
int msgId)
Returns an operation from the provided request.
|
static org.forgerock.opendj.ldap.messages.Response |
searchEntrytoResponse(SearchResultEntry searchEntry)
Returns a Response from the provided SearchResultEntry.
|
static void |
setResultDetails(org.forgerock.opendj.ldap.messages.Result result,
Operation operation,
DirectoryException de,
int ldapVersion)
Set details on the provided result with data from an operation.
|
static byte |
toLdapResponseType(org.forgerock.opendj.ldap.messages.Request request,
org.forgerock.opendj.ldap.messages.Response response)
Returns the LDAP response type to use for the provided request and response.
|
public static final String REACTIVE_OUT
public static final String REQUEST
public static final String REQUEST_CONTEXT
public static final String NO_BACKEND
public static final int LDAP_PROTOCOL_VERSION_3
public static io.reactivex.FlowableEmitter<org.forgerock.opendj.ldap.messages.Response> getFlowableEmitter(Operation operation)
operation
- The operation.public static org.forgerock.opendj.ldap.messages.Result operationToResult(Operation operation, int ldapVersion, long connectionId, org.forgerock.opendj.ldap.SslOptions sslOptions)
operation
- The operation to use to generate the response.ldapVersion
- The LDAP protocol version.connectionId
- The connection id to be used for loggingsslOptions
- Contains options to apply when a Start-TLS operation succeed.null
if LDAP v2 is used or if the operation
has no response.public static Operation requestToOperation(org.forgerock.opendj.ldap.messages.Request request, ClientConnection clientConn, long opId, int msgId)
request
- The request.clientConn
- The client connection to use.opId
- The operation id.msgId
- The message id.public static org.forgerock.opendj.ldap.messages.Response searchEntrytoResponse(SearchResultEntry searchEntry)
searchEntry
- a search result entrypublic static void setResultDetails(org.forgerock.opendj.ldap.messages.Result result, Operation operation, DirectoryException de, int ldapVersion)
result
- The result to update.operation
- The source operation.de
- The directory exception that was thrown.ldapVersion
- The version of LDAP protocol.public static byte toLdapResponseType(org.forgerock.opendj.ldap.messages.Request request, org.forgerock.opendj.ldap.messages.Response response)
request
- The requestresponse
- The response received for the request.public static void addAttachmentsToOperation(Operation op, RequestDJContext requestContext, org.forgerock.opendj.ldap.messages.Request request, io.reactivex.FlowableEmitter<org.forgerock.opendj.ldap.messages.Response> out)
op
- The operation to execute.requestContext
- The context for the request.request
- The request to perform.out
- The flowable emitter to use when response(s) are available.public static ReplicatedRequestControl getReplicationContextControl(org.forgerock.opendj.ldap.messages.Request request)
request
- The requestnull
if there is nonepublic static InternalModificationsRequestControl getInternalModificationControl(org.forgerock.opendj.ldap.messages.Request request)
request
- The requestnull
if there is nonepublic static void emitResult(org.forgerock.opendj.ldap.messages.Result result, io.reactivex.FlowableEmitter<org.forgerock.opendj.ldap.messages.Response> out)
result
- The result to emit, which may be null
.out
- The reactive emitter.Copyright © 2010-2017 ForgeRock AS. All Rights Reserved.