com.communote.plugins.mq.provider.activemq.security

Class CommunoteUsernamePasswordJaasAuthenticationBroker

java.lang.Object

org.apache.activemq.broker.BrokerFilter

com.communote.plugins.mq.provider.activemq.security.CommunoteUsernamePasswordJaasAuthenticationBroker

All Implemented Interfaces:

org.apache.activemq.broker.Broker, org.apache.activemq.broker.region.Region, org.apache.activemq.Service

public class CommunoteUsernamePasswordJaasAuthenticationBroker
extends org.apache.activemq.broker.BrokerFilter

Authentication broker filter implementation

Author:

Communote GmbH - http://www.communote.com/

Field Summary

Fields inherited from class org.apache.activemq.broker.BrokerFilter

next

Constructor Summary

Constructors

Constructor and Description
CommunoteUsernamePasswordJaasAuthenticationBroker(org.apache.activemq.broker.Broker next, String jaasConfiguration)

Method Summary

Modifier and Type	Method and Description
void	addConnection(org.apache.activemq.broker.ConnectionContext context, org.apache.activemq.command.ConnectionInfo info)
void	refresh() Previously logged in users may no longer have the same access anymore.
void	removeConnection(org.apache.activemq.broker.ConnectionContext context, org.apache.activemq.command.ConnectionInfo info, Throwable error)

Methods inherited from class org.apache.activemq.broker.BrokerFilter

acknowledge, addBroker, addConsumer, addDestination, addDestinationInfo, addProducer, addSession, beginTransaction, brokerServiceStarted, commitTransaction, fastProducer, forgetTransaction, gc, getAdaptor, getAdminConnectionContext, getBrokerId, getBrokerName, getBrokerSequenceId, getBrokerService, getClients, getDestinationMap, getDestinations, getDestinations, getDurableDestinations, getExecutor, getPeerBrokerInfos, getPreparedTransactions, getRoot, getScheduler, getTempDataStore, getVmConnectorURI, isExpired, isFaultTolerantConfiguration, isFull, isStopped, messageConsumed, messageDelivered, messageDiscarded, messageExpired, messagePull, networkBridgeStarted, networkBridgeStopped, nowMasterBroker, postProcessDispatch, prepareTransaction, preProcessDispatch, processConsumerControl, processDispatchNotification, removeBroker, removeConsumer, removeDestination, removeDestinationInfo, removeProducer, removeSession, removeSubscription, rollbackTransaction, send, sendToDeadLetterQueue, setAdminConnectionContext, slowConsumer, start, stop

Methods inherited from class java.lang.Object

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

Constructor Detail

CommunoteUsernamePasswordJaasAuthenticationBroker

public CommunoteUsernamePasswordJaasAuthenticationBroker(org.apache.activemq.broker.Broker next,
                                                         String jaasConfiguration)

Parameters:

next - next broker filter in the chain

jaasConfiguration - jaas configuration name

Method Detail

addConnection

public void addConnection(org.apache.activemq.broker.ConnectionContext context,
                          org.apache.activemq.command.ConnectionInfo info)
                   throws Exception

Specified by:

addConnection in interface org.apache.activemq.broker.Broker

Overrides:

addConnection in class org.apache.activemq.broker.BrokerFilter

Throws:

Exception

refresh

public void refresh()

Previously logged in users may no longer have the same access anymore. Refresh all the logged into users.

removeConnection

public void removeConnection(org.apache.activemq.broker.ConnectionContext context,
                             org.apache.activemq.command.ConnectionInfo info,
                             Throwable error)
                      throws Exception

Specified by:

removeConnection in interface org.apache.activemq.broker.Broker

Overrides:

removeConnection in class org.apache.activemq.broker.BrokerFilter

Throws:

Exception