public class ManagedRegionBroker extends RegionBroker
brokerService, connectionStates, destinationFactory, destinationStatistics, ORIGINAL_EXPIRATION
Constructor and Description |
---|
ManagedRegionBroker(BrokerService brokerService,
ManagementContext context,
javax.management.ObjectName brokerObjectName,
TaskRunnerFactory taskRunnerFactory,
SystemUsage memoryManager,
DestinationFactory destinationFactory,
DestinationInterceptor destinationInterceptor,
Scheduler scheduler,
java.util.concurrent.ThreadPoolExecutor executor) |
Modifier and Type | Method and Description |
---|---|
Subscription |
addConsumer(ConnectionContext context,
ConsumerInfo info)
Adds a consumer.
|
protected void |
addInactiveSubscription(SubscriptionKey key,
SubscriptionInfo info,
Subscription subscription) |
void |
addProducer(ConnectionContext context,
ProducerInfo info)
Adds a producer.
|
javax.management.openmbean.CompositeData[] |
browse(SubscriptionView view) |
javax.management.openmbean.TabularData |
browseAsTable(SubscriptionView view) |
protected void |
buildExistingSubscriptions() |
protected javax.management.ObjectName |
createObjectName(ActiveMQDestination destName) |
protected javax.management.ObjectName |
createObjectName(ProducerInfo producerInfo,
java.lang.String connectionClientId) |
protected javax.management.ObjectName |
createObjectName(XATransaction transaction) |
protected Region |
createQueueRegion(SystemUsage memoryManager,
TaskRunnerFactory taskRunnerFactory,
DestinationFactory destinationFactory) |
protected Region |
createTempQueueRegion(SystemUsage memoryManager,
TaskRunnerFactory taskRunnerFactory,
DestinationFactory destinationFactory) |
protected Region |
createTempTopicRegion(SystemUsage memoryManager,
TaskRunnerFactory taskRunnerFactory,
DestinationFactory destinationFactory) |
protected Region |
createTopicRegion(SystemUsage memoryManager,
TaskRunnerFactory taskRunnerFactory,
DestinationFactory destinationFactory) |
protected void |
doStop(ServiceStopper stopper) |
Broker |
getContextBroker() |
protected javax.management.ObjectName[] |
getDurableTopicSubscribers() |
protected javax.management.ObjectName[] |
getDynamicDestinationProducers() |
protected javax.management.ObjectName[] |
getInactiveDurableTopicSubscribers() |
protected javax.management.ObjectName[] |
getQueueProducers() |
protected javax.management.ObjectName[] |
getQueues() |
protected javax.management.ObjectName[] |
getQueueSubscribers() |
Subscription |
getSubscriber(javax.management.ObjectName key) |
protected java.util.List<Message> |
getSubscriberMessages(SubscriptionView view) |
javax.management.ObjectName |
getSubscriberObjectName(Subscription key) |
static java.lang.String |
getSubscriptionObjectName(ConsumerInfo info,
java.lang.String connectionClientId,
javax.management.ObjectName brokerJmxObjectName) |
protected javax.management.ObjectName[] |
getTemporaryQueueProducers() |
protected javax.management.ObjectName[] |
getTemporaryQueues() |
protected javax.management.ObjectName[] |
getTemporaryQueueSubscribers() |
protected javax.management.ObjectName[] |
getTemporaryTopicProducers() |
protected javax.management.ObjectName[] |
getTemporaryTopics() |
protected javax.management.ObjectName[] |
getTemporaryTopicSubscribers() |
protected javax.management.ObjectName[] |
getTopicProducers() |
protected javax.management.ObjectName[] |
getTopics() |
protected javax.management.ObjectName[] |
getTopicSubscribers() |
void |
register(ActiveMQDestination destName,
Destination destination) |
protected void |
registerDestination(javax.management.ObjectName key,
ActiveMQDestination dest,
DestinationView view) |
protected void |
registerProducer(javax.management.ObjectName key,
ActiveMQDestination dest,
ProducerView view) |
void |
registerRecoveredTransactionMBean(XATransaction transaction) |
javax.management.ObjectName |
registerSlowConsumerStrategy(AbortSlowConsumerStrategy strategy) |
javax.management.ObjectName |
registerSubscription(ConnectionContext context,
Subscription sub) |
protected void |
registerSubscription(javax.management.ObjectName key,
ConsumerInfo info,
SubscriptionKey subscriptionKey,
SubscriptionView view) |
void |
removeConsumer(ConnectionContext context,
ConsumerInfo info)
Removes a consumer.
|
void |
removeProducer(ConnectionContext context,
ProducerInfo info)
Removes a producer.
|
void |
send(ProducerBrokerExchange exchange,
Message message)
Send a message to the broker to using the specified destination.
|
void |
setContextBroker(Broker contextBroker) |
void |
start() |
void |
unregister(ActiveMQDestination destName) |
void |
unregister(XATransaction transaction) |
protected void |
unregisterDestination(javax.management.ObjectName key) |
protected void |
unregisterProducer(javax.management.ObjectName key) |
protected void |
unregisterSubscription(javax.management.ObjectName key,
boolean addToInactive) |
void |
unregisterSubscription(Subscription sub) |
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, javax.management.ObjectName brokerObjectName, TaskRunnerFactory taskRunnerFactory, SystemUsage memoryManager, DestinationFactory destinationFactory, DestinationInterceptor destinationInterceptor, Scheduler scheduler, java.util.concurrent.ThreadPoolExecutor executor) throws java.io.IOException
java.io.IOException
public void start() throws java.lang.Exception
start
in interface Service
start
in class RegionBroker
java.lang.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 javax.management.ObjectName registerSubscription(ConnectionContext context, Subscription sub)
public static java.lang.String getSubscriptionObjectName(ConsumerInfo info, java.lang.String connectionClientId, javax.management.ObjectName brokerJmxObjectName)
public Subscription addConsumer(ConnectionContext context, ConsumerInfo info) throws java.lang.Exception
Region
addConsumer
in interface Region
addConsumer
in class RegionBroker
context
- the environment the operation is being executed under.java.lang.Exception
- TODOpublic void removeConsumer(ConnectionContext context, ConsumerInfo info) throws java.lang.Exception
Region
removeConsumer
in interface Region
removeConsumer
in class RegionBroker
context
- the environment the operation is being executed under.java.lang.Exception
- TODOpublic void addProducer(ConnectionContext context, ProducerInfo info) throws java.lang.Exception
Broker
addProducer
in interface Broker
addProducer
in interface Region
addProducer
in class RegionBroker
context
- the enviorment the operation is being executed under.java.lang.Exception
- TODOpublic void removeProducer(ConnectionContext context, ProducerInfo info) throws java.lang.Exception
Broker
removeProducer
in interface Broker
removeProducer
in interface Region
removeProducer
in class RegionBroker
context
- the enviorment the operation is being executed under.java.lang.Exception
- TODOpublic void send(ProducerBrokerExchange exchange, Message message) throws java.lang.Exception
Region
send
in interface Region
send
in class RegionBroker
exchange
- the environment the operation is being executed under.java.lang.Exception
- TODOpublic void unregisterSubscription(Subscription sub)
protected void registerDestination(javax.management.ObjectName key, ActiveMQDestination dest, DestinationView view) throws java.lang.Exception
java.lang.Exception
protected void unregisterDestination(javax.management.ObjectName key) throws java.lang.Exception
java.lang.Exception
protected void registerProducer(javax.management.ObjectName key, ActiveMQDestination dest, ProducerView view) throws java.lang.Exception
java.lang.Exception
protected void unregisterProducer(javax.management.ObjectName key) throws java.lang.Exception
java.lang.Exception
protected void registerSubscription(javax.management.ObjectName key, ConsumerInfo info, SubscriptionKey subscriptionKey, SubscriptionView view) throws java.lang.Exception
java.lang.Exception
protected void unregisterSubscription(javax.management.ObjectName key, boolean addToInactive) throws java.lang.Exception
java.lang.Exception
protected void buildExistingSubscriptions() throws java.lang.Exception
java.lang.Exception
protected void addInactiveSubscription(SubscriptionKey key, SubscriptionInfo info, Subscription subscription)
public javax.management.openmbean.CompositeData[] browse(SubscriptionView view) throws javax.management.openmbean.OpenDataException
javax.management.openmbean.OpenDataException
public javax.management.openmbean.TabularData browseAsTable(SubscriptionView view) throws javax.management.openmbean.OpenDataException
javax.management.openmbean.OpenDataException
protected java.util.List<Message> getSubscriberMessages(SubscriptionView view)
protected javax.management.ObjectName[] getTopics()
protected javax.management.ObjectName[] getQueues()
protected javax.management.ObjectName[] getTemporaryTopics()
protected javax.management.ObjectName[] getTemporaryQueues()
protected javax.management.ObjectName[] getTopicSubscribers()
protected javax.management.ObjectName[] getDurableTopicSubscribers()
protected javax.management.ObjectName[] getQueueSubscribers()
protected javax.management.ObjectName[] getTemporaryTopicSubscribers()
protected javax.management.ObjectName[] getTemporaryQueueSubscribers()
protected javax.management.ObjectName[] getInactiveDurableTopicSubscribers()
protected javax.management.ObjectName[] getTopicProducers()
protected javax.management.ObjectName[] getQueueProducers()
protected javax.management.ObjectName[] getTemporaryTopicProducers()
protected javax.management.ObjectName[] getTemporaryQueueProducers()
protected javax.management.ObjectName[] getDynamicDestinationProducers()
public Broker getContextBroker()
public void setContextBroker(Broker contextBroker)
protected javax.management.ObjectName createObjectName(ActiveMQDestination destName) throws javax.management.MalformedObjectNameException
javax.management.MalformedObjectNameException
protected javax.management.ObjectName createObjectName(ProducerInfo producerInfo, java.lang.String connectionClientId) throws javax.management.MalformedObjectNameException
javax.management.MalformedObjectNameException
public javax.management.ObjectName registerSlowConsumerStrategy(AbortSlowConsumerStrategy strategy) throws javax.management.MalformedObjectNameException
javax.management.MalformedObjectNameException
protected javax.management.ObjectName createObjectName(XATransaction transaction) throws javax.management.MalformedObjectNameException
javax.management.MalformedObjectNameException
public void registerRecoveredTransactionMBean(XATransaction transaction)
public void unregister(XATransaction transaction)
public javax.management.ObjectName getSubscriberObjectName(Subscription key)
public Subscription getSubscriber(javax.management.ObjectName key)
Copyright © 2005-2017. All Rights Reserved.