public class TempQueueRegion extends AbstractTempRegion
autoCreateDestinations, broker, consumerChangeMutexMap, destinationFactory, destinationMap, destinations, destinationsMutex, destinationStatistics, started, subscriptions, taskRunnerFactory, usageManager
Constructor and Description |
---|
TempQueueRegion(RegionBroker broker,
BrokerService brokerService,
DestinationStatistics destinationStatistics,
SystemUsage memoryManager,
TaskRunnerFactory taskRunnerFactory,
DestinationFactory destinationFactory) |
Modifier and Type | Method and Description |
---|---|
protected void |
configureQueue(Queue queue,
ActiveMQDestination destination) |
protected Subscription |
createSubscription(ConnectionContext context,
ConsumerInfo info) |
protected Destination |
doCreateDestination(ConnectionContext context,
ActiveMQDestination destination) |
void |
processDispatchNotification(MessageDispatchNotification messageDispatchNotification)
Process a notification of a dispatch - used by a Slave Broker
|
void |
removeDestination(ConnectionContext context,
ActiveMQDestination destination,
long timeout)
Used to destroy a destination.
|
java.lang.String |
toString() |
createDestination, dispose, stop
acknowledge, addConsumer, addDestination, addProducer, addSubscriptionsForDestination, destroySubscription, gc, getDestinationMap, getDestinations, getDurableDestinations, getInactiveDestinations, getSubscriptions, isAutoCreateDestinations, lookup, messagePull, processConsumerControl, processDispatchNotificationViaDestination, removeConsumer, removeProducer, removeSubscription, send, setAutoCreateDestinations, start
public TempQueueRegion(RegionBroker broker, BrokerService brokerService, DestinationStatistics destinationStatistics, SystemUsage memoryManager, TaskRunnerFactory taskRunnerFactory, DestinationFactory destinationFactory)
protected Destination doCreateDestination(ConnectionContext context, ActiveMQDestination destination) throws java.lang.Exception
doCreateDestination
in class AbstractTempRegion
java.lang.Exception
protected Subscription createSubscription(ConnectionContext context, ConsumerInfo info) throws javax.jms.JMSException
createSubscription
in class AbstractRegion
javax.jms.JMSException
public java.lang.String toString()
toString
in class java.lang.Object
public void removeDestination(ConnectionContext context, ActiveMQDestination destination, long timeout) throws java.lang.Exception
Region
removeDestination
in interface Region
removeDestination
in class AbstractRegion
context
- the environment the operation is being executed under.destination
- what is being removed from the broker.timeout
- the max amount of time to wait for the destination to quiescejava.lang.Exception
- TODOpublic void processDispatchNotification(MessageDispatchNotification messageDispatchNotification) throws java.lang.Exception
Region
processDispatchNotification
in interface Region
processDispatchNotification
in class AbstractRegion
java.lang.Exception
- TODOprotected void configureQueue(Queue queue, ActiveMQDestination destination)
Copyright © 2005-2012. All Rights Reserved.