|
||||||||||
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.xmpp |
Uses of MessageDispatch in org.apache.activemq |
---|
Methods in org.apache.activemq that return MessageDispatch | |
---|---|
MessageDispatch |
MessageDispatchChannel.dequeue(long timeout)
Used to get an enqueued message. |
MessageDispatch |
MessageDispatchChannel.dequeueNoWait()
|
MessageDispatch |
MessageDispatchChannel.peek()
|
Methods in org.apache.activemq that return types with arguments of type MessageDispatch | |
---|---|
List<MessageDispatch> |
MessageDispatchChannel.removeAll()
|
Methods in org.apache.activemq with parameters of type MessageDispatch | |
---|---|
void |
ActiveMQDispatcher.dispatch(MessageDispatch messageDispatch)
|
void |
ActiveMQConnectionConsumer.dispatch(MessageDispatch messageDispatch)
|
void |
ActiveMQInputStream.dispatch(MessageDispatch md)
|
void |
AdvisoryConsumer.dispatch(MessageDispatch md)
|
void |
ActiveMQMessageConsumer.dispatch(MessageDispatch md)
|
void |
ActiveMQSession.dispatch(MessageDispatch messageDispatch)
|
void |
MessageDispatchChannel.enqueue(MessageDispatch message)
|
void |
MessageDispatchChannel.enqueueFirst(MessageDispatch message)
|
Uses of MessageDispatch in org.apache.activemq.broker |
---|
Methods in org.apache.activemq.broker with parameters of type MessageDispatch | |
---|---|
void |
Broker.postProcessDispatch(MessageDispatch messageDispatch)
Notify the Broker that a dispatch has happened |
void |
EmptyBroker.postProcessDispatch(MessageDispatch messageDispatch)
|
void |
MutableBrokerFilter.postProcessDispatch(MessageDispatch messageDispatch)
|
void |
BrokerFilter.postProcessDispatch(MessageDispatch messageDispatch)
|
void |
ErrorBroker.postProcessDispatch(MessageDispatch messageDispatch)
|
void |
Broker.preProcessDispatch(MessageDispatch messageDispatch)
Notify the Broker that a dispatch is going to happen |
void |
EmptyBroker.preProcessDispatch(MessageDispatch messageDispatch)
|
void |
MutableBrokerFilter.preProcessDispatch(MessageDispatch messageDispatch)
|
void |
BrokerFilter.preProcessDispatch(MessageDispatch messageDispatch)
|
void |
ErrorBroker.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 |
UDPTraceBrokerPlugin.postProcessDispatch(MessageDispatch messageDispatch)
|
void |
LoggingBrokerPlugin.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 |
CommandVisitor.processMessageDispatch(MessageDispatch dispatch)
|
Response |
CommandVisitorAdapter.processMessageDispatch(MessageDispatch dispatch)
|
Uses of MessageDispatch in org.apache.activemq.transport.xmpp |
---|
Methods in org.apache.activemq.transport.xmpp with parameters of type MessageDispatch | |
---|---|
protected Message |
ProtocolConverter.createXmppMessage(String to,
MessageDispatch messageDispatch)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |