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. deliveredMessagesMethods in org.apache.activemq that return MessageDispatch Modifier and Type Method Description MessageDispatchFifoMessageDispatchChannel. dequeue(long timeout)MessageDispatchMessageDispatchChannel. dequeue(long timeout)Used to get an enqueued message.MessageDispatchSimplePriorityMessageDispatchChannel. dequeue(long timeout)MessageDispatchFifoMessageDispatchChannel. dequeueNoWait()MessageDispatchMessageDispatchChannel. dequeueNoWait()MessageDispatchSimplePriorityMessageDispatchChannel. dequeueNoWait()MessageDispatchFifoMessageDispatchChannel. peek()MessageDispatchMessageDispatchChannel. peek()MessageDispatchSimplePriorityMessageDispatchChannel. 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 voidActiveMQConnectionConsumer. dispatch(MessageDispatch messageDispatch)voidActiveMQDispatcher. dispatch(MessageDispatch messageDispatch)voidActiveMQMessageConsumer. dispatch(MessageDispatch md)voidActiveMQSession. dispatch(MessageDispatch messageDispatch)voidAdvisoryConsumer. dispatch(MessageDispatch md)voidFifoMessageDispatchChannel. enqueue(MessageDispatch message)voidMessageDispatchChannel. enqueue(MessageDispatch message)voidSimplePriorityMessageDispatchChannel. enqueue(MessageDispatch message)voidFifoMessageDispatchChannel. enqueueFirst(MessageDispatch message)voidMessageDispatchChannel. enqueueFirst(MessageDispatch message)voidSimplePriorityMessageDispatchChannel. enqueueFirst(MessageDispatch message)protected LinkedList<MessageDispatch>SimplePriorityMessageDispatchChannel. getList(MessageDispatch md)protected intSimplePriorityMessageDispatchChannel. 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 voidBroker. postProcessDispatch(MessageDispatch messageDispatch)Notify the Broker that a dispatch has happenedvoidBrokerFilter. postProcessDispatch(MessageDispatch messageDispatch)voidEmptyBroker. postProcessDispatch(MessageDispatch messageDispatch)voidErrorBroker. postProcessDispatch(MessageDispatch messageDispatch)voidBroker. preProcessDispatch(MessageDispatch messageDispatch)Notify the Broker that a dispatch is going to happenvoidBrokerFilter. preProcessDispatch(MessageDispatch messageDispatch)voidEmptyBroker. preProcessDispatch(MessageDispatch messageDispatch)voidErrorBroker. preProcessDispatch(MessageDispatch messageDispatch)ResponseTransportConnection. 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 MessageDispatchDurableTopicSubscription. createMessageDispatch(MessageReference node, Message message)protected MessageDispatchPrefetchSubscription. createMessageDispatch(MessageReference node, Message message)Methods in org.apache.activemq.broker.region with parameters of type MessageDispatch Modifier and Type Method Description voidRegionBroker. postProcessDispatch(MessageDispatch messageDispatch)voidRegionBroker. 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 voidLoggingBrokerPlugin. postProcessDispatch(MessageDispatch messageDispatch)voidUDPTraceBrokerPlugin. postProcessDispatch(MessageDispatch messageDispatch)voidLoggingBrokerPlugin. preProcessDispatch(MessageDispatch messageDispatch)voidTraceBrokerPathPlugin. 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 MessageDemandForwardingBridgeSupport. configureMessage(MessageDispatch md)voidDemandForwardingBridgeSupport. 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 ResponseCommandVisitor. processMessageDispatch(MessageDispatch dispatch)ResponseCommandVisitorAdapter. 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 voidAmqpSender. 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 MessageAckMQTTSubscription. createMessageAck(MessageDispatch md)Create aMessageAckthat 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 MessageDispatchStompAckEntry. getMessageDispatch()Constructors in org.apache.activemq.transport.stomp with parameters of type MessageDispatch Constructor Description StompAckEntry(MessageDispatch dispatch, String ackId, StompSubscription subscription)
-