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, addDestination, addDestinationInfo, beginTransaction, brokerServiceStarted, commitTransaction, createUnknownDestinationTypeException, forgetTransaction, gc, getAdaptor, getAdminConnectionContext, getBrokerId, getBrokerName, getBrokerSequenceId, getBrokerService, getClients, getConnectionContext, getConnectionStates, getDestinationInterceptor, getDestinationMap, getDestinationMap, getDestinationPolicy, getDestinations, getDestinations, getDestinationStatistics, getDurableDestinations, getExecutor, getPeerBrokerInfos, getPreparedTransactions, getQueueRegion, getRegion, getRoot, getScheduler, getTempDataStore, getTempQueueRegion, getTempTopicRegion, getTopicRegion, getVmConnectorURI, isAllowTempAutoCreationOnSend, isEqual, isExpired, isKeepDurableSubsActive, isStopped, messageExpired, messagePull, postProcessDispatch, prepareTransaction, preProcessDispatch, processConsumerControl, processDispatchNotification, purgeInactiveDestinations, reapplyInterceptor, removeBroker, removeBrokerInClusterUpdate, removeDestination, removeDestinationInfo, removeSubscription, rollbackTransaction, sendToDeadLetterQueue, setAdminConnectionContext, setAllowTempAutoCreationOnSend, setBrokerId, setBrokerName, setKeepDurableSubsActive, stop
addSession, fastProducer, isFaultTolerantConfiguration, isFull, messageConsumed, messageDelivered, messageDiscarded, networkBridgeStarted, networkBridgeStopped, nowMasterBroker, removeSession, slowConsumer, virtualDestinationAdded, virtualDestinationRemoved
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 void addConnection(ConnectionContext context, ConnectionInfo info) throws Exception
Broker
addConnection
in interface Broker
addConnection
in class RegionBroker
Exception
- TODOpublic void removeConnection(ConnectionContext context, ConnectionInfo info, Throwable error) throws Exception
Broker
removeConnection
in interface Broker
removeConnection
in class RegionBroker
context
- the environment the operation is being executed under.error
- null if the client requested the disconnect or the error
that caused the client to disconnect.Exception
- TODOpublic 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
public void remove(SubscriptionView view, String messageId) throws Exception
Exception
protected Message[] getSubscriberMessages(SubscriptionView view)
protected ObjectName[] getTopics()
protected ObjectName[] getTopicsNonSuppressed()
protected ObjectName[] getQueues()
protected ObjectName[] getQueuesNonSuppressed()
protected ObjectName[] getTemporaryTopics()
protected ObjectName[] getTemporaryTopicsNonSuppressed()
protected ObjectName[] getTemporaryQueues()
protected ObjectName[] getTemporaryQueuesNonSuppressed()
protected ObjectName[] getTopicSubscribers()
protected ObjectName[] getTopicSubscribersNonSuppressed()
protected ObjectName[] getDurableTopicSubscribers()
protected ObjectName[] getDurableTopicSubscribersNonSuppressed()
protected ObjectName[] getQueueSubscribers()
protected ObjectName[] getQueueSubscribersNonSuppressed()
protected ObjectName[] getTemporaryTopicSubscribers()
protected ObjectName[] getTemporaryTopicSubscribersNonSuppressed()
protected ObjectName[] getTemporaryQueueSubscribers()
protected ObjectName[] getTemporaryQueueSubscribersNonSuppressed()
protected ObjectName[] getInactiveDurableTopicSubscribers()
protected ObjectName[] getInactiveDurableTopicSubscribersNonSuppressed()
protected ObjectName[] getTopicProducers()
protected ObjectName[] getTopicProducersNonSuppressed()
protected ObjectName[] getQueueProducers()
protected ObjectName[] getQueueProducersNonSuppressed()
protected ObjectName[] getTemporaryTopicProducers()
protected ObjectName[] getTemporaryTopicProducersNonSuppressed()
protected ObjectName[] getTemporaryQueueProducers()
protected ObjectName[] getTemporaryQueueProducersNonSuppressed()
protected ObjectName[] getDynamicDestinationProducers()
protected ObjectName[] getDynamicDestinationProducersNonSuppressed()
public Broker getContextBroker()
public void setContextBroker(Broker contextBroker)
public ObjectName registerSlowConsumerStrategy(AbortSlowConsumerStrategy strategy) throws MalformedObjectNameException
MalformedObjectNameException
public void registerRecoveredTransactionMBean(XATransaction transaction)
public void unregister(XATransaction transaction)
public ObjectName getSubscriberObjectName(Subscription key)
public Subscription getSubscriber(ObjectName key)
public Map<ObjectName,DestinationView> getQueueViews()
public Map<ObjectName,DestinationView> getTopicViews()
public DestinationView getQueueView(String queueName) throws MalformedObjectNameException
MalformedObjectNameException
public Set<ObjectName> getRegisteredMbeans()
Copyright © 2005–2019 FuseSource, Corp.. All rights reserved.