Uses of Class
org.apache.activemq.command.Message

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 CompositeDestinationBroker.send(ConnectionContext context, Message message)
           
 void TransactionBroker.send(ConnectionContext context, Message message)
           
 void ErrorBroker.send(ConnectionContext context, Message message)
           
 void UserIDBroker.send(ConnectionContext context, Message messageSend)
           
 void BrokerBroadcaster.send(ConnectionContext context, Message messageSend)
           
 void EmptyBroker.send(ConnectionContext context, Message message)
           
 

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[] Topic.browse()
           
 Message[] DestinationFilter.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 Region.send(ConnectionContext context, Message message)
          Send a message to the broker to using the specified destination.
 void Destination.send(ConnectionContext context, Message messageSend)
           
 void RegionBroker.send(ConnectionContext context, Message message)
           
 void Queue.send(ConnectionContext context, Message message)
           
 void Topic.send(ConnectionContext context, Message message)
           
 void DestinationFilter.send(ConnectionContext context, Message messageSend)
           
 void AbstractRegion.send(ConnectionContext context, Message messageSend)
           
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[] SubscriptionRecoveryPolicy.browse(ActiveMQDestination dest)
           
 Message[] QueryBasedSubscriptionRecoveryPolicy.browse(ActiveMQDestination dest)
           
 Message[] NoSubscriptionRecoveryPolicy.browse(ActiveMQDestination dest)
           
 Message[] LastImageSubscriptionRecoveryPolicy.browse(ActiveMQDestination destination)
           
 Message[] TimedSubscriptionRecoveryPolicy.browse(ActiveMQDestination destination)
           
 Message[] FixedCountSubscriptionRecoveryPolicy.browse(ActiveMQDestination destination)
           
 Message[] FixedSizedSubscriptionRecoveryPolicy.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 VirtualTopicInterceptor.send(ConnectionContext context, Message message)
           
 void CompositeDestinationInterceptor.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 UDPTraceBrokerPlugin.send(ConnectionContext context, Message messageSend)
           
 void LoggingBrokerPlugin.send(ConnectionContext context, Message messageSend)
           
 void TimeStampingBrokerPlugin.send(ConnectionContext context, Message message)
           
 

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 ActiveMQObjectMessage.copy()
           
 Message ActiveMQStreamMessage.copy()
           
 Message ActiveMQTextMessage.copy()
           
 Message ActiveMQMapMessage.copy()
           
 Message ActiveMQBytesMessage.copy()
           
 Message Message.getMessage()
           
 Message MessageDispatch.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[] SimpleMessageList.browse(ActiveMQDestination destination)
           
 Message[] MessageList.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 KahaMessageStore.getMessage(MessageId identity)
           
 Message KahaTopicMessageStore.getMessage(MessageId identity)
           
 

Methods in org.apache.activemq.store.kahadaptor with parameters of type Message
 void KahaMessageStore.addMessage(ConnectionContext context, Message message)
           
 void KahaTopicMessageStore.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)
           
 



Copyright © 2010 Apache Software Foundation. All Rights Reserved.