public interface Destination extends Service, Task, Message.MessageDestination
Modifier and Type | Field and Description |
---|---|
static long |
DEFAULT_BLOCKED_PRODUCER_WARNING_INTERVAL |
static DeadLetterStrategy |
DEFAULT_DEAD_LETTER_STRATEGY |
Modifier and Type | Method and Description |
---|---|
void |
acknowledge(ConnectionContext context,
Subscription sub,
MessageAck ack,
MessageReference node) |
void |
addProducer(ConnectionContext context,
ProducerInfo info) |
void |
addSubscription(ConnectionContext context,
Subscription sub) |
Message[] |
browse() |
boolean |
canGC() |
void |
clearPendingMessages() |
void |
dispose(ConnectionContext context) |
void |
duplicateFromStore(Message message,
Subscription subscription) |
void |
fastProducer(ConnectionContext context,
ProducerInfo producerInfo)
Called to notify a producer is too fast
|
void |
gc() |
ActiveMQDestination |
getActiveMQDestination() |
long |
getBlockedProducerWarningInterval() |
List<Subscription> |
getConsumers() |
int |
getCursorMemoryHighWaterMark() |
DeadLetterStrategy |
getDeadLetterStrategy() |
DestinationStatistics |
getDestinationStatistics() |
long |
getInactiveTimeoutBeforeGC() |
int |
getMaxAuditDepth() |
int |
getMaxBrowsePageSize() |
int |
getMaxPageSize() |
int |
getMaxProducersToAudit() |
MemoryUsage |
getMemoryUsage() |
MessageStore |
getMessageStore() |
int |
getMinimumMessageSize() |
String |
getName() |
SlowConsumerStrategy |
getSlowConsumerStrategy() |
TempUsage |
getTempUsage() |
boolean |
isActive() |
boolean |
isAlwaysRetroactive() |
boolean |
isDisposed() |
boolean |
isDoOptimzeMessageStorage() |
boolean |
isEnableAudit() |
void |
isFull(ConnectionContext context,
Usage<?> usage)
Called when a Usage reaches a limit
|
boolean |
isLazyDispatch() |
boolean |
isPrioritizedMessages() |
boolean |
isProducerFlowControl() |
boolean |
isUseCache() |
void |
markForGC(long timeStamp) |
void |
messageConsumed(ConnectionContext context,
MessageReference messageReference)
called when message is consumed
|
void |
messageDelivered(ConnectionContext context,
MessageReference messageReference)
Called when message is delivered to the broker
|
void |
messageDiscarded(ConnectionContext context,
Subscription sub,
MessageReference messageReference)
Called when a message is discarded - e.g.
|
void |
messageExpired(ConnectionContext context,
Subscription subs,
MessageReference node)
Inform the Destination a message has expired
|
void |
processDispatchNotification(MessageDispatchNotification messageDispatchNotification)
called on Queues in slave mode to allow dispatch to follow subscription
choice of master
|
void |
removeProducer(ConnectionContext context,
ProducerInfo info) |
void |
removeSubscription(ConnectionContext context,
Subscription sub,
long lastDeliveredSequenceId) |
void |
send(ProducerBrokerExchange producerExchange,
Message messageSend) |
void |
setAlwaysRetroactive(boolean value) |
void |
setBlockedProducerWarningInterval(long blockedProducerWarningInterval)
Set's the interval at which warnings about producers being blocked by
resource usage will be triggered.
|
void |
setCursorMemoryHighWaterMark(int cursorMemoryHighWaterMark) |
void |
setDoOptimzeMessageStorage(boolean doOptimzeMessageStorage) |
void |
setEnableAudit(boolean enableAudit) |
void |
setLazyDispatch(boolean value)
set the lazy dispatch - default is false
|
void |
setMaxAuditDepth(int maxAuditDepth) |
void |
setMaxBrowsePageSize(int maxPageSize) |
void |
setMaxPageSize(int maxPageSize) |
void |
setMaxProducersToAudit(int maxProducersToAudit) |
void |
setMemoryUsage(MemoryUsage memoryUsage) |
void |
setMinimumMessageSize(int minimumMessageSize) |
void |
setProducerFlowControl(boolean value) |
void |
setUseCache(boolean useCache) |
void |
slowConsumer(ConnectionContext context,
Subscription subs)
Called when there is a slow consumer
|
void |
wakeup()
optionally called by a Subscriber - to inform the Destination its ready
for more messages
|
static final DeadLetterStrategy DEFAULT_DEAD_LETTER_STRATEGY
static final long DEFAULT_BLOCKED_PRODUCER_WARNING_INTERVAL
void addSubscription(ConnectionContext context, Subscription sub) throws Exception
Exception
void removeSubscription(ConnectionContext context, Subscription sub, long lastDeliveredSequenceId) throws Exception
Exception
void addProducer(ConnectionContext context, ProducerInfo info) throws Exception
Exception
void removeProducer(ConnectionContext context, ProducerInfo info) throws Exception
Exception
void send(ProducerBrokerExchange producerExchange, Message messageSend) throws Exception
Exception
void acknowledge(ConnectionContext context, Subscription sub, MessageAck ack, MessageReference node) throws IOException
IOException
long getInactiveTimeoutBeforeGC()
void markForGC(long timeStamp)
boolean canGC()
void gc()
ActiveMQDestination getActiveMQDestination()
MemoryUsage getMemoryUsage()
getMemoryUsage
in interface Message.MessageDestination
void setMemoryUsage(MemoryUsage memoryUsage)
TempUsage getTempUsage()
void dispose(ConnectionContext context) throws IOException
IOException
boolean isDisposed()
DestinationStatistics getDestinationStatistics()
DeadLetterStrategy getDeadLetterStrategy()
MessageStore getMessageStore()
boolean isProducerFlowControl()
void setProducerFlowControl(boolean value)
boolean isAlwaysRetroactive()
void setAlwaysRetroactive(boolean value)
void setBlockedProducerWarningInterval(long blockedProducerWarningInterval)
blockedProducerWarningInterval
- the interval at which warning about
blocked producers will be triggered.long getBlockedProducerWarningInterval()
int getMaxProducersToAudit()
void setMaxProducersToAudit(int maxProducersToAudit)
int getMaxAuditDepth()
void setMaxAuditDepth(int maxAuditDepth)
boolean isEnableAudit()
void setEnableAudit(boolean enableAudit)
boolean isActive()
int getMaxPageSize()
void setMaxPageSize(int maxPageSize)
int getMaxBrowsePageSize()
void setMaxBrowsePageSize(int maxPageSize)
boolean isUseCache()
void setUseCache(boolean useCache)
int getMinimumMessageSize()
getMinimumMessageSize
in interface Message.MessageDestination
void setMinimumMessageSize(int minimumMessageSize)
int getCursorMemoryHighWaterMark()
void setCursorMemoryHighWaterMark(int cursorMemoryHighWaterMark)
void wakeup()
boolean isLazyDispatch()
void setLazyDispatch(boolean value)
value
- void messageExpired(ConnectionContext context, Subscription subs, MessageReference node)
context
- subs
- node
- void messageConsumed(ConnectionContext context, MessageReference messageReference)
context
- messageReference
- void messageDelivered(ConnectionContext context, MessageReference messageReference)
context
- messageReference
- void messageDiscarded(ConnectionContext context, Subscription sub, MessageReference messageReference)
context
- messageReference
- sub
- void slowConsumer(ConnectionContext context, Subscription subs)
context
- subs
- void fastProducer(ConnectionContext context, ProducerInfo producerInfo)
context
- producerInfo
- void isFull(ConnectionContext context, Usage<?> usage)
context
- usage
- List<Subscription> getConsumers()
void processDispatchNotification(MessageDispatchNotification messageDispatchNotification) throws Exception
messageDispatchNotification
- Exception
boolean isPrioritizedMessages()
SlowConsumerStrategy getSlowConsumerStrategy()
boolean isDoOptimzeMessageStorage()
void setDoOptimzeMessageStorage(boolean doOptimzeMessageStorage)
void clearPendingMessages()
void duplicateFromStore(Message message, Subscription subscription)
Copyright © 2005–2019 The Apache Software Foundation. All rights reserved.