|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface Destination
Field Summary | |
---|---|
static long |
DEFAULT_BLOCKED_PRODUCER_WARNING_INTERVAL
|
static DeadLetterStrategy |
DEFAULT_DEAD_LETTER_STRATEGY
|
Method Summary | |
---|---|
void |
acknowledge(ConnectionContext context,
Subscription sub,
MessageAck ack,
MessageReference node)
|
void |
addProducer(ConnectionContext context,
ProducerInfo info)
|
void |
addSubscription(ConnectionContext context,
Subscription sub)
|
Message[] |
browse()
|
void |
dispose(ConnectionContext context)
|
void |
fastProducer(ConnectionContext context,
ProducerInfo producerInfo)
Called to notify a producer is too fast |
void |
gc()
|
ActiveMQDestination |
getActiveMQDestination()
|
long |
getBlockedProducerWarningInterval()
|
java.util.List<Subscription> |
getConsumers()
|
int |
getCursorMemoryHighWaterMark()
|
DeadLetterStrategy |
getDeadLetterStrategy()
|
DestinationStatistics |
getDestinationStatistics()
|
int |
getMaxAuditDepth()
|
int |
getMaxBrowsePageSize()
|
int |
getMaxPageSize()
|
int |
getMaxProducersToAudit()
|
MemoryUsage |
getMemoryUsage()
|
MessageStore |
getMessageStore()
|
int |
getMinimumMessageSize()
|
java.lang.String |
getName()
|
SlowConsumerStrategy |
getSlowConsumerStrategy()
|
boolean |
isActive()
|
boolean |
isEnableAudit()
|
void |
isFull(ConnectionContext context,
Usage usage)
Called when a Usage reaches a limit |
boolean |
isLazyDispatch()
|
boolean |
isPrioritizedMessages()
|
boolean |
isProducerFlowControl()
|
boolean |
isUseCache()
|
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 |
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 |
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 |
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 |
Methods inherited from interface org.apache.activemq.Service |
---|
start, stop |
Methods inherited from interface org.apache.activemq.thread.Task |
---|
iterate |
Field Detail |
---|
static final DeadLetterStrategy DEFAULT_DEAD_LETTER_STRATEGY
static final long DEFAULT_BLOCKED_PRODUCER_WARNING_INTERVAL
Method Detail |
---|
void addSubscription(ConnectionContext context, Subscription sub) throws java.lang.Exception
java.lang.Exception
void removeSubscription(ConnectionContext context, Subscription sub, long lastDeliveredSequenceId) throws java.lang.Exception
java.lang.Exception
void addProducer(ConnectionContext context, ProducerInfo info) throws java.lang.Exception
java.lang.Exception
void removeProducer(ConnectionContext context, ProducerInfo info) throws java.lang.Exception
java.lang.Exception
void send(ProducerBrokerExchange producerExchange, Message messageSend) throws java.lang.Exception
java.lang.Exception
void acknowledge(ConnectionContext context, Subscription sub, MessageAck ack, MessageReference node) throws java.io.IOException
java.io.IOException
void gc()
ActiveMQDestination getActiveMQDestination()
MemoryUsage getMemoryUsage()
void dispose(ConnectionContext context) throws java.io.IOException
java.io.IOException
DestinationStatistics getDestinationStatistics()
DeadLetterStrategy getDeadLetterStrategy()
Message[] browse()
java.lang.String getName()
MessageStore getMessageStore()
boolean isProducerFlowControl()
void setProducerFlowControl(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()
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
- java.util.List<Subscription> getConsumers()
void processDispatchNotification(MessageDispatchNotification messageDispatchNotification) throws java.lang.Exception
messageDispatchNotification
-
java.lang.Exception
boolean isPrioritizedMessages()
SlowConsumerStrategy getSlowConsumerStrategy()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |