edu.internet2.middleware.grouperActivemq

Class GrouperBroker

java.lang.Object

org.apache.activemq.broker.BrokerFilter

edu.internet2.middleware.grouperActivemq.GrouperBroker

All Implemented Interfaces:

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

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

my broker

Field Summary

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

next

Constructor Summary

Constructors

Constructor and Description
GrouperBroker(org.apache.activemq.broker.Broker next1)

Method Summary

Modifier and Type	Method and Description
void	addConnection(org.apache.activemq.broker.ConnectionContext context, org.apache.activemq.command.ConnectionInfo info)
org.apache.activemq.broker.region.Subscription	addConsumer(org.apache.activemq.broker.ConnectionContext context, org.apache.activemq.command.ConsumerInfo info)
org.apache.activemq.broker.region.Destination	addDestination(org.apache.activemq.broker.ConnectionContext context, org.apache.activemq.command.ActiveMQDestination destination, boolean create)
void	addDestinationInfo(org.apache.activemq.broker.ConnectionContext context, org.apache.activemq.command.DestinationInfo info)
void	addProducer(org.apache.activemq.broker.ConnectionContext context, org.apache.activemq.command.ProducerInfo info)
void	addSession(org.apache.activemq.broker.ConnectionContext context, org.apache.activemq.command.SessionInfo info)
void	removeConnection(org.apache.activemq.broker.ConnectionContext context, org.apache.activemq.command.ConnectionInfo info, Throwable error)
void	removeConsumer(org.apache.activemq.broker.ConnectionContext context, org.apache.activemq.command.ConsumerInfo info)
void	removeDestination(org.apache.activemq.broker.ConnectionContext context, org.apache.activemq.command.ActiveMQDestination destination, long timeout)
void	removeDestinationInfo(org.apache.activemq.broker.ConnectionContext context, org.apache.activemq.command.DestinationInfo info)
void	removeProducer(org.apache.activemq.broker.ConnectionContext context, org.apache.activemq.command.ProducerInfo info)
void	removeSession(org.apache.activemq.broker.ConnectionContext context, org.apache.activemq.command.SessionInfo info)
void	removeSubscription(org.apache.activemq.broker.ConnectionContext context, org.apache.activemq.command.RemoveSubscriptionInfo info)
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, 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, 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

GrouperBroker

public GrouperBroker(org.apache.activemq.broker.Broker next1)

Parameters:

next1 -

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

See Also:

BrokerFilter.addConnection(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.ConnectionInfo)

addSession

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

Specified by:

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

Overrides:

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

Throws:

Exception

See Also:

BrokerFilter.addSession(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.SessionInfo)

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

See Also:

BrokerFilter.removeConnection(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.ConnectionInfo, java.lang.Throwable)

removeConsumer

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

Specified by:

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

Overrides:

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

Throws:

Exception

See Also:

BrokerFilter.removeConsumer(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.ConsumerInfo)

removeDestinationInfo

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

Specified by:

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

Overrides:

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

Throws:

Exception

See Also:

BrokerFilter.removeDestinationInfo(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.DestinationInfo)

removeProducer

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

Specified by:

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

Specified by:

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

Overrides:

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

Throws:

Exception

See Also:

BrokerFilter.removeProducer(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.ProducerInfo)

removeSession

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

Specified by:

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

Overrides:

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

Throws:

Exception

See Also:

BrokerFilter.removeSession(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.SessionInfo)

removeSubscription

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

Specified by:

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

Overrides:

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

Throws:

Exception

See Also:

BrokerFilter.removeSubscription(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.RemoveSubscriptionInfo)

addDestinationInfo

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

Specified by:

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

Overrides:

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

Throws:

Exception

See Also:

BrokerFilter.addDestinationInfo(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.DestinationInfo)

addDestination

public org.apache.activemq.broker.region.Destination addDestination(org.apache.activemq.broker.ConnectionContext context,
                                                                    org.apache.activemq.command.ActiveMQDestination destination,
                                                                    boolean create)
                                                             throws Exception

Specified by:

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

Overrides:

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

Throws:

Exception

See Also:

BrokerFilter.addDestination(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.ActiveMQDestination, boolean)

removeDestination

public void removeDestination(org.apache.activemq.broker.ConnectionContext context,
                              org.apache.activemq.command.ActiveMQDestination destination,
                              long timeout)
                       throws Exception

Specified by:

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

Overrides:

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

Throws:

Exception

See Also:

BrokerFilter.removeDestination(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.ActiveMQDestination, long)

addConsumer

public org.apache.activemq.broker.region.Subscription addConsumer(org.apache.activemq.broker.ConnectionContext context,
                                                                  org.apache.activemq.command.ConsumerInfo info)
                                                           throws Exception

Specified by:

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

Overrides:

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

Throws:

Exception

See Also:

BrokerFilter.addConsumer(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.ConsumerInfo)

addProducer

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

Specified by:

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

Specified by:

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

Overrides:

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

Throws:

Exception

See Also:

BrokerFilter.addProducer(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.ProducerInfo)

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

See Also:

BrokerFilter.send(org.apache.activemq.broker.ProducerBrokerExchange, org.apache.activemq.command.Message)