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

Class CommunoteJaasAuthenticationBroker

java.lang.Object

org.apache.activemq.broker.BrokerFilter

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

All Implemented Interfaces:

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

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

A Jaas Authenticator that will either use a certificate or a username password authentication based on the settings and the connection.

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
CommunoteJaasAuthenticationBroker(MQSettingsDAO settingsDao, ActiveMQEmbeddedConfiguration embeddedConfiguration, org.apache.activemq.broker.Broker next, String jaasConfiguration, String jaasSslConfiguration) Simple constructor.

Method Summary

Modifier and Type	Method and Description
void	addConnection(org.apache.activemq.broker.ConnectionContext context, org.apache.activemq.command.ConnectionInfo info) Overridden to allow for authentication using different Jaas configurations depending on if the connection is SSL or not.
void	removeConnection(org.apache.activemq.broker.ConnectionContext context, org.apache.activemq.command.ConnectionInfo info, Throwable error)
void	send(org.apache.activemq.broker.ProducerBrokerExchange producerExchange, org.apache.activemq.command.Message messageSend)

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, 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

CommunoteJaasAuthenticationBroker

public CommunoteJaasAuthenticationBroker(MQSettingsDAO settingsDao,
                                         ActiveMQEmbeddedConfiguration embeddedConfiguration,
                                         org.apache.activemq.broker.Broker next,
                                         String jaasConfiguration,
                                         String jaasSslConfiguration)

Simple constructor. Leaves everything to superclass.

Parameters:

settingsDao - the settings dao

embeddedConfiguration - the embedded configuration

next - The Broker that does the actual work for this Filter.

jaasConfiguration - The JAAS domain configuration name for non-SSL connections (refer to JAAS documentation).

jaasSslConfiguration - The JAAS domain configuration name for SSL connections (refer to JAAS documentation).

Method Detail

addConnection

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

Overridden to allow for authentication using different Jaas configurations depending on if the connection is SSL or not.

Specified by:

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

Overrides:

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

Parameters:

context - The context for the incoming Connection.

info - The ConnectionInfo Command representing the incoming connection.

Throws:

Exception - in case of an error

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

send

public void send(org.apache.activemq.broker.ProducerBrokerExchange producerExchange,
                 org.apache.activemq.command.Message messageSend)
          throws Exception

Specified by:

send in interface org.apache.activemq.broker.region.Region

Overrides:

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

Throws:

Exception