edu.internet2.middleware.grouperActivemq

Class MyBroker

java.lang.Object

org.apache.activemq.broker.BrokerFilter

edu.internet2.middleware.grouperActivemq.MyBroker

All Implemented Interfaces:

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

public class MyBroker
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
MyBroker(org.apache.activemq.broker.Broker next1)

Method Summary

Modifier and Type	Method and Description
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	removeDestination(org.apache.activemq.broker.ConnectionContext context, org.apache.activemq.command.ActiveMQDestination destination, long timeout)
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, addConnection, 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, removeConnection, removeConsumer, 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

MyBroker

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

Parameters:

next1 -

Method Detail

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)