public class ManagedRegionBroker extends RegionBroker
brokerService, connectionStates, destinationFactory, destinationStatistics, ORIGINAL_EXPIRATION
Constructor and Description |
---|
ManagedRegionBroker(BrokerService brokerService,
ManagementContext context,
ObjectName brokerObjectName,
TaskRunnerFactory taskRunnerFactory,
SystemUsage memoryManager,
DestinationFactory destinationFactory,
DestinationInterceptor destinationInterceptor,
Scheduler scheduler,
ThreadPoolExecutor executor) |
acknowledge, addBroker, addBrokerInClusterUpdate, addConnection, addDestination, addDestinationInfo, beginTransaction, brokerServiceStarted, commitTransaction, createUnknownDestinationTypeException, forgetTransaction, gc, getAdaptor, getAdminConnectionContext, getBrokerId, getBrokerName, getBrokerSequenceId, getBrokerService, getClients, getConnectionStates, getDestinationInterceptor, getDestinationMap, getDestinationPolicy, getDestinations, getDestinations, getDestinationStatistics, getDurableDestinations, getExecutor, getPeerBrokerInfos, getPreparedTransactions, getQueueRegion, getRoot, getScheduler, getTempDataStore, getTempQueueRegion, getTempTopicRegion, getTopicRegion, getVmConnectorURI, isAllowTempAutoCreationOnSend, isEqual, isExpired, isKeepDurableSubsActive, isSlaveBroker, isStopped, messageExpired, messagePull, postProcessDispatch, prepareTransaction, preProcessDispatch, processConsumerControl, processDispatchNotification, purgeInactiveDestinations, removeBroker, removeBrokerInClusterUpdate, removeConnection, removeDestination, removeDestinationInfo, removeSubscription, rollbackTransaction, sendToDeadLetterQueue, setAdminConnectionContext, setAllowTempAutoCreationOnSend, setBrokerId, setBrokerName, setKeepDurableSubsActive, stop
addSession, fastProducer, isFaultTolerantConfiguration, isFull, messageConsumed, messageDelivered, messageDiscarded, networkBridgeStarted, networkBridgeStopped, nowMasterBroker, removeSession, slowConsumer
public ManagedRegionBroker(BrokerService brokerService, ManagementContext context, ObjectName brokerObjectName, TaskRunnerFactory taskRunnerFactory, SystemUsage memoryManager, DestinationFactory destinationFactory, DestinationInterceptor destinationInterceptor, Scheduler scheduler, ThreadPoolExecutor executor) throws IOException
IOException
public void start() throws Exception
start
in interface Service
start
in class RegionBroker
Exception
protected void doStop(ServiceStopper stopper)
doStop
in class RegionBroker
protected Region createQueueRegion(SystemUsage memoryManager, TaskRunnerFactory taskRunnerFactory, DestinationFactory destinationFactory)
createQueueRegion
in class RegionBroker
protected Region createTempQueueRegion(SystemUsage memoryManager, TaskRunnerFactory taskRunnerFactory, DestinationFactory destinationFactory)
createTempQueueRegion
in class RegionBroker
protected Region createTempTopicRegion(SystemUsage memoryManager, TaskRunnerFactory taskRunnerFactory, DestinationFactory destinationFactory)
createTempTopicRegion
in class RegionBroker
protected Region createTopicRegion(SystemUsage memoryManager, TaskRunnerFactory taskRunnerFactory, DestinationFactory destinationFactory)
createTopicRegion
in class RegionBroker
public void register(ActiveMQDestination destName, Destination destination)
public void unregister(ActiveMQDestination destName)
public ObjectName registerSubscription(ConnectionContext context, Subscription sub)
public static String getSubscriptionObjectName(ConsumerInfo info, String connectionClientId, ObjectName brokerJmxObjectName)
public Subscription addConsumer(ConnectionContext context, ConsumerInfo info) throws Exception
Region
addConsumer
in interface Region
addConsumer
in class RegionBroker
context
- the environment the operation is being executed under.Exception
- TODOpublic void removeConsumer(ConnectionContext context, ConsumerInfo info) throws Exception
Region
removeConsumer
in interface Region
removeConsumer
in class RegionBroker
context
- the environment the operation is being executed under.Exception
- TODOpublic void addProducer(ConnectionContext context, ProducerInfo info) throws Exception
Broker
addProducer
in interface Broker
addProducer
in interface Region
addProducer
in class RegionBroker
context
- the enviorment the operation is being executed under.Exception
- TODOpublic void removeProducer(ConnectionContext context, ProducerInfo info) throws Exception
Broker
removeProducer
in interface Broker
removeProducer
in interface Region
removeProducer
in class RegionBroker
context
- the enviorment the operation is being executed under.Exception
- TODOpublic void send(ProducerBrokerExchange exchange, Message message) throws Exception
Region
send
in interface Region
send
in class RegionBroker
exchange
- the environment the operation is being executed under.Exception
- TODOpublic void unregisterSubscription(Subscription sub)
protected void registerDestination(ObjectName key, ActiveMQDestination dest, DestinationView view) throws Exception
Exception
protected void unregisterDestination(ObjectName key) throws Exception
Exception
protected void registerProducer(ObjectName key, ActiveMQDestination dest, ProducerView view) throws Exception
Exception
protected void unregisterProducer(ObjectName key) throws Exception
Exception
protected void registerSubscription(ObjectName key, ConsumerInfo info, SubscriptionKey subscriptionKey, SubscriptionView view) throws Exception
Exception
protected void unregisterSubscription(ObjectName key, boolean addToInactive) throws Exception
Exception
protected void buildExistingSubscriptions() throws Exception
Exception
protected void addInactiveSubscription(SubscriptionKey key, SubscriptionInfo info, Subscription subscription)
public CompositeData[] browse(SubscriptionView view) throws OpenDataException
OpenDataException
public TabularData browseAsTable(SubscriptionView view) throws OpenDataException
OpenDataException
protected List<Message> getSubscriberMessages(SubscriptionView view)
protected ObjectName[] getTopics()
protected ObjectName[] getQueues()
protected ObjectName[] getTemporaryTopics()
protected ObjectName[] getTemporaryQueues()
protected ObjectName[] getTopicSubscribers()
protected ObjectName[] getDurableTopicSubscribers()
protected ObjectName[] getQueueSubscribers()
protected ObjectName[] getTemporaryTopicSubscribers()
protected ObjectName[] getTemporaryQueueSubscribers()
protected ObjectName[] getInactiveDurableTopicSubscribers()
protected ObjectName[] getTopicProducers()
protected ObjectName[] getQueueProducers()
protected ObjectName[] getTemporaryTopicProducers()
protected ObjectName[] getTemporaryQueueProducers()
protected ObjectName[] getDynamicDestinationProducers()
public Broker getContextBroker()
public void setContextBroker(Broker contextBroker)
protected ObjectName createObjectName(ActiveMQDestination destName) throws MalformedObjectNameException
MalformedObjectNameException
protected ObjectName createObjectName(ProducerInfo producerInfo, String connectionClientId) throws MalformedObjectNameException
MalformedObjectNameException
public ObjectName registerSlowConsumerStrategy(AbortSlowConsumerStrategy strategy) throws MalformedObjectNameException
MalformedObjectNameException
protected ObjectName createObjectName(XATransaction transaction) throws MalformedObjectNameException
MalformedObjectNameException
public void registerRecoveredTransactionMBean(XATransaction transaction)
public void unregister(XATransaction transaction)
public ObjectName getSubscriberObjectName(Subscription key)
public Subscription getSubscriber(ObjectName key)
Copyright © 2005–2015. All rights reserved.