|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use Message | |
---|---|
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.jmx | JMX MBeans for the broker and its core connectors. |
org.apache.activemq.broker.region | Region abstraction and implementations in the Broker. |
org.apache.activemq.broker.region.policy | The policies which can be associated with a particular destination or wildcard. |
org.apache.activemq.broker.region.virtual | Implementation classes for Virtual Destinations |
org.apache.activemq.broker.util | Some utility Broker Plugins |
org.apache.activemq.broker.view | Broker Plugins for visualising the current system |
org.apache.activemq.command | Command objects used via the Command Pattern to communicate among nodes |
org.apache.activemq.filter | Filter implementations for wildcards & JMS selectors |
org.apache.activemq.memory.list | |
org.apache.activemq.network | Support for federated networks of brokers. |
org.apache.activemq.security | Plugable Security Adapter framework along with default implementations such as the JAAS implementation. |
org.apache.activemq.state | |
org.apache.activemq.store | The APIs which need to be implemented for persistent message stores for durable messaging |
org.apache.activemq.store.jdbc | Message persistence implemented using JDBC |
org.apache.activemq.store.journal | Message persistence using a high performance transaction log via the Journal interface. |
org.apache.activemq.store.kahadaptor | kaha implementation of message persistence for the broker |
org.apache.activemq.store.memory | VM based implementation of message persistence |
org.apache.activemq.store.rapid | |
org.apache.activemq.util | Some utility classes |
Uses of Message in org.apache.activemq.broker |
---|
Methods in org.apache.activemq.broker with parameters of type Message | |
---|---|
Response |
TransportConnection.processMessage(Message messageSend)
|
void |
MutableBrokerFilter.send(ConnectionContext context,
Message messageSend)
|
void |
BrokerFilter.send(ConnectionContext context,
Message messageSend)
|
void |
TransactionBroker.send(ConnectionContext context,
Message message)
|
void |
CompositeDestinationBroker.send(ConnectionContext context,
Message message)
|
void |
ErrorBroker.send(ConnectionContext context,
Message message)
|
void |
EmptyBroker.send(ConnectionContext context,
Message message)
|
void |
UserIDBroker.send(ConnectionContext context,
Message messageSend)
|
void |
BrokerBroadcaster.send(ConnectionContext context,
Message messageSend)
|
Uses of Message in org.apache.activemq.broker.ft |
---|
Methods in org.apache.activemq.broker.ft with parameters of type Message | |
---|---|
void |
MasterBroker.send(ConnectionContext context,
Message message)
|
protected void |
MasterBroker.sendToSlave(Message message)
|
Uses of Message in org.apache.activemq.broker.jmx |
---|
Methods in org.apache.activemq.broker.jmx with parameters of type Message | |
---|---|
static javax.management.openmbean.CompositeData |
OpenTypeSupport.convert(Message message)
|
Uses of Message in org.apache.activemq.broker.region |
---|
Methods in org.apache.activemq.broker.region that return Message | |
---|---|
Message[] |
Destination.browse()
|
Message[] |
Queue.browse()
|
Message[] |
DestinationFilter.browse()
|
Message[] |
Topic.browse()
|
Message |
MessageReference.getMessage()
|
Message |
IndirectMessageReference.getMessage()
|
Message |
Queue.getMessage(java.lang.String messageId)
|
Message |
MessageReference.getMessageHardRef()
|
Message |
IndirectMessageReference.getMessageHardRef()
|
Message |
Topic.loadMessage(MessageId messageId)
|
Methods in org.apache.activemq.broker.region with parameters of type Message | |
---|---|
protected MessageDispatch |
DurableTopicSubscription.createMessageDispatch(MessageReference node,
Message message)
|
protected MessageDispatch |
PrefetchSubscription.createMessageDispatch(MessageReference node,
Message message)
|
protected void |
Topic.dispatch(ConnectionContext context,
Message message)
|
protected void |
PrefetchSubscription.onDispatch(MessageReference node,
Message message)
|
protected void |
QueueSubscription.onDispatch(MessageReference node,
Message message)
OK Message was transmitted, we can now drop the reference count. |
protected void |
Topic.onMessageWithNoConsumers(ConnectionContext context,
Message message)
Provides a hook to allow messages with no consumer to be processed in some way - such as to send to a dead letter queue or something.. |
void |
Destination.send(ConnectionContext context,
Message messageSend)
|
void |
Region.send(ConnectionContext context,
Message message)
Send a message to the broker to using the specified destination. |
void |
RegionBroker.send(ConnectionContext context,
Message message)
|
void |
Queue.send(ConnectionContext context,
Message message)
|
void |
AbstractRegion.send(ConnectionContext context,
Message messageSend)
|
void |
DestinationFilter.send(ConnectionContext context,
Message messageSend)
|
void |
Topic.send(ConnectionContext context,
Message message)
|
protected void |
DestinationFilter.send(ConnectionContext context,
Message message,
ActiveMQDestination destination)
Sends a message to the given destination which may be a wildcard |
Constructors in org.apache.activemq.broker.region with parameters of type Message | |
---|---|
IndirectMessageReference(Queue destination,
MessageStore destinationStore,
Message message)
|
Uses of Message in org.apache.activemq.broker.region.policy |
---|
Methods in org.apache.activemq.broker.region.policy that return Message | |
---|---|
Message[] |
NoSubscriptionRecoveryPolicy.browse(ActiveMQDestination dest)
|
Message[] |
SubscriptionRecoveryPolicy.browse(ActiveMQDestination dest)
|
Message[] |
FixedCountSubscriptionRecoveryPolicy.browse(ActiveMQDestination destination)
|
Message[] |
TimedSubscriptionRecoveryPolicy.browse(ActiveMQDestination destination)
|
Message[] |
FixedSizedSubscriptionRecoveryPolicy.browse(ActiveMQDestination destination)
|
Message[] |
QueryBasedSubscriptionRecoveryPolicy.browse(ActiveMQDestination dest)
|
Message[] |
LastImageSubscriptionRecoveryPolicy.browse(ActiveMQDestination destination)
|
Methods in org.apache.activemq.broker.region.policy with parameters of type Message | |
---|---|
boolean |
MessageQuery.validateUpdate(Message message)
Returns true if the given update is valid and does not overlap with the initial message query. |
Uses of Message in org.apache.activemq.broker.region.virtual |
---|
Methods in org.apache.activemq.broker.region.virtual with parameters of type Message | |
---|---|
void |
CompositeDestinationInterceptor.send(ConnectionContext context,
Message message)
|
void |
VirtualTopicInterceptor.send(ConnectionContext context,
Message message)
|
Uses of Message in org.apache.activemq.broker.util |
---|
Methods in org.apache.activemq.broker.util with parameters of type Message | |
---|---|
void |
LoggingBrokerPlugin.send(ConnectionContext context,
Message messageSend)
|
void |
TimeStampingBrokerPlugin.send(ConnectionContext context,
Message message)
|
void |
UDPTraceBrokerPlugin.send(ConnectionContext context,
Message messageSend)
|
Uses of Message in org.apache.activemq.broker.view |
---|
Methods in org.apache.activemq.broker.view with parameters of type Message | |
---|---|
void |
ConnectionDotFileInterceptor.send(ConnectionContext context,
Message messageSend)
|
Uses of Message in org.apache.activemq.command |
---|
Subclasses of Message in org.apache.activemq.command | |
---|---|
class |
ActiveMQBytesMessage
A BytesMessage object is used to send a message containing a stream of uninterpreted bytes. |
class |
ActiveMQMapMessage
A MapMessage object is used to send a set of name-value pairs. |
class |
ActiveMQMessage
|
class |
ActiveMQObjectMessage
An ObjectMessage object is used to send a message that contains a serializable object in the Java
programming language ("Java object"). |
class |
ActiveMQStreamMessage
A StreamMessage object is used to send a stream of primitive
types in the Java programming language. |
class |
ActiveMQTextMessage
|
Fields in org.apache.activemq.command declared as Message | |
---|---|
protected Message |
MessageDispatch.message
|
Methods in org.apache.activemq.command that return Message | |
---|---|
abstract Message |
Message.copy()
|
Message |
ActiveMQMessage.copy()
|
Message |
ActiveMQTextMessage.copy()
|
Message |
ActiveMQStreamMessage.copy()
|
Message |
ActiveMQBytesMessage.copy()
|
Message |
ActiveMQObjectMessage.copy()
|
Message |
ActiveMQMapMessage.copy()
|
Message |
MessageDispatch.getMessage()
|
Message |
Message.getMessage()
|
Message |
Message.getMessageHardRef()
|
Methods in org.apache.activemq.command with parameters of type Message | |
---|---|
protected void |
Message.copy(Message copy)
|
protected boolean |
NetworkBridgeFilter.matchesForwardingFilter(Message message)
|
void |
MessageDispatch.setMessage(Message message)
|
Uses of Message in org.apache.activemq.filter |
---|
Methods in org.apache.activemq.filter that return Message | |
---|---|
Message |
MessageEvaluationContext.getMessage()
|
Methods in org.apache.activemq.filter with parameters of type Message | |
---|---|
boolean |
XMLBeansXPathEvaluator.evaluate(Message message)
|
boolean |
JAXPXPathEvaluator.evaluate(Message message)
|
java.lang.Object |
PropertyExpression.evaluate(Message message)
|
boolean |
XalanXPathEvaluator.evaluate(Message m)
|
boolean |
XPathExpression.XPathEvaluator.evaluate(Message message)
|
static java.lang.String[] |
DestinationPath.getDestinationPaths(Message message)
|
Uses of Message in org.apache.activemq.memory.list |
---|
Methods in org.apache.activemq.memory.list that return Message | |
---|---|
Message[] |
MessageList.browse(ActiveMQDestination destination)
|
Message[] |
SimpleMessageList.browse(ActiveMQDestination destination)
|
Message[] |
DestinationBasedMessageList.browse(ActiveMQDestination destination)
|
Uses of Message in org.apache.activemq.network |
---|
Methods in org.apache.activemq.network that return Message | |
---|---|
protected Message |
DemandForwardingBridgeSupport.configureMessage(MessageDispatch md)
|
Uses of Message in org.apache.activemq.security |
---|
Methods in org.apache.activemq.security with parameters of type Message | |
---|---|
boolean |
MessageAuthorizationPolicy.isAllowedToConsume(ConnectionContext context,
Message message)
Returns true if the given message is able to be dispatched to the connection performing any user |
void |
AuthorizationBroker.send(ConnectionContext context,
Message messageSend)
|
Uses of Message in org.apache.activemq.state |
---|
Methods in org.apache.activemq.state with parameters of type Message | |
---|---|
Response |
CommandVisitor.processMessage(Message send)
|
Response |
ConnectionStateTracker.processMessage(Message send)
|
Uses of Message in org.apache.activemq.store |
---|
Methods in org.apache.activemq.store that return Message | |
---|---|
Message |
MessageStore.getMessage(MessageId identity)
Looks up a message using either the String messageID or the messageNumber. |
Message |
ProxyTopicMessageStore.getMessage(MessageId identity)
|
Message |
ProxyMessageStore.getMessage(MessageId identity)
|
Methods in org.apache.activemq.store with parameters of type Message | |
---|---|
void |
MessageStore.addMessage(ConnectionContext context,
Message message)
Adds a message to the message store |
void |
ProxyTopicMessageStore.addMessage(ConnectionContext context,
Message message)
|
void |
ProxyMessageStore.addMessage(ConnectionContext context,
Message message)
|
void |
TransactionRecoveryListener.recover(XATransactionId xid,
Message[] addedMessages,
MessageAck[] aks)
|
void |
MessageRecoveryListener.recoverMessage(Message message)
|
Uses of Message in org.apache.activemq.store.jdbc |
---|
Methods in org.apache.activemq.store.jdbc that return Message | |
---|---|
Message |
JDBCMessageStore.getMessage(MessageId messageId)
|
Methods in org.apache.activemq.store.jdbc with parameters of type Message | |
---|---|
void |
JDBCMessageStore.addMessage(ConnectionContext context,
Message message)
|
Uses of Message in org.apache.activemq.store.journal |
---|
Methods in org.apache.activemq.store.journal that return Message | |
---|---|
Message |
QuickJournalMessageStore.getMessage(MessageId identity)
|
Message |
JournalMessageStore.getMessage(MessageId identity)
|
Message[] |
QuickJournalTransactionStore.Tx.getMessages()
|
Message[] |
JournalTransactionStore.Tx.getMessages()
|
Methods in org.apache.activemq.store.journal with parameters of type Message | |
---|---|
void |
JournalTransactionStore.Tx.add(JournalMessageStore store,
Message msg)
|
void |
QuickJournalTransactionStore.Tx.add(QuickJournalMessageStore store,
Message msg,
org.apache.activeio.journal.RecordLocation loc)
|
void |
QuickJournalMessageStore.addMessage(ConnectionContext context,
Message message)
Not synchronized since the Journal has better throughput if you increase the number of concurrent writes that it is doing. |
void |
QuickJournalTopicMessageStore.addMessage(ConnectionContext context,
Message message)
|
void |
JournalMessageStore.addMessage(ConnectionContext context,
Message message)
Not synchronized since the Journal has better throughput if you increase the number of concurrent writes that it is doing. |
void |
JournalTopicMessageStore.addMessage(ConnectionContext context,
Message message)
|
void |
JournalMessageStore.replayAddMessage(ConnectionContext context,
Message message)
|
void |
QuickJournalMessageStore.replayAddMessage(ConnectionContext context,
Message message,
org.apache.activeio.journal.RecordLocation location)
|
Constructors in org.apache.activemq.store.journal with parameters of type Message | |
---|---|
QuickJournalMessageData(Message message,
org.apache.activeio.journal.RecordLocation location)
|
Uses of Message in org.apache.activemq.store.kahadaptor |
---|
Methods in org.apache.activemq.store.kahadaptor that return Message | |
---|---|
Message |
KahaTopicMessageStore.getMessage(MessageId identity)
|
Message |
KahaMessageStore.getMessage(MessageId identity)
|
Methods in org.apache.activemq.store.kahadaptor with parameters of type Message | |
---|---|
void |
KahaTopicMessageStore.addMessage(ConnectionContext context,
Message message)
|
void |
KahaMessageStore.addMessage(ConnectionContext context,
Message message)
|
Uses of Message in org.apache.activemq.store.memory |
---|
Methods in org.apache.activemq.store.memory that return Message | |
---|---|
Message |
MemoryTransactionStore.AddMessageCommand.getMessage()
|
Message |
MemoryMessageStore.getMessage(MessageId identity)
|
Message[] |
MemoryTransactionStore.Tx.getMessages()
|
Methods in org.apache.activemq.store.memory with parameters of type Message | |
---|---|
void |
MemoryMessageStore.addMessage(ConnectionContext context,
Message message)
|
void |
MemoryTopicMessageStore.addMessage(ConnectionContext context,
Message message)
|
Uses of Message in org.apache.activemq.store.rapid |
---|
Methods in org.apache.activemq.store.rapid that return Message | |
---|---|
Message |
RapidMessageStore.getMessage(MessageId id)
|
Message[] |
RapidTransactionStore.Tx.getMessages()
|
Methods in org.apache.activemq.store.rapid with parameters of type Message | |
---|---|
void |
RapidTransactionStore.Tx.add(RapidMessageStore store,
Message msg,
org.apache.activeio.journal.RecordLocation loc)
|
void |
RapidMessageStore.addMessage(ConnectionContext context,
Message message)
Not synchronized since the Journal has better throughput if you increase the number of concurrent writes that it is doing. |
void |
RapidTopicMessageStore.addMessage(ConnectionContext context,
Message message)
|
void |
RapidMessageStore.replayAddMessage(ConnectionContext context,
Message message,
org.apache.activeio.journal.RecordLocation location)
|
Constructors in org.apache.activemq.store.rapid with parameters of type Message | |
---|---|
RapidMessageReference(Message message,
org.apache.activeio.journal.RecordLocation location)
|
Uses of Message in org.apache.activemq.util |
---|
Methods in org.apache.activemq.util with parameters of type Message | |
---|---|
static void |
BrokerSupport.resend(ConnectionContext context,
Message message,
ActiveMQDestination deadLetterDestination)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |