Uses of Class
org.apache.activemq.command.MessageDispatch
-
Packages that use MessageDispatch Package Description 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.region Region abstraction and implementations in the Broker.org.apache.activemq.broker.util Some utility Broker Pluginsorg.apache.activemq.command Command objects used via the Command Pattern to communicate among nodesorg.apache.activemq.network Support for federated networks of brokers.org.apache.activemq.state org.apache.activemq.transport.amqp.protocol org.apache.activemq.transport.mqtt A Broker side implementation of the MQTT 3.1 protocol - see http://mqtt.org/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
Fields in org.apache.activemq with type parameters of type MessageDispatch Modifier and Type Field Description protected LinkedList<MessageDispatch>
ActiveMQMessageConsumer. deliveredMessages
Methods in org.apache.activemq that return MessageDispatch Modifier and Type Method Description MessageDispatch
FifoMessageDispatchChannel. dequeue(long timeout)
MessageDispatch
MessageDispatchChannel. dequeue(long timeout)
Used to get an enqueued message.MessageDispatch
SimplePriorityMessageDispatchChannel. dequeue(long timeout)
MessageDispatch
FifoMessageDispatchChannel. dequeueNoWait()
MessageDispatch
MessageDispatchChannel. dequeueNoWait()
MessageDispatch
SimplePriorityMessageDispatchChannel. dequeueNoWait()
MessageDispatch
FifoMessageDispatchChannel. peek()
MessageDispatch
MessageDispatchChannel. peek()
MessageDispatch
SimplePriorityMessageDispatchChannel. peek()
Methods in org.apache.activemq that return types with arguments of type MessageDispatch Modifier and Type Method Description protected LinkedList<MessageDispatch>
SimplePriorityMessageDispatchChannel. getList(MessageDispatch md)
List<MessageDispatch>
ActiveMQSession. getUnconsumedMessages()
List<MessageDispatch>
FifoMessageDispatchChannel. removeAll()
List<MessageDispatch>
MessageDispatchChannel. removeAll()
List<MessageDispatch>
SimplePriorityMessageDispatchChannel. removeAll()
Methods in org.apache.activemq with parameters of type MessageDispatch Modifier and Type Method Description void
ActiveMQConnectionConsumer. dispatch(MessageDispatch messageDispatch)
void
ActiveMQDispatcher. dispatch(MessageDispatch messageDispatch)
void
ActiveMQMessageConsumer. dispatch(MessageDispatch md)
void
ActiveMQSession. dispatch(MessageDispatch messageDispatch)
void
AdvisoryConsumer. dispatch(MessageDispatch md)
void
FifoMessageDispatchChannel. enqueue(MessageDispatch message)
void
MessageDispatchChannel. enqueue(MessageDispatch message)
void
SimplePriorityMessageDispatchChannel. enqueue(MessageDispatch message)
void
FifoMessageDispatchChannel. enqueueFirst(MessageDispatch message)
void
MessageDispatchChannel. enqueueFirst(MessageDispatch message)
void
SimplePriorityMessageDispatchChannel. enqueueFirst(MessageDispatch message)
protected 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 Modifier and Type Method Description void
Broker. postProcessDispatch(MessageDispatch messageDispatch)
Notify the Broker that a dispatch has happenedvoid
BrokerFilter. postProcessDispatch(MessageDispatch messageDispatch)
void
EmptyBroker. postProcessDispatch(MessageDispatch messageDispatch)
void
ErrorBroker. postProcessDispatch(MessageDispatch messageDispatch)
void
Broker. preProcessDispatch(MessageDispatch messageDispatch)
Notify the Broker that a dispatch is going to happenvoid
BrokerFilter. preProcessDispatch(MessageDispatch messageDispatch)
void
EmptyBroker. preProcessDispatch(MessageDispatch messageDispatch)
void
ErrorBroker. preProcessDispatch(MessageDispatch messageDispatch)
Response
TransportConnection. processMessageDispatch(MessageDispatch dispatch)
-
Uses of MessageDispatch in org.apache.activemq.broker.region
Methods in org.apache.activemq.broker.region that return MessageDispatch Modifier and Type Method Description protected MessageDispatch
DurableTopicSubscription. createMessageDispatch(MessageReference node, Message message)
protected MessageDispatch
PrefetchSubscription. createMessageDispatch(MessageReference node, Message message)
Methods in org.apache.activemq.broker.region with parameters of type MessageDispatch Modifier and Type Method Description 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 Modifier and Type Method Description 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 Constructor Description 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 Modifier and Type Method Description protected Message
DemandForwardingBridgeSupport. configureMessage(MessageDispatch md)
void
DemandForwardingBridgeSupport. serviceLocalException(MessageDispatch messageDispatch, Throwable error)
-
Uses of MessageDispatch in org.apache.activemq.state
Methods in org.apache.activemq.state with parameters of type MessageDispatch Modifier and Type Method Description Response
CommandVisitor. processMessageDispatch(MessageDispatch dispatch)
Response
CommandVisitorAdapter. processMessageDispatch(MessageDispatch dispatch)
-
Uses of MessageDispatch in org.apache.activemq.transport.amqp.protocol
Methods in org.apache.activemq.transport.amqp.protocol with parameters of type MessageDispatch Modifier and Type Method Description void
AmqpSender. onMessageDispatch(MessageDispatch dispatch)
Event point for incoming message from ActiveMQ on this Sender's corresponding subscription. -
Uses of MessageDispatch in org.apache.activemq.transport.mqtt
Methods in org.apache.activemq.transport.mqtt with parameters of type MessageDispatch Modifier and Type Method Description MessageAck
MQTTSubscription. createMessageAck(MessageDispatch md)
Create aMessageAck
that will acknowledge the givenMessageDispatch
. -
Uses of MessageDispatch in org.apache.activemq.transport.stomp
Methods in org.apache.activemq.transport.stomp that return MessageDispatch Modifier and Type Method Description MessageDispatch
StompAckEntry. getMessageDispatch()
Constructors in org.apache.activemq.transport.stomp with parameters of type MessageDispatch Constructor Description StompAckEntry(MessageDispatch dispatch, String ackId, StompSubscription subscription)
-