| Modifier and Type | Field and Description |
|---|---|
private java.util.Map<org.apache.mina.core.session.IoSession,LdapSession> |
LdapSessionManager.ldapSessions
Concurrent hashMap backing for IoSession to LdapSession mapping
|
| Modifier and Type | Method and Description |
|---|---|
LdapSession |
LdapSessionManager.getLdapSession(org.apache.mina.core.session.IoSession session)
Gets the LdapSession associated with the MINA session.
|
LdapSession[] |
LdapSessionManager.getSessions()
Gets the active sessions managed by the LdapServer.
|
LdapSession |
LdapSessionManager.removeLdapSession(org.apache.mina.core.session.IoSession session)
Removes an LdapSession managed by the
LdapServer. |
| Modifier and Type | Method and Description |
|---|---|
void |
LdapSessionManager.addLdapSession(LdapSession ldapSession)
Adds a new LdapSession to the LdapServer.
|
private void |
LdapProtocolHandler.cleanUpSession(LdapSession ldapSession)
Explicitly handles
LdapSession and IoSession cleanup tasks. |
void |
ExtendedOperationHandler.handleExtendedOperation(LdapSession session,
R req)
Handles the specified extended operation.
|
| Modifier and Type | Field and Description |
|---|---|
(package private) LdapSession |
PersistentSearchListener.session |
| Modifier and Type | Method and Description |
|---|---|
abstract void |
LdapRequestHandler.handle(LdapSession session,
T message)
Handle a Ldap message associated with a session
|
abstract void |
LdapResponseHandler.handle(LdapSession session,
T message)
Handle a Ldap message associated with a session
|
void |
LdapRequestHandler.handleException(LdapSession session,
org.apache.directory.api.ldap.model.message.ResultResponseRequest req,
java.lang.Exception e)
Handles processing with referrals without ManageDsaIT decorator.
|
| Constructor and Description |
|---|
PersistentSearchListener(LdapSession session,
org.apache.directory.api.ldap.model.message.SearchRequest req) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
PagedSearchContext.hasSameRequest(org.apache.directory.api.ldap.model.message.SearchRequest request,
LdapSession session)
Compare the previous search request and the new one, and return
true if they are equal.
|
| Modifier and Type | Method and Description |
|---|---|
void |
CertGenerationRequestHandler.handleExtendedOperation(LdapSession session,
org.apache.directory.api.ldap.extras.extended.certGeneration.CertGenerationRequest req)
Handles the specified extended operation.
|
void |
StartTlsHandler.handleExtendedOperation(LdapSession session,
org.apache.directory.api.ldap.model.message.ExtendedRequest req)
Handles the specified extended operation.
|
void |
GracefulShutdownHandler.handleExtendedOperation(LdapSession requestor,
org.apache.directory.api.ldap.extras.extended.gracefulShutdown.GracefulShutdownRequest req) |
void |
PwdModifyHandler.handleExtendedOperation(LdapSession requestor,
org.apache.directory.api.ldap.extras.extended.pwdModify.PasswordModifyRequest req)
Handles the specified extended operation.
|
void |
StoredProcedureExtendedOperationHandler.handleExtendedOperation(LdapSession session,
org.apache.directory.api.ldap.extras.extended.storedProcedure.StoredProcedureRequest req) |
void |
WhoAmIHandler.handleExtendedOperation(LdapSession requestor,
org.apache.directory.api.ldap.extras.extended.whoAmI.WhoAmIRequest req)
Handles the specified extended operation.
|
| Modifier and Type | Method and Description |
|---|---|
private org.apache.directory.api.ldap.model.message.SearchResultDone |
SearchRequestHandler.abandonPagedSearch(LdapSession session,
org.apache.directory.api.ldap.model.message.SearchRequest req)
Manage the abandoned Paged Search (when paged size = 0).
|
private org.apache.directory.api.ldap.model.message.SearchResultDone |
SearchRequestHandler.doPagedSearch(LdapSession session,
org.apache.directory.api.ldap.model.message.SearchRequest req,
org.apache.directory.api.ldap.codec.controls.search.pagedSearch.PagedResultsDecorator control)
Handle a Paged Search request.
|
private org.apache.directory.api.ldap.model.message.SearchResultDone |
SearchRequestHandler.doSimpleSearch(LdapSession session,
org.apache.directory.api.ldap.model.message.SearchRequest req)
Conducts a simple search across the result set returning each entry
back except for the search response done.
|
private org.apache.directory.api.ldap.model.message.Response |
SearchRequestHandler.generateResponse(LdapSession session,
org.apache.directory.api.ldap.model.message.SearchRequest req,
org.apache.directory.api.ldap.model.entry.Entry entry)
Generates a response for an entry retrieved from the server core based
on the nature of the request with respect to referral handling.
|
private void |
BindRequestHandler.generateSaslChallengeOrComplete(LdapSession ldapSession,
javax.security.sasl.SaslServer ss,
org.apache.directory.api.ldap.model.message.BindRequest bindRequest)
For challenge/response exchange, generate the challenge.
|
static org.apache.directory.api.ldap.model.entry.Entry |
SearchRequestHandler.getFarthestReferralAncestor(LdapSession session,
org.apache.directory.api.ldap.model.name.Dn target)
Searches up the ancestry of a Dn searching for the farthest referral
ancestor.
|
org.apache.directory.api.ldap.model.message.Referral |
SearchRequestHandler.getReferralOnAncestor(LdapSession session,
org.apache.directory.api.ldap.model.name.Dn reqTargetDn,
org.apache.directory.api.ldap.model.message.SearchRequest req,
org.apache.directory.api.ldap.model.entry.Entry referralAncestor)
Handles processing with referrals without ManageDsaIT decorator and with
an ancestor that is a referral.
|
org.apache.directory.api.ldap.model.message.Referral |
SearchRequestHandler.getReferralOnAncestorForSearch(LdapSession session,
org.apache.directory.api.ldap.model.message.SearchRequest req,
org.apache.directory.api.ldap.model.entry.Entry referralAncestor)
Handles processing with referrals without ManageDsaIT decorator and with
an ancestor that is a referral.
|
private long |
SearchRequestHandler.getServerSizeLimit(LdapSession session,
org.apache.directory.api.ldap.model.message.SearchRequest request)
Return the server size limit
|
void |
AbandonRequestHandler.handle(LdapSession session,
org.apache.directory.api.ldap.model.message.AbandonRequest request)
Handle a Ldap message associated with a session
|
void |
AddRequestHandler.handle(LdapSession session,
org.apache.directory.api.ldap.model.message.AddRequest req)
Handle a Ldap message associated with a session
|
void |
BindRequestHandler.handle(LdapSession ldapSession,
org.apache.directory.api.ldap.model.message.BindRequest bindRequest)
Deal with a received BindRequest
|
void |
CompareRequestHandler.handle(LdapSession session,
org.apache.directory.api.ldap.model.message.CompareRequest req)
Handle a Ldap message associated with a session
|
void |
DeleteRequestHandler.handle(LdapSession session,
org.apache.directory.api.ldap.model.message.DeleteRequest req)
Handle a Ldap message associated with a session
|
void |
ExtendedRequestHandler.handle(LdapSession session,
org.apache.directory.api.ldap.model.message.ExtendedRequest req)
Handle a Ldap message associated with a session
|
void |
ModifyDnRequestHandler.handle(LdapSession session,
org.apache.directory.api.ldap.model.message.ModifyDnRequest req)
Deal with a ModifyDN request received from a client.
|
void |
ModifyRequestHandler.handle(LdapSession session,
org.apache.directory.api.ldap.model.message.ModifyRequest req)
Handle a Ldap message associated with a session
|
void |
SearchRequestHandler.handle(LdapSession session,
org.apache.directory.api.ldap.model.message.SearchRequest req)
Handle a Ldap message associated with a session
|
void |
UnbindRequestHandler.handle(LdapSession session,
org.apache.directory.api.ldap.model.message.UnbindRequest unbindRequest) |
void |
SearchRequestHandler.handleException(LdapSession session,
org.apache.directory.api.ldap.model.message.ResultResponseRequest req,
java.lang.Exception e)
Handles processing with referrals without ManageDsaIT decorator.
|
private void |
SearchRequestHandler.handleIgnoringReferrals(LdapSession session,
org.apache.directory.api.ldap.model.message.SearchRequest req)
Main message handing method for search requests.
|
private void |
SearchRequestHandler.handleLookup(LdapSession session,
org.apache.directory.api.ldap.model.message.SearchRequest req)
Handles a simple lookup, or a RootDSE lookup.
|
private boolean |
SearchRequestHandler.handleLookupAndRootDse(LdapSession session,
org.apache.directory.api.ldap.model.message.SearchRequest req)
Handles the RootDSE and lookups searches
|
private void |
SearchRequestHandler.handlePersistentSearch(LdapSession session,
org.apache.directory.api.ldap.model.message.SearchRequest req,
org.apache.directory.api.ldap.model.message.controls.PersistentSearch psearch)
Handles search requests containing the persistent search decorator but
delegates to doSimpleSearch() if the changesOnly parameter of the
decorator is set to false.
|
private void |
SearchRequestHandler.handleReferralEntryForSearch(LdapSession session,
org.apache.directory.api.ldap.model.message.SearchRequest req,
org.apache.directory.api.ldap.model.entry.Entry entry)
Handles processing a referral response on a target entry which is a
referral.
|
private void |
SearchRequestHandler.handleReplication(LdapSession session,
org.apache.directory.api.ldap.model.message.SearchRequest searchRequest)
Handle the replication request.
|
void |
BindRequestHandler.handleSaslAuth(LdapSession ldapSession,
org.apache.directory.api.ldap.model.message.BindRequest bindRequest)
Handle the SASL authentication.
|
private void |
BindRequestHandler.handleSaslAuthPending(LdapSession ldapSession,
org.apache.directory.api.ldap.model.message.BindRequest bindRequest) |
void |
BindRequestHandler.handleSimpleAuth(LdapSession ldapSession,
org.apache.directory.api.ldap.model.message.BindRequest bindRequest)
Handle the Simple authentication.
|
private void |
SearchRequestHandler.handleWithReferrals(LdapSession session,
org.apache.directory.api.ldap.model.message.SearchRequest req)
Handles processing with referrals without ManageDsaIT decorator.
|
private boolean |
SearchRequestHandler.isSubSchemaSubEntrySearch(LdapSession session,
org.apache.directory.api.ldap.model.message.SearchRequest req)
Determines if a search request is a subSchemaSubEntry search.
|
private void |
SearchRequestHandler.modifyFilter(LdapSession session,
org.apache.directory.api.ldap.model.message.SearchRequest req)
Alters the filter expression based on the presence of the
ManageDsaIT decorator.
|
private org.apache.directory.api.ldap.model.filter.EqualityNode<java.lang.String> |
SearchRequestHandler.newIsReferralEqualityNode(LdapSession session)
Constructs a new filter EqualityNode asserting that a candidate
objectClass is a referral.
|
private void |
SearchRequestHandler.readPagedResults(LdapSession session,
org.apache.directory.api.ldap.model.message.SearchRequest req,
org.apache.directory.api.ldap.model.message.LdapResult ldapResult,
org.apache.directory.api.ldap.model.cursor.Cursor<org.apache.directory.api.ldap.model.entry.Entry> cursor,
long sizeLimit,
int pagedLimit,
PagedSearchContext pagedContext,
org.apache.directory.api.ldap.codec.controls.search.pagedSearch.PagedResultsDecorator pagedResultsControl) |
private PagedSearchContext |
SearchRequestHandler.removeContext(LdapSession session,
PagedSearchContext cookieInstance)
Remove a cookie instance from the session, if it exists.
|
private void |
BindRequestHandler.sendAuthMethNotSupported(LdapSession ldapSession,
org.apache.directory.api.ldap.model.message.BindRequest bindRequest)
Send back an AUTH-METH-NOT-SUPPORTED error message to the client
|
private void |
BindRequestHandler.sendBindSuccess(LdapSession ldapSession,
org.apache.directory.api.ldap.model.message.BindRequest bindRequest,
byte[] tokenBytes)
Send a SUCCESS message back to the client.
|
private void |
BindRequestHandler.sendInvalidCredentials(LdapSession ldapSession,
org.apache.directory.api.ldap.model.message.BindRequest bindRequest,
java.lang.Exception e)
Send back an INVALID-CREDENTIAL error message to the user.
|
private void |
SearchRequestHandler.setTimeLimitsOnCursor(org.apache.directory.api.ldap.model.message.SearchRequest req,
LdapSession session,
org.apache.directory.api.ldap.model.cursor.Cursor<org.apache.directory.api.ldap.model.entry.Entry> cursor)
Based on the server maximum time limits configured for search and the
requested time limits this method determines if at all to replace the
default ClosureMonitor of the result set Cursor with one that closes
the Cursor when either server mandated or request mandated time limits
are reached.
|
private void |
SearchRequestHandler.writeResults(LdapSession session,
org.apache.directory.api.ldap.model.message.SearchRequest req,
org.apache.directory.api.ldap.model.message.LdapResult ldapResult,
org.apache.directory.api.ldap.model.cursor.Cursor<org.apache.directory.api.ldap.model.entry.Entry> cursor,
long sizeLimit) |
| Modifier and Type | Method and Description |
|---|---|
void |
AddResponseHandler.handle(LdapSession session,
org.apache.directory.api.ldap.model.message.AddResponse addResponse)
Handle a Ldap message associated with a session
|
void |
BindResponseHandler.handle(LdapSession ldapSession,
org.apache.directory.api.ldap.model.message.BindResponse bindResponse)
Handle a Ldap message associated with a session
|
void |
CompareResponseHandler.handle(LdapSession session,
org.apache.directory.api.ldap.model.message.CompareResponse compareResponse)
Handle a Ldap message associated with a session
|
void |
DeleteResponseHandler.handle(LdapSession session,
org.apache.directory.api.ldap.model.message.DeleteResponse deleteResponse)
Handle a Ldap message associated with a session
|
void |
ExtendedResponseHandler.handle(LdapSession session,
org.apache.directory.api.ldap.model.message.ExtendedResponse extendedResponse)
Handle a Ldap message associated with a session
|
void |
IntermediateResponseHandler.handle(LdapSession session,
org.apache.directory.api.ldap.model.message.IntermediateResponse intermediateResponse)
Handle a Ldap message associated with a session
|
void |
ModifyDnResponseHandler.handle(LdapSession session,
org.apache.directory.api.ldap.model.message.ModifyDnResponse modifyDnResponse)
Handle a Ldap message associated with a session
|
void |
ModifyResponseHandler.handle(LdapSession session,
org.apache.directory.api.ldap.model.message.ModifyResponse modifyResponse)
Handle a Ldap message associated with a session
|
void |
SearchResultDoneHandler.handle(LdapSession session,
org.apache.directory.api.ldap.model.message.SearchResultDone searchResultDone)
Handle a Ldap message associated with a session
|
void |
SearchResultEntryHandler.handle(LdapSession session,
org.apache.directory.api.ldap.model.message.SearchResultEntry searchResultEntry)
Handle a Ldap message associated with a session
|
void |
SearchResultReferenceHandler.handle(LdapSession session,
org.apache.directory.api.ldap.model.message.SearchResultReference searchResultReference)
Handle a Ldap message associated with a session
|
| Modifier and Type | Field and Description |
|---|---|
protected LdapSession |
AbstractSaslCallbackHandler.ldapSession
The reference on the user ldap session
|
private LdapSession |
AbstractSaslServer.ldapSession
The associated LdapSession instance
|
| Modifier and Type | Method and Description |
|---|---|
LdapSession |
AbstractSaslServer.getLdapSession() |
| Modifier and Type | Method and Description |
|---|---|
void |
SimpleMechanismHandler.cleanup(LdapSession ldapSession)
Clean the Sasl properties when the use has been authenticated
|
void |
MechanismHandler.cleanup(LdapSession ldapSession)
Clean the Sasl properties when the use has been authenticated
|
javax.security.sasl.SaslServer |
SimpleMechanismHandler.handleMechanism(LdapSession ldapSession,
org.apache.directory.api.ldap.model.message.BindRequest bindRequest) |
javax.security.sasl.SaslServer |
MechanismHandler.handleMechanism(LdapSession session,
org.apache.directory.api.ldap.model.message.BindRequest bindRequest)
Implementors will use the session and message to determine what kind of
SaslServer to create and what initialization parameters it will require. |
void |
SimpleMechanismHandler.init(LdapSession ldapSession)
Initialize the saslProperties with some mechanism's specific data
|
void |
MechanismHandler.init(LdapSession ldapSession)
Initialize the saslProperties with some mechanism's specific data
|
protected void |
AbstractMechanismHandler.insertSaslFilter(LdapSession ldapSession)
Inject a SaslFilter into the Filter chain, to deal with modified
PDU sent when some mechanisms have been negotiated (DIGEST-MD5, GSSAPI,
for instance)
|
| Constructor and Description |
|---|
AbstractSaslServer(LdapSession ldapSession,
CoreSession adminSession,
org.apache.directory.api.ldap.model.message.BindRequest bindRequest) |
| Modifier and Type | Method and Description |
|---|---|
void |
CramMd5MechanismHandler.cleanup(LdapSession ldapSession)
Remove the SaslServer and Mechanism property.
|
javax.security.sasl.SaslServer |
CramMd5MechanismHandler.handleMechanism(LdapSession ldapSession,
org.apache.directory.api.ldap.model.message.BindRequest bindRequest) |
void |
CramMd5MechanismHandler.init(LdapSession ldapSession)
Initialize the saslProperties with some mechanism's specific data
|
| Constructor and Description |
|---|
CramMd5CallbackHandler(LdapSession ldapSession,
CoreSession adminSession,
org.apache.directory.api.ldap.model.message.BindRequest bindRequest)
Creates a new instance of CramMd5CallbackHandler.
|
| Modifier and Type | Method and Description |
|---|---|
void |
DigestMd5MechanismHandler.cleanup(LdapSession ldapSession)
Remove the Host, UserBaseDn, props and Mechanism property.
|
javax.security.sasl.SaslServer |
DigestMd5MechanismHandler.handleMechanism(LdapSession ldapSession,
org.apache.directory.api.ldap.model.message.BindRequest bindRequest) |
void |
DigestMd5MechanismHandler.init(LdapSession ldapSession)
Initialize the saslProperties with some mechanism's specific data
|
| Constructor and Description |
|---|
DigestMd5CallbackHandler(LdapSession ldapSession,
CoreSession adminSession,
org.apache.directory.api.ldap.model.message.BindRequest bindRequest)
Creates a new instance of DigestMd5CallbackHandler.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GssapiMechanismHandler.cleanup(LdapSession ldapSession)
Remove the Host, UserBaseDn, props and Mechanism property.
|
javax.security.sasl.SaslServer |
GssapiMechanismHandler.handleMechanism(LdapSession ldapSession,
org.apache.directory.api.ldap.model.message.BindRequest bindRequest) |
void |
GssapiMechanismHandler.init(LdapSession ldapSession)
Initialize the saslProperties with some mechanism's specific data
|
| Constructor and Description |
|---|
GssapiCallbackHandler(LdapSession ldapSession,
CoreSession adminSession,
org.apache.directory.api.ldap.model.message.BindRequest bindRequest)
Creates a new instance of GssapiCallbackHandler.
|
| Modifier and Type | Method and Description |
|---|---|
void |
NtlmMechanismHandler.cleanup(LdapSession ldapSession)
Remove the Host, UserBaseDn, props and Mechanism property.
|
javax.security.sasl.SaslServer |
NtlmMechanismHandler.handleMechanism(LdapSession ldapSession,
org.apache.directory.api.ldap.model.message.BindRequest bindRequest) |
void |
NtlmMechanismHandler.init(LdapSession ldapSession)
Initialize the saslProperties with some mechanism's specific data
|
| Constructor and Description |
|---|
NtlmSaslServer(NtlmProvider provider,
org.apache.directory.api.ldap.model.message.BindRequest bindRequest,
LdapSession ldapSession,
CoreSession adminSession) |
| Modifier and Type | Method and Description |
|---|---|
void |
PlainMechanismHandler.cleanup(LdapSession ldapSession)
Remove the SaslServer and Mechanism property.
|
javax.security.sasl.SaslServer |
PlainMechanismHandler.handleMechanism(LdapSession ldapSession,
org.apache.directory.api.ldap.model.message.BindRequest bindRequest)
Implementors will use the session and message to determine what kind of
SaslServer to create and what initialization parameters it will require. |
void |
PlainMechanismHandler.init(LdapSession ldapSession)
Initialize the saslProperties with some mechanism's specific data
|
| Constructor and Description |
|---|
PlainSaslServer(LdapSession ldapSession,
CoreSession adminSession,
org.apache.directory.api.ldap.model.message.BindRequest bindRequest)
Creates a new instance of PlainSaslServer.
|
| Modifier and Type | Field and Description |
|---|---|
private LdapSession |
SyncReplSearchListener.session
The ldap session
|
| Modifier and Type | Method and Description |
|---|---|
private void |
SyncReplRequestHandler.doContentUpdate(LdapSession session,
org.apache.directory.api.ldap.model.message.SearchRequest req,
ReplicaEventLog replicaLog,
java.lang.String consumerCsn)
process the update of the consumer, starting from the given LastEntryCSN the consumer
has sent with the sync request.
|
private void |
SyncReplRequestHandler.doInitialRefresh(LdapSession session,
org.apache.directory.api.ldap.model.message.SearchRequest request)
Process the initial refresh : we will send all the entries
|
private org.apache.directory.api.ldap.model.message.SearchResultDone |
SyncReplRequestHandler.doSimpleSearch(LdapSession session,
org.apache.directory.api.ldap.model.message.SearchRequest req,
ReplicaEventLog replicaLog)
Process a search on the provider to get all the modified entries.
|
private org.apache.directory.api.ldap.model.message.Response |
SyncReplRequestHandler.generateResponse(LdapSession session,
org.apache.directory.api.ldap.model.message.SearchRequest req,
org.apache.directory.api.ldap.model.entry.Entry entry)
Build the response to be sent to the client
|
private long |
SyncReplRequestHandler.getServerSizeLimit(LdapSession session,
org.apache.directory.api.ldap.model.message.SearchRequest request)
Return the server size limit
|
void |
SyncReplRequestHandler.handleSyncRequest(LdapSession session,
org.apache.directory.api.ldap.model.message.SearchRequest request)
Process the incoming search request sent by a remote server when trying to replicate.
|
void |
ReplicationRequestHandler.handleSyncRequest(LdapSession session,
org.apache.directory.api.ldap.model.message.SearchRequest req)
A method to be used by any RFC 4533 compatible provider implementation
|
org.apache.directory.api.ldap.model.filter.ExprNode |
SyncReplRequestHandler.modifyFilter(LdapSession session,
org.apache.directory.api.ldap.model.message.SearchRequest req) |
private org.apache.directory.api.ldap.model.filter.EqualityNode<java.lang.String> |
SyncReplRequestHandler.newIsReferralEqualityNode(LdapSession session) |
private void |
SyncReplRequestHandler.readResults(LdapSession session,
org.apache.directory.api.ldap.model.message.SearchRequest req,
org.apache.directory.api.ldap.model.message.LdapResult ldapResult,
org.apache.directory.api.ldap.model.cursor.Cursor<org.apache.directory.api.ldap.model.entry.Entry> cursor,
long sizeLimit,
ReplicaEventLog replicaLog)
Process the results get from a search request.
|
private void |
SyncReplRequestHandler.sendContentFromLog(LdapSession session,
org.apache.directory.api.ldap.model.message.SearchRequest req,
ReplicaEventLog clientMsgLog,
java.lang.String fromCsn)
Send all the stored modifications to the consumer
|
private void |
SyncReplRequestHandler.sendESyncRefreshRequired(LdapSession session,
org.apache.directory.api.ldap.model.message.SearchRequest req)
Send an error response to he consue r: it has to send a SYNC_REFRESH request first.
|
private void |
SyncReplRequestHandler.sendSearchResultEntry(LdapSession session,
org.apache.directory.api.ldap.model.message.SearchRequest req,
org.apache.directory.api.ldap.model.entry.Entry entry,
org.apache.directory.api.ldap.extras.controls.syncrepl.syncState.SyncStateTypeEnum syncStateType)
Prepare and send a search result entry response, with the associated
SyncState control.
|
void |
SyncReplSearchListener.setSession(LdapSession session)
Store the Ldap session to use
|
private void |
SyncReplRequestHandler.setTimeLimitsOnCursor(org.apache.directory.api.ldap.model.message.SearchRequest req,
LdapSession session,
org.apache.directory.api.ldap.model.cursor.Cursor<org.apache.directory.api.ldap.model.entry.Entry> cursor) |
| Constructor and Description |
|---|
SyncReplSearchListener(LdapSession session,
org.apache.directory.api.ldap.model.message.SearchRequest searchRequest,
ReplicaEventLog consumerMsgLog,
boolean pushInRealTime)
Create a new instance of a consumer listener
|