org.apache.activemq.security
Class CachedLDAPAuthorizationMap

java.lang.Object
  extended by org.apache.activemq.filter.DestinationMap
      extended by org.apache.activemq.security.DefaultAuthorizationMap
          extended by 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
CachedLDAPAuthorizationMap()
           
 
Method Summary
 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)


Copyright © 2005-2016. All Rights Reserved.