org.apache.activemq.security

Class CachedLDAPAuthorizationMap

java.lang.Object

org.apache.activemq.filter.DestinationMap

org.apache.activemq.security.DefaultAuthorizationMap

org.apache.activemq.security.CachedLDAPAuthorizationMap

All Implemented Interfaces:

java.util.EventListener, javax.naming.event.NamespaceChangeListener, javax.naming.event.NamingListener, javax.naming.event.ObjectChangeListener, AuthorizationMap, org.springframework.beans.factory.InitializingBean

public class CachedLDAPAuthorizationMap
extends DefaultAuthorizationMap
implements javax.naming.event.NamespaceChangeListener, javax.naming.event.ObjectChangeListener, org.springframework.beans.factory.InitializingBean

A DefaultAuthorizationMap implementation which uses LDAP to initialize and update

Field Summary

Fields inherited from class org.apache.activemq.filter.DestinationMap

ANY_CHILD, ANY_DESCENDENT

Constructor Summary

Constructors

Constructor and Description
CachedLDAPAuthorizationMap()

Method Summary

Methods

Modifier and Type	Method and Description
void	afterPropertiesSet()
protected void	applyACL(AuthorizationEntry entry, javax.naming.directory.SearchResult result)
protected ActiveMQDestination	formatDestination(java.lang.String destinationName, java.lang.String destinationType)
protected java.lang.String	formatDestinationName(java.lang.String cn)
protected java.util.Set<AuthorizationEntry>	getAllEntries(ActiveMQDestination destination)
java.lang.String	getAuthentication()
java.lang.String	getBaseDn()
java.lang.String	getConnectionPassword()
java.lang.String	getConnectionProtocol()
java.lang.String	getConnectionURL()
java.lang.String	getConnectionUsername()
protected AuthorizationEntry	getEntry(java.lang.String name)
int	getRefreshInterval()
protected boolean	isPriviledge(javax.naming.Binding binding)
void	namingExceptionThrown(javax.naming.event.NamingExceptionEvent namingExceptionEvent)
void	objectAdded(javax.naming.event.NamingEvent namingEvent)
void	objectChanged(javax.naming.event.NamingEvent namingEvent)
void	objectRemoved(javax.naming.event.NamingEvent namingEvent)
void	objectRenamed(javax.naming.event.NamingEvent namingEvent)
protected javax.naming.directory.DirContext	open()
void	query()
void	setAuthentication(java.lang.String authentication)
void	setBaseDn(java.lang.String baseDn)
void	setConnectionPassword(java.lang.String connectionPassword)
void	setConnectionProtocol(java.lang.String connectionProtocol)
void	setConnectionURL(java.lang.String connectionURL)
void	setConnectionUsername(java.lang.String connectionUsername)
void	setRefreshInterval(int refreshInterval)
protected void	updated()

Methods inherited from class org.apache.activemq.security.DefaultAuthorizationMap

get, getAdminACLs, getDefaultEntry, getEntryClass, getEntryFor, getReadACLs, getTempDestinationAdminACLs, getTempDestinationAuthorizationEntry, getTempDestinationReadACLs, getTempDestinationWriteACLs, getWriteACLs, setAuthorizationEntries, setDefaultEntry, setTempDestinationAuthorizationEntry

Methods inherited from class org.apache.activemq.filter.DestinationMap

chooseValue, findWildcardMatches, getQueueRootChildCount, getQueueRootNode, getRootNode, getTempQueueRootNode, getTempTopicRootNode, getTopicRootChildCount, getTopicRootNode, put, remove, removeAll, reset, setEntries, union

Methods inherited from class java.lang.Object

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

Constructor Detail

CachedLDAPAuthorizationMap

public CachedLDAPAuthorizationMap()

Method Detail

open

protected javax.naming.directory.DirContext open()
                                          throws javax.naming.NamingException

Throws:

javax.naming.NamingException

query

public void query()
           throws java.lang.Exception

Throws:

java.lang.Exception

updated

protected void updated()

getEntry

protected AuthorizationEntry getEntry(java.lang.String name)

formatDestination

protected ActiveMQDestination formatDestination(java.lang.String destinationName,
                                    java.lang.String destinationType)

applyACL

protected void applyACL(AuthorizationEntry entry,
            javax.naming.directory.SearchResult result)
                 throws javax.naming.NamingException

Throws:

javax.naming.NamingException

formatDestinationName

protected java.lang.String formatDestinationName(java.lang.String cn)

isPriviledge

protected boolean isPriviledge(javax.naming.Binding binding)

getAllEntries

protected java.util.Set<AuthorizationEntry> getAllEntries(ActiveMQDestination destination)

Overrides:

getAllEntries in class DefaultAuthorizationMap

objectAdded

public void objectAdded(javax.naming.event.NamingEvent namingEvent)

Specified by:

objectAdded in interface javax.naming.event.NamespaceChangeListener

objectRemoved

public void objectRemoved(javax.naming.event.NamingEvent namingEvent)

Specified by:

objectRemoved in interface javax.naming.event.NamespaceChangeListener

objectRenamed

public void objectRenamed(javax.naming.event.NamingEvent namingEvent)

Specified by:

objectRenamed in interface javax.naming.event.NamespaceChangeListener

objectChanged

public void objectChanged(javax.naming.event.NamingEvent namingEvent)

Specified by:

objectChanged in interface javax.naming.event.ObjectChangeListener

namingExceptionThrown

public void namingExceptionThrown(javax.naming.event.NamingExceptionEvent namingExceptionEvent)

Specified by:

namingExceptionThrown in interface javax.naming.event.NamingListener

afterPropertiesSet

public void afterPropertiesSet()
                        throws java.lang.Exception

Specified by:

afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean

Throws:

java.lang.Exception

getConnectionURL

public java.lang.String getConnectionURL()

setConnectionURL

public void setConnectionURL(java.lang.String connectionURL)

getConnectionUsername

public java.lang.String getConnectionUsername()

setConnectionUsername

public void setConnectionUsername(java.lang.String connectionUsername)

getConnectionPassword

public java.lang.String getConnectionPassword()

setConnectionPassword

public void setConnectionPassword(java.lang.String connectionPassword)

getConnectionProtocol

public java.lang.String getConnectionProtocol()

setConnectionProtocol

public void setConnectionProtocol(java.lang.String connectionProtocol)

getAuthentication

public java.lang.String getAuthentication()

setAuthentication

public void setAuthentication(java.lang.String authentication)

getBaseDn

public java.lang.String getBaseDn()

setBaseDn

public void setBaseDn(java.lang.String baseDn)

getRefreshInterval

public int getRefreshInterval()

setRefreshInterval

public void setRefreshInterval(int refreshInterval)