|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use MessageDispatch | |
---|---|
org.apache.activemq | The core JMS client API implementation classes. |
org.apache.activemq.broker | The core classes for the ActiveMQ Message Broker and its connectors. |
org.apache.activemq.broker.ft | Helper classes for implementing fault tolerance |
org.apache.activemq.broker.region | Region abstraction and implementations in the Broker. |
org.apache.activemq.broker.util | Some utility Broker Plugins |
org.apache.activemq.command | Command objects used via the Command Pattern to communicate among nodes |
org.apache.activemq.network | Support for federated networks of brokers. |
org.apache.activemq.state | |
org.apache.activemq.transport.stomp | An implementation of the Stomp protocol which is a simple wire protocol for writing clients for ActiveMQ in different languages like Ruby, Python, PHP, C etc. |
Uses of MessageDispatch in org.apache.activemq |
---|
Methods in org.apache.activemq that return MessageDispatch | |
---|---|
MessageDispatch |
SimplePriorityMessageDispatchChannel.dequeue(long timeout)
|
MessageDispatch |
MessageDispatchChannel.dequeue(long timeout)
Used to get an enqueued message. |
MessageDispatch |
FifoMessageDispatchChannel.dequeue(long timeout)
|
MessageDispatch |
SimplePriorityMessageDispatchChannel.dequeueNoWait()
|
MessageDispatch |
MessageDispatchChannel.dequeueNoWait()
|
MessageDispatch |
FifoMessageDispatchChannel.dequeueNoWait()
|
MessageDispatch |
SimplePriorityMessageDispatchChannel.peek()
|
MessageDispatch |
MessageDispatchChannel.peek()
|
MessageDispatch |
FifoMessageDispatchChannel.peek()
|
Methods in org.apache.activemq that return types with arguments of type MessageDispatch | |
---|---|
protected java.util.LinkedList<MessageDispatch> |
SimplePriorityMessageDispatchChannel.getList(MessageDispatch md)
|
java.util.List<MessageDispatch> |
ActiveMQSession.getUnconsumedMessages()
|
java.util.List<MessageDispatch> |
SimplePriorityMessageDispatchChannel.removeAll()
|
java.util.List<MessageDispatch> |
MessageDispatchChannel.removeAll()
|
java.util.List<MessageDispatch> |
FifoMessageDispatchChannel.removeAll()
|
Methods in org.apache.activemq with parameters of type MessageDispatch | |
---|---|
void |
ActiveMQConnectionConsumer.dispatch(MessageDispatch messageDispatch)
|
void |
ActiveMQMessageConsumer.dispatch(MessageDispatch md)
|
void |
ActiveMQInputStream.dispatch(MessageDispatch md)
|
void |
AdvisoryConsumer.dispatch(MessageDispatch md)
|
void |
ActiveMQSession.dispatch(MessageDispatch messageDispatch)
|
void |
ActiveMQDispatcher.dispatch(MessageDispatch messageDispatch)
|
void |
SimplePriorityMessageDispatchChannel.enqueue(MessageDispatch message)
|
void |
MessageDispatchChannel.enqueue(MessageDispatch message)
|
void |
FifoMessageDispatchChannel.enqueue(MessageDispatch message)
|
void |
SimplePriorityMessageDispatchChannel.enqueueFirst(MessageDispatch message)
|
void |
MessageDispatchChannel.enqueueFirst(MessageDispatch message)
|
void |
FifoMessageDispatchChannel.enqueueFirst(MessageDispatch message)
|
protected java.util.LinkedList<MessageDispatch> |
SimplePriorityMessageDispatchChannel.getList(MessageDispatch md)
|
protected int |
SimplePriorityMessageDispatchChannel.getPriority(MessageDispatch message)
|
Uses of MessageDispatch in org.apache.activemq.broker |
---|
Methods in org.apache.activemq.broker with parameters of type MessageDispatch | |
---|---|
void |
MutableBrokerFilter.postProcessDispatch(MessageDispatch messageDispatch)
|
void |
EmptyBroker.postProcessDispatch(MessageDispatch messageDispatch)
|
void |
Broker.postProcessDispatch(MessageDispatch messageDispatch)
Notify the Broker that a dispatch has happened |
void |
ErrorBroker.postProcessDispatch(MessageDispatch messageDispatch)
|
void |
BrokerFilter.postProcessDispatch(MessageDispatch messageDispatch)
|
void |
MutableBrokerFilter.preProcessDispatch(MessageDispatch messageDispatch)
|
void |
EmptyBroker.preProcessDispatch(MessageDispatch messageDispatch)
|
void |
Broker.preProcessDispatch(MessageDispatch messageDispatch)
Notify the Broker that a dispatch is going to happen |
void |
ErrorBroker.preProcessDispatch(MessageDispatch messageDispatch)
|
void |
BrokerFilter.preProcessDispatch(MessageDispatch messageDispatch)
|
Response |
TransportConnection.processMessageDispatch(MessageDispatch dispatch)
|
Uses of MessageDispatch in org.apache.activemq.broker.ft |
---|
Methods in org.apache.activemq.broker.ft with parameters of type MessageDispatch | |
---|---|
void |
MasterBroker.preProcessDispatch(MessageDispatch messageDispatch)
Notifiy the Broker that a dispatch will happen Do in 'pre' so that slave will avoid getting ack before dispatch similar logic to send() below. |
Uses of MessageDispatch in org.apache.activemq.broker.region |
---|
Methods in org.apache.activemq.broker.region that return MessageDispatch | |
---|---|
protected MessageDispatch |
PrefetchSubscription.createMessageDispatch(MessageReference node,
Message message)
|
protected MessageDispatch |
DurableTopicSubscription.createMessageDispatch(MessageReference node,
Message message)
|
Methods in org.apache.activemq.broker.region with parameters of type MessageDispatch | |
---|---|
void |
RegionBroker.postProcessDispatch(MessageDispatch messageDispatch)
|
void |
RegionBroker.preProcessDispatch(MessageDispatch messageDispatch)
|
Uses of MessageDispatch in org.apache.activemq.broker.util |
---|
Methods in org.apache.activemq.broker.util with parameters of type MessageDispatch | |
---|---|
void |
LoggingBrokerPlugin.postProcessDispatch(MessageDispatch messageDispatch)
|
void |
UDPTraceBrokerPlugin.postProcessDispatch(MessageDispatch messageDispatch)
|
void |
LoggingBrokerPlugin.preProcessDispatch(MessageDispatch messageDispatch)
|
void |
TraceBrokerPathPlugin.preProcessDispatch(MessageDispatch messageDispatch)
|
Uses of MessageDispatch in org.apache.activemq.command |
---|
Constructors in org.apache.activemq.command with parameters of type MessageDispatch | |
---|---|
MessageAck(MessageDispatch md,
byte ackType,
int messageCount)
|
Uses of MessageDispatch in org.apache.activemq.network |
---|
Methods in org.apache.activemq.network with parameters of type MessageDispatch | |
---|---|
protected Message |
DemandForwardingBridgeSupport.configureMessage(MessageDispatch md)
|
Uses of MessageDispatch in org.apache.activemq.state |
---|
Methods in org.apache.activemq.state with parameters of type MessageDispatch | |
---|---|
Response |
CommandVisitorAdapter.processMessageDispatch(MessageDispatch dispatch)
|
Response |
CommandVisitor.processMessageDispatch(MessageDispatch dispatch)
|
Uses of MessageDispatch in org.apache.activemq.transport.stomp |
---|
Fields in org.apache.activemq.transport.stomp with type parameters of type MessageDispatch | |
---|---|
protected java.util.LinkedHashMap<MessageId,MessageDispatch> |
StompSubscription.dispatchedMessage
|
protected java.util.LinkedList<MessageDispatch> |
StompSubscription.unconsumedMessage
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |