public abstract class TypedRequestHandler extends Object implements RequestHandler, org.forgerock.opendj.ldap.messages.RequestVisitor<io.reactivex.Flowable<org.forgerock.opendj.ldap.messages.Response>,org.forgerock.services.context.Context,Exception>
RequestHander
s whose behavior depends on the type of Request
.
It is possible to provides specific behavior for different request types by selectively overriding the handle*()
methods. Common behaviour can be added for the remaining request types by overriding the
handleAny(Context, Request)
.
RequestHandler
Constructor and Description |
---|
TypedRequestHandler() |
Modifier and Type | Method and Description |
---|---|
io.reactivex.Flowable<org.forgerock.opendj.ldap.messages.Response> |
handle(org.forgerock.services.context.Context context,
org.forgerock.opendj.ldap.messages.Request request)
Returns a
Flowable representing the asynchronous Response of the given request . |
protected io.reactivex.Flowable<org.forgerock.opendj.ldap.messages.Response> |
handleAbandon(org.forgerock.services.context.Context context,
org.forgerock.opendj.ldap.messages.AbandonRequest request)
Implements the specific behavior for all AbandonRequest.
|
protected io.reactivex.Flowable<org.forgerock.opendj.ldap.messages.Response> |
handleAdd(org.forgerock.services.context.Context context,
org.forgerock.opendj.ldap.messages.AddRequest request)
Implements the specific behavior for all AddRequest.
|
protected io.reactivex.Flowable<org.forgerock.opendj.ldap.messages.Response> |
handleAny(org.forgerock.services.context.Context context,
org.forgerock.opendj.ldap.messages.Request request)
Implements the common behavior for all the request types.
|
protected io.reactivex.Flowable<org.forgerock.opendj.ldap.messages.Response> |
handleBind(org.forgerock.services.context.Context context,
org.forgerock.opendj.ldap.messages.BindRequest request)
Implements the specific behavior for all BindRequest.
|
protected io.reactivex.Flowable<org.forgerock.opendj.ldap.messages.Response> |
handleCompare(org.forgerock.services.context.Context context,
org.forgerock.opendj.ldap.messages.CompareRequest request)
Implements the specific behavior for all CompareRequest.
|
protected io.reactivex.Flowable<org.forgerock.opendj.ldap.messages.Response> |
handleDelete(org.forgerock.services.context.Context context,
org.forgerock.opendj.ldap.messages.DeleteRequest request)
Implements the specific behavior for all DeleteRequest.
|
protected io.reactivex.Flowable<org.forgerock.opendj.ldap.messages.Response> |
handleExtended(org.forgerock.services.context.Context context,
org.forgerock.opendj.ldap.messages.ExtendedRequest<?> request)
Implements the specific behavior for all ExtendedRequest.
|
protected io.reactivex.Flowable<org.forgerock.opendj.ldap.messages.Response> |
handleInvalid(org.forgerock.services.context.Context context,
org.forgerock.opendj.ldap.messages.InvalidRequest request)
Implements the specific behavior for all InvalidRequest.
|
protected io.reactivex.Flowable<org.forgerock.opendj.ldap.messages.Response> |
handleModify(org.forgerock.services.context.Context context,
org.forgerock.opendj.ldap.messages.ModifyRequest request)
Implements the specific behavior for all ModifyRequest.
|
protected io.reactivex.Flowable<org.forgerock.opendj.ldap.messages.Response> |
handleModifyDn(org.forgerock.services.context.Context context,
org.forgerock.opendj.ldap.messages.ModifyDnRequest request)
Implements the specific behavior for all ModifyDnRequest.
|
protected io.reactivex.Flowable<org.forgerock.opendj.ldap.messages.Response> |
handleSearch(org.forgerock.services.context.Context context,
org.forgerock.opendj.ldap.messages.SearchRequest request)
Implements the specific behavior for all SearchRequest.
|
protected io.reactivex.Flowable<org.forgerock.opendj.ldap.messages.Response> |
handleUnbind(org.forgerock.services.context.Context context,
org.forgerock.opendj.ldap.messages.UnbindRequest request)
Implements the specific behavior for all UnbindRequest.
|
protected io.reactivex.Flowable<org.forgerock.opendj.ldap.messages.Response> |
handleUnknown(org.forgerock.services.context.Context context,
org.forgerock.opendj.ldap.messages.UnknownRequest request)
Implements the specific behavior for all UnknownRequest.
|
io.reactivex.Flowable<org.forgerock.opendj.ldap.messages.Response> |
visitRequest(org.forgerock.services.context.Context context,
org.forgerock.opendj.ldap.messages.AbandonRequest request) |
io.reactivex.Flowable<org.forgerock.opendj.ldap.messages.Response> |
visitRequest(org.forgerock.services.context.Context context,
org.forgerock.opendj.ldap.messages.AddRequest request) |
io.reactivex.Flowable<org.forgerock.opendj.ldap.messages.Response> |
visitRequest(org.forgerock.services.context.Context context,
org.forgerock.opendj.ldap.messages.BindRequest request) |
io.reactivex.Flowable<org.forgerock.opendj.ldap.messages.Response> |
visitRequest(org.forgerock.services.context.Context context,
org.forgerock.opendj.ldap.messages.CompareRequest request) |
io.reactivex.Flowable<org.forgerock.opendj.ldap.messages.Response> |
visitRequest(org.forgerock.services.context.Context context,
org.forgerock.opendj.ldap.messages.DeleteRequest request) |
io.reactivex.Flowable<org.forgerock.opendj.ldap.messages.Response> |
visitRequest(org.forgerock.services.context.Context context,
org.forgerock.opendj.ldap.messages.ExtendedRequest<?> request) |
io.reactivex.Flowable<org.forgerock.opendj.ldap.messages.Response> |
visitRequest(org.forgerock.services.context.Context context,
org.forgerock.opendj.ldap.messages.InvalidRequest request) |
io.reactivex.Flowable<org.forgerock.opendj.ldap.messages.Response> |
visitRequest(org.forgerock.services.context.Context context,
org.forgerock.opendj.ldap.messages.ModifyDnRequest request) |
io.reactivex.Flowable<org.forgerock.opendj.ldap.messages.Response> |
visitRequest(org.forgerock.services.context.Context context,
org.forgerock.opendj.ldap.messages.ModifyRequest request) |
io.reactivex.Flowable<org.forgerock.opendj.ldap.messages.Response> |
visitRequest(org.forgerock.services.context.Context context,
org.forgerock.opendj.ldap.messages.SearchRequest request) |
io.reactivex.Flowable<org.forgerock.opendj.ldap.messages.Response> |
visitRequest(org.forgerock.services.context.Context context,
org.forgerock.opendj.ldap.messages.UnbindRequest request) |
io.reactivex.Flowable<org.forgerock.opendj.ldap.messages.Response> |
visitRequest(org.forgerock.services.context.Context context,
org.forgerock.opendj.ldap.messages.UnknownRequest request) |
public TypedRequestHandler()
public final io.reactivex.Flowable<org.forgerock.opendj.ldap.messages.Response> handle(org.forgerock.services.context.Context context, org.forgerock.opendj.ldap.messages.Request request) throws Exception
RequestHandler
Flowable
representing the asynchronous Response
of the given request
.
Successful responses (@see ResultCode#isExceptional()
must be provided to the subscriber through the
onNext() method. All erroneous responses (e.g: no such object) must be published to the subscriber through the
onError() method.
handle
in interface RequestHandler
context
- The request context.request
- The request.Flowable
of zero or several Response
to be returned to the caller.Exception
- If an error occurred during the processing of the request.public final io.reactivex.Flowable<org.forgerock.opendj.ldap.messages.Response> visitRequest(org.forgerock.services.context.Context context, org.forgerock.opendj.ldap.messages.AbandonRequest request) throws Exception
public final io.reactivex.Flowable<org.forgerock.opendj.ldap.messages.Response> visitRequest(org.forgerock.services.context.Context context, org.forgerock.opendj.ldap.messages.AddRequest request) throws Exception
public final io.reactivex.Flowable<org.forgerock.opendj.ldap.messages.Response> visitRequest(org.forgerock.services.context.Context context, org.forgerock.opendj.ldap.messages.BindRequest request) throws Exception
public final io.reactivex.Flowable<org.forgerock.opendj.ldap.messages.Response> visitRequest(org.forgerock.services.context.Context context, org.forgerock.opendj.ldap.messages.CompareRequest request) throws Exception
public final io.reactivex.Flowable<org.forgerock.opendj.ldap.messages.Response> visitRequest(org.forgerock.services.context.Context context, org.forgerock.opendj.ldap.messages.DeleteRequest request) throws Exception
public final io.reactivex.Flowable<org.forgerock.opendj.ldap.messages.Response> visitRequest(org.forgerock.services.context.Context context, org.forgerock.opendj.ldap.messages.ExtendedRequest<?> request) throws Exception
public final io.reactivex.Flowable<org.forgerock.opendj.ldap.messages.Response> visitRequest(org.forgerock.services.context.Context context, org.forgerock.opendj.ldap.messages.InvalidRequest request) throws Exception
public final io.reactivex.Flowable<org.forgerock.opendj.ldap.messages.Response> visitRequest(org.forgerock.services.context.Context context, org.forgerock.opendj.ldap.messages.ModifyDnRequest request) throws Exception
public final io.reactivex.Flowable<org.forgerock.opendj.ldap.messages.Response> visitRequest(org.forgerock.services.context.Context context, org.forgerock.opendj.ldap.messages.ModifyRequest request) throws Exception
public final io.reactivex.Flowable<org.forgerock.opendj.ldap.messages.Response> visitRequest(org.forgerock.services.context.Context context, org.forgerock.opendj.ldap.messages.SearchRequest request) throws Exception
public final io.reactivex.Flowable<org.forgerock.opendj.ldap.messages.Response> visitRequest(org.forgerock.services.context.Context context, org.forgerock.opendj.ldap.messages.UnbindRequest request) throws Exception
public final io.reactivex.Flowable<org.forgerock.opendj.ldap.messages.Response> visitRequest(org.forgerock.services.context.Context context, org.forgerock.opendj.ldap.messages.UnknownRequest request) throws Exception
protected io.reactivex.Flowable<org.forgerock.opendj.ldap.messages.Response> handleAny(org.forgerock.services.context.Context context, org.forgerock.opendj.ldap.messages.Request request) throws Exception
context
- The request context.request
- The request.Flowable
representing the response to be returned to the client.Exception
- If an error occurred during the processing of the request.protected io.reactivex.Flowable<org.forgerock.opendj.ldap.messages.Response> handleAbandon(org.forgerock.services.context.Context context, org.forgerock.opendj.ldap.messages.AbandonRequest request) throws Exception
context
- The request context.request
- The request.Flowable
representing the response to be returned to the client.Exception
- If an error occurred during the processing of the request.protected io.reactivex.Flowable<org.forgerock.opendj.ldap.messages.Response> handleAdd(org.forgerock.services.context.Context context, org.forgerock.opendj.ldap.messages.AddRequest request) throws Exception
context
- The request context.request
- The request.Flowable
representing the response to be returned to the client.Exception
- If an error occurred during the processing of the request.protected io.reactivex.Flowable<org.forgerock.opendj.ldap.messages.Response> handleBind(org.forgerock.services.context.Context context, org.forgerock.opendj.ldap.messages.BindRequest request) throws Exception
context
- The request context.request
- The request.Flowable
representing the response to be returned to the client.Exception
- If an error occurred during the processing of the request.protected io.reactivex.Flowable<org.forgerock.opendj.ldap.messages.Response> handleCompare(org.forgerock.services.context.Context context, org.forgerock.opendj.ldap.messages.CompareRequest request) throws Exception
context
- The request context.request
- The request.Flowable
representing the response to be returned to the client.Exception
- If an error occurred during the processing of the request.protected io.reactivex.Flowable<org.forgerock.opendj.ldap.messages.Response> handleDelete(org.forgerock.services.context.Context context, org.forgerock.opendj.ldap.messages.DeleteRequest request) throws Exception
context
- The request context.request
- The request.Flowable
representing the response to be returned to the client.Exception
- If an error occurred during the processing of the request.protected io.reactivex.Flowable<org.forgerock.opendj.ldap.messages.Response> handleExtended(org.forgerock.services.context.Context context, org.forgerock.opendj.ldap.messages.ExtendedRequest<?> request) throws Exception
context
- The request context.request
- The request.Flowable
representing the response to be returned to the client.Exception
- If an error occurred during the processing of the request.protected io.reactivex.Flowable<org.forgerock.opendj.ldap.messages.Response> handleInvalid(org.forgerock.services.context.Context context, org.forgerock.opendj.ldap.messages.InvalidRequest request) throws Exception
context
- The request context.request
- The request.Flowable
representing the response to be returned to the client.Exception
- If an error occurred during the processing of the request.protected io.reactivex.Flowable<org.forgerock.opendj.ldap.messages.Response> handleSearch(org.forgerock.services.context.Context context, org.forgerock.opendj.ldap.messages.SearchRequest request) throws Exception
context
- The request context.request
- The request.Flowable
representing the response to be returned to the client.Exception
- If an error occurred during the processing of the request.protected io.reactivex.Flowable<org.forgerock.opendj.ldap.messages.Response> handleModify(org.forgerock.services.context.Context context, org.forgerock.opendj.ldap.messages.ModifyRequest request) throws Exception
context
- The request context.request
- The request.Flowable
representing the response to be returned to the client.Exception
- If an error occurred during the processing of the request.protected io.reactivex.Flowable<org.forgerock.opendj.ldap.messages.Response> handleModifyDn(org.forgerock.services.context.Context context, org.forgerock.opendj.ldap.messages.ModifyDnRequest request) throws Exception
context
- The request context.request
- The request.Flowable
representing the response to be returned to the client.Exception
- If an error occurred during the processing of the request.protected io.reactivex.Flowable<org.forgerock.opendj.ldap.messages.Response> handleUnbind(org.forgerock.services.context.Context context, org.forgerock.opendj.ldap.messages.UnbindRequest request) throws Exception
context
- The request context.request
- The request.Flowable
representing the response to be returned to the client.Exception
- If an error occurred during the processing of the request.protected io.reactivex.Flowable<org.forgerock.opendj.ldap.messages.Response> handleUnknown(org.forgerock.services.context.Context context, org.forgerock.opendj.ldap.messages.UnknownRequest request) throws Exception
context
- The request context.request
- The request.Flowable
representing the response to be returned to the client.Exception
- If an error occurred during the processing of the request.Copyright © 2010-2017 ForgeRock AS. All Rights Reserved.