org.apache.activemq.broker.region
Interface Destination

All Superinterfaces:

Service, Task

All Known Implementing Classes:

BaseDestination, CompositeDestinationFilter, DestinationFilter, Queue, TempQueue, TempTopic, Topic, VirtualTopicInterceptor

public interface Destination
extends Service, Task

Version:

$Revision: 1.12 $

Field Summary

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()
List<Subscription>	getConsumers()
DeadLetterStrategy	getDeadLetterStrategy()
DestinationStatistics	getDestinationStatistics()
int	getMaxAuditDepth()
int	getMaxBrowsePageSize()
int	getMaxPageSize()
int	getMaxProducersToAudit()
MemoryUsage	getMemoryUsage()
MessageStore	getMessageStore()
int	getMinimumMessageSize()
String	getName()
boolean	isActive()
boolean	isEnableAudit()
void	isFull(ConnectionContext context, Usage usage) Called when a Usage reaches a limit
boolean	isLazyDispatch()
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, 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	removeProducer(ConnectionContext context, ProducerInfo info)
void	removeSubscription(ConnectionContext context, Subscription sub)
void	send(ProducerBrokerExchange producerExchange, Message messageSend)
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

DEFAULT_DEAD_LETTER_STRATEGY

static final DeadLetterStrategy DEFAULT_DEAD_LETTER_STRATEGY

Method Detail

addSubscription

void addSubscription(ConnectionContext context,
                     Subscription sub)
                     throws Exception

Throws:

Exception

removeSubscription

void removeSubscription(ConnectionContext context,
                        Subscription sub)
                        throws Exception

Throws:

Exception

addProducer

void addProducer(ConnectionContext context,
                 ProducerInfo info)
                 throws Exception

Throws:

Exception

removeProducer

void removeProducer(ConnectionContext context,
                    ProducerInfo info)
                    throws Exception

Throws:

Exception

send

void send(ProducerBrokerExchange producerExchange,
          Message messageSend)
          throws Exception

Throws:

Exception

acknowledge

void acknowledge(ConnectionContext context,
                 Subscription sub,
                 MessageAck ack,
                 MessageReference node)
                 throws IOException

Throws:

IOException

gc

void gc()

getActiveMQDestination

ActiveMQDestination getActiveMQDestination()

getMemoryUsage

MemoryUsage getMemoryUsage()

dispose

void dispose(ConnectionContext context)
             throws IOException

Throws:

IOException

getDestinationStatistics

DestinationStatistics getDestinationStatistics()

getDeadLetterStrategy

DeadLetterStrategy getDeadLetterStrategy()

browse

Message[] browse()

getName

String getName()

getMessageStore

MessageStore getMessageStore()

isProducerFlowControl

boolean isProducerFlowControl()

setProducerFlowControl

void setProducerFlowControl(boolean value)

getMaxProducersToAudit

int getMaxProducersToAudit()

setMaxProducersToAudit

void setMaxProducersToAudit(int maxProducersToAudit)

getMaxAuditDepth

int getMaxAuditDepth()

setMaxAuditDepth

void setMaxAuditDepth(int maxAuditDepth)

isEnableAudit

boolean isEnableAudit()

setEnableAudit

void setEnableAudit(boolean enableAudit)

isActive

boolean isActive()

getMaxPageSize

int getMaxPageSize()

setMaxPageSize

void setMaxPageSize(int maxPageSize)

getMaxBrowsePageSize

int getMaxBrowsePageSize()

setMaxBrowsePageSize

void setMaxBrowsePageSize(int maxPageSize)

isUseCache

boolean isUseCache()

setUseCache

void setUseCache(boolean useCache)

getMinimumMessageSize

int getMinimumMessageSize()

setMinimumMessageSize

void setMinimumMessageSize(int minimumMessageSize)

wakeup

void wakeup()

optionally called by a Subscriber - to inform the Destination its ready for more messages

isLazyDispatch

boolean isLazyDispatch()

Returns:

true if lazyDispatch is enabled

setLazyDispatch

void setLazyDispatch(boolean value)

set the lazy dispatch - default is false

Parameters:

value -

messageExpired

void messageExpired(ConnectionContext context,
                    Subscription subs,
                    MessageReference node)

Inform the Destination a message has expired

Parameters:

context -

subs -

node -

messageConsumed

void messageConsumed(ConnectionContext context,
                     MessageReference messageReference)

called when message is consumed

Parameters:

context -

messageReference -

messageDelivered

void messageDelivered(ConnectionContext context,
                      MessageReference messageReference)

Called when message is delivered to the broker

Parameters:

context -

messageReference -

messageDiscarded

void messageDiscarded(ConnectionContext context,
                      MessageReference messageReference)

Called when a message is discarded - e.g. running low on memory This will happen only if the policy is enabled - e.g. non durable topics

Parameters:

context -

messageReference -

slowConsumer

void slowConsumer(ConnectionContext context,
                  Subscription subs)

Called when there is a slow consumer

Parameters:

context -

subs -

fastProducer

void fastProducer(ConnectionContext context,
                  ProducerInfo producerInfo)

Called to notify a producer is too fast

Parameters:

context -

producerInfo -

isFull

void isFull(ConnectionContext context,
            Usage usage)

Called when a Usage reaches a limit

Parameters:

context -

usage -

getConsumers

List<Subscription> getConsumers()