Package org.apache.activemq.broker.region

Class TempQueueRegion

java.lang.Object

org.apache.activemq.broker.region.AbstractRegion

org.apache.activemq.broker.region.AbstractTempRegion

org.apache.activemq.broker.region.TempQueueRegion

All Implemented Interfaces:

Region, Service

Direct Known Subclasses:

ManagedTempQueueRegion

public class TempQueueRegion
extends AbstractTempRegion

Field Summary

Fields inherited from class org.apache.activemq.broker.region.AbstractRegion

autoCreateDestinations, broker, consumerChangeMutexMap, destinationFactory, destinationMap, destinations, destinationsLock, destinationStatistics, regionStatistics, started, subscriptions, taskRunnerFactory, usageManager

Constructor Summary

Constructors

Constructor	Description
TempQueueRegion(RegionBroker broker, DestinationStatistics destinationStatistics, SystemUsage memoryManager, TaskRunnerFactory taskRunnerFactory, DestinationFactory destinationFactory)

Method Summary

Modifier and Type	Method	Description
protected Subscription	createSubscription(ConnectionContext context, ConsumerInfo info)
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.
String	toString()

Methods inherited from class org.apache.activemq.broker.region.AbstractTempRegion

createDestination, dispose, stop

Methods inherited from class org.apache.activemq.broker.region.AbstractRegion

acknowledge, addConsumer, addDestination, addProducer, addSubscriptionsForDestination, destroySubscription, gc, getDestinationMap, getDestinations, getDurableDestinations, getInactiveDestinations, getSubscriptions, isAutoCreateDestinations, lookup, messagePull, processConsumerControl, processDispatchNotificationViaDestination, reapplyInterceptor, removeConsumer, removeProducer, removeSubscription, send, setAutoCreateDestinations, start, updateRegionDestCounts, validateMaxDestinations

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

TempQueueRegion

public TempQueueRegion(RegionBroker broker,
                       DestinationStatistics destinationStatistics,
                       SystemUsage memoryManager,
                       TaskRunnerFactory taskRunnerFactory,
                       DestinationFactory destinationFactory)

Method Detail

createSubscription

protected Subscription createSubscription(ConnectionContext context,
                                          ConsumerInfo info)
                                   throws JMSException

Specified by:

createSubscription in class AbstractRegion

Throws:

JMSException

toString

public String toString()

Overrides:

toString in class Object

removeDestination

public void removeDestination(ConnectionContext context,
                              ActiveMQDestination destination,
                              long timeout)
                       throws Exception

Description copied from interface: Region

Used to destroy a destination. This should try to quiesce use of the destination up to the timeout allotted time before removing the destination. This will remove all persistent messages associated with the destination.

Specified by:

removeDestination in interface Region

Overrides:

removeDestination in class AbstractRegion

Parameters:

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 quiesce

Throws:

Exception - TODO

processDispatchNotification

public void processDispatchNotification(MessageDispatchNotification messageDispatchNotification)
                                 throws Exception

Description copied from interface: Region

Process a notification of a dispatch - used by a Slave Broker

Specified by:

processDispatchNotification in interface Region

Overrides:

processDispatchNotification in class AbstractRegion

Throws:

Exception - TODO