public class LdapNetworkConnector extends NetworkConnector implements NamespaceChangeListener, ObjectChangeListener
bridges, connectionFilter, localURI, serviceSupport
dynamicallyIncludedDestinations, excludedDestinations, staticallyIncludedDestinations
Constructor and Description |
---|
LdapNetworkConnector() |
Modifier and Type | Method and Description |
---|---|
protected void |
addConnector(SearchResult result)
add connector of the given URI
|
URI |
getUri()
returns the next URI from the configured list
|
void |
namingExceptionThrown(NamingExceptionEvent event)
invoked when an exception has occurred during a persistent search
|
void |
objectAdded(NamingEvent event)
invoked when an entry has been added during a persistent search
|
void |
objectChanged(NamingEvent event)
invoked when an entry has been changed during a persistent search
|
void |
objectRemoved(NamingEvent event)
invoked when an entry has been removed during a persistent search
|
void |
objectRenamed(NamingEvent event)
invoked when an entry has been renamed during a persistent search
|
protected void |
removeConnector(SearchResult result)
remove connector of the given URI
|
void |
setAnonymousAuthentication(boolean anonymousAuthentication)
sets LDAP anonymous authentication access credentials
|
void |
setBase(String base)
sets the base LDAP dn used for lookup operations
|
void |
setPassword(String password)
sets the LDAP password for access credentials
|
void |
setSearchEventListener(boolean searchEventListener)
enables/disable a persistent search to the LDAP server as defined in
draft-ietf-ldapext-psearch-03.txt (2.16.840.1.113730.3.4.3)
|
void |
setSearchFilter(String searchFilter)
sets the LDAP search filter as defined in RFC 2254
|
void |
setSearchScope(String searchScope)
sets the LDAP search scope
|
void |
setUri(URI uri)
sets the LDAP server URI
|
void |
setUser(String user)
sets the LDAP user for access credentials
|
void |
start()
start the connector
|
void |
stop()
stop the connector
|
String |
toString() |
protected URI |
toURI(SearchResult result)
convert search result into URI
|
protected String |
toUUID(SearchResult result)
convert search result into URI
|
activeBridges, addDynamicallyIncludedDestination, addExcludedDestination, addStaticallyIncludedDestination, configureBridge, createLocalTransport, createNetworkBridgeObjectName, getBrokerService, getConnectionFilter, getDurableDestinations, getLocalUri, getObjectName, handleStart, handleStop, isStarted, isStopped, isStopping, registerNetworkBridgeMBean, removeDemandSubscription, setBrokerService, setConnectionFilter, setDurableDestinations, setLocalUri, setObjectName, unregisterNetworkBridgeMBean
getBrokerName, getBrokerURL, getConsumerPriorityBase, getConsumerTTL, getDestinationFilter, getDynamicallyIncludedDestinations, getExcludedDestinations, getGcSweepTime, getMessageTTL, getName, getNetworkTTL, getPassword, getPrefetchSize, getStaticallyIncludedDestinations, getUserName, isAdvisoryForFailedForward, isAlwaysSyncSend, isBridgeTempDestinations, isCheckDuplicateMessagesOnDuplex, isConduitSubscriptions, isDecreaseNetworkConsumerPriority, isDispatchAsync, isDuplex, isDynamicOnly, isGcDestinationViews, isStaticBridge, isSuppressDuplicateQueueSubscriptions, isSuppressDuplicateTopicSubscriptions, isUseBrokerNamesAsIdSeed, isUseCompression, isUseVirtualDestSus, setAdvisoryForFailedForward, setAlwaysSyncSend, setBridgeTempDestinations, setBrokerName, setBrokerURL, setCheckDuplicateMessagesOnDuplex, setConduitSubscriptions, setConsumerPriorityBase, setConsumerTTL, setDecreaseNetworkConsumerPriority, setDestinationFilter, setDispatchAsync, setDuplex, setDynamicallyIncludedDestinations, setDynamicOnly, setExcludedDestinations, setGcDestinationViews, setGcSweepTime, setMessageTTL, setName, setNetworkTTL, setPrefetchSize, setStaticallyIncludedDestinations, setStaticBridge, setSuppressDuplicateQueueSubscriptions, setSuppressDuplicateTopicSubscriptions, setUseBrokerNameAsIdSees, setUseCompression, setUserName, setUseVirtualDestSubs
public LdapNetworkConnector()
public URI getUri()
public void setUri(URI uri) throws Exception
_uri
- LDAP server URIException
public void setBase(String base)
_base
- LDAP base dnpublic void setUser(String user)
_user
- LDAP dn of userpublic void setPassword(String password)
setPassword
in class NetworkBridgeConfiguration
_password
- user passwordpublic void setAnonymousAuthentication(boolean anonymousAuthentication)
_anonymousAuthentication
- set to true to use anonymous authenticationpublic void setSearchScope(String searchScope) throws Exception
_searchScope
- LDAP JNDI search scopeException
public void setSearchFilter(String searchFilter)
_searchFilter
- LDAP search filterpublic void setSearchEventListener(boolean searchEventListener)
_searchEventListener
- enable = true, disable = false (default)public void start() throws Exception
start
in interface Service
start
in class NetworkConnector
Exception
public void stop() throws Exception
stop
in interface Service
stop
in class NetworkConnector
Exception
protected void addConnector(SearchResult result) throws Exception
result
- search result of connector to addException
protected void removeConnector(SearchResult result) throws Exception
result
- search result of connector to removeException
protected URI toURI(SearchResult result) throws Exception
result
- search result to convert to URIException
protected String toUUID(SearchResult result)
result
- search result to convert to URIpublic void objectAdded(NamingEvent event)
objectAdded
in interface NamespaceChangeListener
public void objectRemoved(NamingEvent event)
objectRemoved
in interface NamespaceChangeListener
public void objectRenamed(NamingEvent event)
objectRenamed
in interface NamespaceChangeListener
public void objectChanged(NamingEvent event)
objectChanged
in interface ObjectChangeListener
public void namingExceptionThrown(NamingExceptionEvent event)
namingExceptionThrown
in interface NamingListener
Copyright © 2005–2018 FuseSource, Corp.. All rights reserved.