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:

EventListener, NamespaceChangeListener, NamingListener, ObjectChangeListener, AuthorizationMap, org.springframework.beans.factory.InitializingBean

public class CachedLDAPAuthorizationMap
extends DefaultAuthorizationMap
implements NamespaceChangeListener, 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, SearchResult result)
protected ActiveMQDestination	formatDestination(String destinationName, String destinationType)
protected String	formatDestinationName(String cn)
protected Set<AuthorizationEntry>	getAllEntries(ActiveMQDestination destination)
String	getAuthentication()
String	getBaseDn()
String	getConnectionPassword()
String	getConnectionProtocol()
String	getConnectionURL()
String	getConnectionUsername()
protected AuthorizationEntry	getEntry(String name)
int	getRefreshInterval()
protected boolean	isPriviledge(Binding binding)
void	namingExceptionThrown(NamingExceptionEvent namingExceptionEvent)
void	objectAdded(NamingEvent namingEvent)
void	objectChanged(NamingEvent namingEvent)
void	objectRemoved(NamingEvent namingEvent)
void	objectRenamed(NamingEvent namingEvent)
protected DirContext	open()
void	query()
void	setAuthentication(String authentication)
void	setBaseDn(String baseDn)
void	setConnectionPassword(String connectionPassword)
void	setConnectionProtocol(String connectionProtocol)
void	setConnectionURL(String connectionURL)
void	setConnectionUsername(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 DirContext open()
                   throws NamingException

Throws:

NamingException

query

public void query()
           throws Exception

Throws:

Exception

updated

protected void updated()

getEntry

protected AuthorizationEntry getEntry(String name)

formatDestination

protected ActiveMQDestination formatDestination(String destinationName,
                                    String destinationType)

applyACL

protected void applyACL(AuthorizationEntry entry,
            SearchResult result)
                 throws NamingException

Throws:

NamingException

formatDestinationName

protected String formatDestinationName(String cn)

isPriviledge

protected boolean isPriviledge(Binding binding)

getAllEntries

protected Set<AuthorizationEntry> getAllEntries(ActiveMQDestination destination)

Overrides:

getAllEntries in class DefaultAuthorizationMap

objectAdded

public void objectAdded(NamingEvent namingEvent)

Specified by:

objectAdded in interface NamespaceChangeListener

objectRemoved

public void objectRemoved(NamingEvent namingEvent)

Specified by:

objectRemoved in interface NamespaceChangeListener

objectRenamed

public void objectRenamed(NamingEvent namingEvent)

Specified by:

objectRenamed in interface NamespaceChangeListener

objectChanged

public void objectChanged(NamingEvent namingEvent)

Specified by:

objectChanged in interface ObjectChangeListener

namingExceptionThrown

public void namingExceptionThrown(NamingExceptionEvent namingExceptionEvent)

Specified by:

namingExceptionThrown in interface NamingListener

afterPropertiesSet

public void afterPropertiesSet()
                        throws Exception

Specified by:

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

Throws:

Exception

getConnectionURL

public String getConnectionURL()

setConnectionURL

public void setConnectionURL(String connectionURL)

getConnectionUsername

public String getConnectionUsername()

setConnectionUsername

public void setConnectionUsername(String connectionUsername)

getConnectionPassword

public String getConnectionPassword()

setConnectionPassword

public void setConnectionPassword(String connectionPassword)

getConnectionProtocol

public String getConnectionProtocol()

setConnectionProtocol

public void setConnectionProtocol(String connectionProtocol)

getAuthentication

public String getAuthentication()

setAuthentication

public void setAuthentication(String authentication)

getBaseDn

public String getBaseDn()

setBaseDn

public void setBaseDn(String baseDn)

getRefreshInterval

public int getRefreshInterval()

setRefreshInterval

public void setRefreshInterval(int refreshInterval)