|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.activemq.broker.region.BaseDestination
org.apache.activemq.broker.region.Queue
org.apache.activemq.broker.region.TempQueue
public class TempQueue
The Queue is a List of MessageEntry objects that are dispatched to matching subscriptions.
Field Summary |
---|
Fields inherited from class org.apache.activemq.broker.region.Queue |
---|
consumers, messages, messagesWaitingForSpace, taskFactory, taskRunner |
Fields inherited from class org.apache.activemq.broker.region.BaseDestination |
---|
blockedProducerWarningInterval, broker, brokerService, cursorMemoryHighWaterMark, deadLetterStrategy, DEFAULT_INACTIVE_TIMEOUT_BEFORE_GC, destination, destinationStatistics, EXPIRE_MESSAGE_PERIOD, expireMessagesPeriod, MAX_AUDIT_DEPTH, MAX_BROWSE_PAGE_SIZE, MAX_PAGE_SIZE, MAX_PRODUCERS_TO_AUDIT, memoryUsage, regionBroker, store, storeUsageHighWaterMark, systemUsage, warnOnProducerFlowControl |
Fields inherited from interface org.apache.activemq.broker.region.Destination |
---|
DEFAULT_BLOCKED_PRODUCER_WARNING_INTERVAL, DEFAULT_DEAD_LETTER_STRATEGY |
Constructor Summary | |
---|---|
TempQueue(BrokerService brokerService,
ActiveMQDestination destination,
MessageStore store,
DestinationStatistics parentStats,
TaskRunnerFactory taskFactory)
|
Method Summary | |
---|---|
void |
addSubscription(ConnectionContext context,
Subscription sub)
|
void |
dispose(ConnectionContext context)
|
void |
initialize()
initialize the destination |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Constructor Detail |
---|
public TempQueue(BrokerService brokerService, ActiveMQDestination destination, MessageStore store, DestinationStatistics parentStats, TaskRunnerFactory taskFactory) throws java.lang.Exception
brokerService
- destination
- store
- parentStats
- taskFactory
-
java.lang.Exception
Method Detail |
---|
public void initialize() throws java.lang.Exception
BaseDestination
initialize
in class Queue
java.lang.Exception
public void addSubscription(ConnectionContext context, Subscription sub) throws java.lang.Exception
addSubscription
in interface Destination
addSubscription
in class Queue
java.lang.Exception
public void dispose(ConnectionContext context) throws java.io.IOException
dispose
in interface Destination
dispose
in class BaseDestination
java.io.IOException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |