org.apache.qpid.server.message

Interface MessageDestination

All Superinterfaces:

MessageNode

All Known Subinterfaces:

AMQQueue<X>, Exchange<X>, ExchangeImpl<T>, LastValueQueue<X>, PriorityQueue<X>, SortedQueue<X>, StandardQueue<X>

All Known Implementing Classes:

AbstractExchange, AbstractQueue, DefaultDestination, DirectExchange, FanoutExchange, HeadersExchange, LastValueQueueImpl, OutOfOrderQueue, PriorityQueueImpl, SortedQueueImpl, StandardQueueImpl, TopicExchange

public interface MessageDestination
extends MessageNode

Method Summary

Modifier and Type	Method and Description
String	getName()
<M extends ServerMessage<? extends StorableMessageMetaData>> int	send(M message, String routingAddress, InstanceProperties instanceProperties, ServerTransaction txn, Action<? super MessageInstance> postEnqueueAction) Routes a message

Method Detail

getName

String getName()

Specified by:

getName in interface MessageNode

send

<M extends ServerMessage<? extends StorableMessageMetaData>> int send(M message,
                                                                      String routingAddress,
                                                                      InstanceProperties instanceProperties,
                                                                      ServerTransaction txn,
                                                                      Action<? super MessageInstance> postEnqueueAction)

Routes a message

Parameters:

message - the message to be routed

routingAddress -

instanceProperties - the instance properties

txn - the transaction to enqueue within

postEnqueueAction - action to perform on the result of every enqueue (may be null)

Returns:

the number of queues in which the message was enqueued performed