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) |
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 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[] |
getInactiveDurableTopicSubscribers() |
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(Subscription sub,
java.lang.String connectionClientId,
javax.management.ObjectName brokerJmxObjectName) |
protected javax.management.ObjectName[] |
getTemporaryQueues() |
protected javax.management.ObjectName[] |
getTemporaryQueueSubscribers() |
protected javax.management.ObjectName[] |
getTemporaryTopics() |
protected javax.management.ObjectName[] |
getTemporaryTopicSubscribers() |
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) |
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 |
setContextBroker(Broker contextBroker) |
void |
start() |
void |
unregister(ActiveMQDestination destName) |
protected void |
unregisterDestination(javax.management.ObjectName key) |
protected void |
unregisterSubscription(javax.management.ObjectName key,
boolean addToInactive) |
void |
unregisterSubscription(Subscription sub) |
acknowledge, addBroker, addBrokerInClusterUpdate, addConnection, addDestination, addDestinationInfo, addProducer, 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, isEqual, isExpired, isKeepDurableSubsActive, isSlaveBroker, isStopped, messageExpired, messagePull, postProcessDispatch, prepareTransaction, preProcessDispatch, processConsumerControl, processDispatchNotification, purgeInactiveDestinations, removeAdvisoryTopics, removeBroker, removeBrokerInClusterUpdate, removeConnection, removeDestination, removeDestinationInfo, removeProducer, removeSubscription, rollbackTransaction, send, sendToDeadLetterQueue, setAdminConnectionContext, 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(Subscription sub, 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 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 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)
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()
public Broker getContextBroker()
public void setContextBroker(Broker contextBroker)
protected javax.management.ObjectName createObjectName(ActiveMQDestination destName) throws javax.management.MalformedObjectNameException
javax.management.MalformedObjectNameException
public javax.management.ObjectName registerSlowConsumerStrategy(AbortSlowConsumerStrategy strategy) throws javax.management.MalformedObjectNameException
javax.management.MalformedObjectNameException
public javax.management.ObjectName getSubscriberObjectName(Subscription key)
public Subscription getSubscriber(javax.management.ObjectName key)
Copyright © 2005-2012. All Rights Reserved.