org.ldaptive.ad.control.util

Class NotificationClient

java.lang.Object

org.ldaptive.ad.control.util.NotificationClient

public class NotificationClient
extends java.lang.Object

Client that simplifies using the notification control.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	NotificationClient.NotificationItem Contains data returned when using the notification control.

Field Summary

Fields

Modifier and Type	Field and Description
private Connection	connection Connection to invoke the search operation on.
protected org.slf4j.Logger	logger Logger for this class.

Constructor Summary

Constructors

Constructor and Description
NotificationClient(Connection conn) Creates a new notification client.

Method Summary

Modifier and Type	Method and Description
void	abandon(int messageId) Invokes an abandon operation on the supplied ldap message id.
java.util.concurrent.BlockingQueue<NotificationClient.NotificationItem>	execute(SearchRequest request) Invokes execute(SearchRequest, int) with a capacity of Integer.MAX_VALUE.
java.util.concurrent.BlockingQueue<NotificationClient.NotificationItem>	execute(SearchRequest request, int capacity) Performs a search operation with the NotificationControl.

Methods inherited from class java.lang.Object

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

Field Detail

logger

protected final org.slf4j.Logger logger

Logger for this class.

connection

private final Connection connection

Connection to invoke the search operation on.

Constructor Detail

NotificationClient

public NotificationClient(Connection conn)

Creates a new notification client.

Parameters:

conn - to execute the search operation on

Method Detail

execute

public java.util.concurrent.BlockingQueue<NotificationClient.NotificationItem> execute(SearchRequest request)
                                                                                throws LdapException

Invokes execute(SearchRequest, int) with a capacity of Integer.MAX_VALUE.

Parameters:

request - search request to execute

Returns:

blocking queue to wait for search entries

Throws:

LdapException - if the search fails

execute

public java.util.concurrent.BlockingQueue<NotificationClient.NotificationItem> execute(SearchRequest request,
                                                                                       int capacity)
                                                                                throws LdapException

Performs a search operation with the NotificationControl. The supplied request is modified in the following way:

• AbstractRequest.setControls( org.ldaptive.control.RequestControl...) is invoked with NotificationControl
• SearchRequest.setSearchEntryHandlers(SearchEntryHandler...) is invoked with a custom handler that places notification data in a blocking queue. The ObjectGuidHandler and ObjectSidHandler handlers are included as well.
• AbstractAsyncOperation.setExceptionHandler(ExceptionHandler) is invoked with a custom handler that places the exception in a blocking queue.

The search request object should not be reused for any other search operations.

Parameters:

request - search request to execute

capacity - of the returned blocking queue

Returns:

blocking queue to wait for search entries

Throws:

LdapException - if the search fails

abandon

public void abandon(int messageId)
             throws LdapException

Invokes an abandon operation on the supplied ldap message id. Convenience method supplied to abandon async search operations.

Parameters:

messageId - of the operation to abandon

Throws:

LdapException - if the abandon operation fails