Package com.netscape.jndi.ldap

Class EventService

java.lang.Object

com.netscape.jndi.ldap.EventService

All Implemented Interfaces:

Runnable

class EventService
extends Object
implements Runnable

Event Service monitors changes on the server Implemented with the persistent search control. Uses ldapjdk asynchronous interfaces so that multiple search requests can be processed by a single thread

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	EventService.EventEntry	Inner class that represents a binding between a change event, described with a set of search parameters, and a list of listeners

Field Summary

Fields

Modifier and Type	Field	Description
(package private) Vector<EventService.EventEntry>	m_eventList
(package private) LdapService	m_ldapSvc
(package private) Thread	m_monitorThread
(package private) LDAPSearchListener	m_msgQueue

Constructor Summary

Constructors

Constructor	Description
EventService(LdapService ldapSvc)	Constructor

Method Summary

Modifier and Type	Method	Description
private void	abandonRequest(int id)	Abandon LDAP request with the specified message ID
(package private) void	addListener(LdapContextImpl ctx, String name, String filter, SearchControls jndiCtrls, NamingListener l)	Add change event listener
private NamingEvent	createNamingEvent(LdapContextImpl ctx, LDAPEntry entry, LDAPEntryChangeControl changeCtrl)	Create naming event from a change control
private LDAPPersistSearchControl	createSrchCtrl(NamingListener listener)	Create a persistent search control.
private void	dispatchEvent(EventObject event, EventService.EventEntry eventEntry)	Dispatch naming event to all listeners
private EventService.EventEntry	getEventEntry(int id)	Find event entry by message ID
private void	processNetworkError(LDAPException ex)	On network error, create NamingExceptionEvent and delever it to all listeners on all events.
private void	processResponseMsg(LDAPResponse rsp, EventService.EventEntry ee)	Response message carries a LDAP error.
private void	processSearchResultMsg(LDAPSearchResult res, EventService.EventEntry ee)	Process change notification attached as the change control to the message
private void	processSearchResultRef(LDAPSearchResultReference ref, EventService.EventEntry ee)	Search continuation messages are ignored.
(package private) void	removeListener(NamingListener listener)	Remove change event listener
void	run()	Main monitor thread loop.

Methods inherited from class java.lang.Object

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

Field Details

m_ldapSvc

LdapService m_ldapSvc

m_eventList

Vector<EventService.EventEntry> m_eventList

m_monitorThread

Thread m_monitorThread

m_msgQueue

LDAPSearchListener m_msgQueue

Constructor Details

EventService

public EventService(LdapService ldapSvc)

Constructor

Method Details

addListener

void addListener(LdapContextImpl ctx,
 String name,
 String filter,
 SearchControls jndiCtrls,
 NamingListener l)
          throws NamingException

Add change event listener

Throws:

NamingException

removeListener

void removeListener(NamingListener listener)
             throws NamingException

Remove change event listener

Throws:

NamingException

abandonRequest

private void abandonRequest(int id)

Abandon LDAP request with the specified message ID

run

public void run()

Main monitor thread loop. Wait for persistent search change notifications

Specified by:

run in interface Runnable

processNetworkError

private void processNetworkError(LDAPException ex)

On network error, create NamingExceptionEvent and delever it to all listeners on all events.

processResponseMsg

private void processResponseMsg(LDAPResponse rsp,
 EventService.EventEntry ee)

Response message carries a LDAP error. Response with the code 0 (SUCCESS), should never be received as persistent search never completes, it has to be abandon. Referral messages are ignored

processSearchResultMsg

private void processSearchResultMsg(LDAPSearchResult res,
 EventService.EventEntry ee)

Process change notification attached as the change control to the message

processSearchResultRef

private void processSearchResultRef(LDAPSearchResultReference ref,
 EventService.EventEntry ee)

Search continuation messages are ignored.

getEventEntry

private EventService.EventEntry getEventEntry(int id)

Find event entry by message ID

dispatchEvent

private void dispatchEvent(EventObject event,
 EventService.EventEntry eventEntry)

Dispatch naming event to all listeners

createNamingEvent

private NamingEvent createNamingEvent(LdapContextImpl ctx,
 LDAPEntry entry,
 LDAPEntryChangeControl changeCtrl)
                               throws NamingException

Create naming event from a change control

Throws:

NamingException

createSrchCtrl

private LDAPPersistSearchControl createSrchCtrl(NamingListener listener)
                                         throws NamingException

Create a persistent search control.

Throws:

NamingException