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 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.mqtt |
A Broker side implementation of the MQTT 3.1 protocol - see http://mqtt.org/
|
Modifier and Type | Field and Description |
---|---|
protected LinkedList<MessageDispatch> |
ActiveMQMessageConsumer.deliveredMessages |
Modifier and Type | Method and Description |
---|---|
MessageDispatch |
SimplePriorityMessageDispatchChannel.dequeue(long timeout) |
MessageDispatch |
FifoMessageDispatchChannel.dequeue(long timeout) |
MessageDispatch |
MessageDispatchChannel.dequeue(long timeout)
Used to get an enqueued message.
|
MessageDispatch |
SimplePriorityMessageDispatchChannel.dequeueNoWait() |
MessageDispatch |
FifoMessageDispatchChannel.dequeueNoWait() |
MessageDispatch |
MessageDispatchChannel.dequeueNoWait() |
MessageDispatch |
SimplePriorityMessageDispatchChannel.peek() |
MessageDispatch |
FifoMessageDispatchChannel.peek() |
MessageDispatch |
MessageDispatchChannel.peek() |
Modifier and Type | Method and Description |
---|---|
protected LinkedList<MessageDispatch> |
SimplePriorityMessageDispatchChannel.getList(MessageDispatch md) |
List<MessageDispatch> |
ActiveMQSession.getUnconsumedMessages() |
List<MessageDispatch> |
SimplePriorityMessageDispatchChannel.removeAll() |
List<MessageDispatch> |
FifoMessageDispatchChannel.removeAll() |
List<MessageDispatch> |
MessageDispatchChannel.removeAll() |
Modifier and Type | Method and Description |
---|---|
void |
AdvisoryConsumer.dispatch(MessageDispatch md) |
void |
ActiveMQDispatcher.dispatch(MessageDispatch messageDispatch) |
void |
ActiveMQConnectionConsumer.dispatch(MessageDispatch messageDispatch) |
void |
ActiveMQSession.dispatch(MessageDispatch messageDispatch) |
void |
ActiveMQMessageConsumer.dispatch(MessageDispatch md) |
void |
SimplePriorityMessageDispatchChannel.enqueue(MessageDispatch message) |
void |
FifoMessageDispatchChannel.enqueue(MessageDispatch message) |
void |
MessageDispatchChannel.enqueue(MessageDispatch message) |
void |
SimplePriorityMessageDispatchChannel.enqueueFirst(MessageDispatch message) |
void |
FifoMessageDispatchChannel.enqueueFirst(MessageDispatch message) |
void |
MessageDispatchChannel.enqueueFirst(MessageDispatch message) |
protected LinkedList<MessageDispatch> |
SimplePriorityMessageDispatchChannel.getList(MessageDispatch md) |
protected int |
SimplePriorityMessageDispatchChannel.getPriority(MessageDispatch message) |
Modifier and Type | Method and Description |
---|---|
void |
EmptyBroker.postProcessDispatch(MessageDispatch messageDispatch) |
void |
MutableBrokerFilter.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 |
EmptyBroker.preProcessDispatch(MessageDispatch messageDispatch) |
void |
MutableBrokerFilter.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) |
Modifier and Type | Method and Description |
---|---|
protected MessageDispatch |
DurableTopicSubscription.createMessageDispatch(MessageReference node,
Message message) |
protected MessageDispatch |
PrefetchSubscription.createMessageDispatch(MessageReference node,
Message message) |
Modifier and Type | Method and Description |
---|---|
void |
RegionBroker.postProcessDispatch(MessageDispatch messageDispatch) |
void |
RegionBroker.preProcessDispatch(MessageDispatch messageDispatch) |
Modifier and Type | Method and Description |
---|---|
void |
UDPTraceBrokerPlugin.postProcessDispatch(MessageDispatch messageDispatch) |
void |
LoggingBrokerPlugin.postProcessDispatch(MessageDispatch messageDispatch) |
void |
LoggingBrokerPlugin.preProcessDispatch(MessageDispatch messageDispatch) |
void |
TraceBrokerPathPlugin.preProcessDispatch(MessageDispatch messageDispatch) |
Constructor and Description |
---|
MessageAck(MessageDispatch md,
byte ackType,
int messageCount) |
Modifier and Type | Method and Description |
---|---|
protected Message |
DemandForwardingBridgeSupport.configureMessage(MessageDispatch md) |
void |
DemandForwardingBridgeSupport.serviceLocalException(MessageDispatch messageDispatch,
Throwable error) |
Modifier and Type | Method and Description |
---|---|
Response |
CommandVisitor.processMessageDispatch(MessageDispatch dispatch) |
Response |
CommandVisitorAdapter.processMessageDispatch(MessageDispatch dispatch) |
Modifier and Type | Method and Description |
---|---|
MessageAck |
MQTTSubscription.createMessageAck(MessageDispatch md)
Create a
MessageAck that will acknowledge the given MessageDispatch . |
Copyright © 2005–2016 The Apache Software Foundation. All rights reserved.