Uses of Class
org.codehaus.activemq.message.ActiveMQMessage

Packages that use ActiveMQMessage
org.codehaus.activemq The core JMS client implementation classes  
org.codehaus.activemq.broker The API for the JMS Broker which is the server side of a JMS network though it may be deployed inside a client in peer style networks. 
org.codehaus.activemq.broker.impl The default implementation of the JMS Broker  
org.codehaus.activemq.message Message implementations  
org.codehaus.activemq.ra JCA managed connections and resource adapters for working with ActiveMQ  
org.codehaus.activemq.service The core services which make up the JMS Message Broker such as the Store, MessageContainer and MessageContainerManager  
org.codehaus.activemq.service.boundedvm   
org.codehaus.activemq.service.impl Default implementations of the services  
org.codehaus.activemq.store The APIs which need to be implemented for persistent message stores for durable messaging  
org.codehaus.activemq.store.bdb Message persistence implemented using Berkeley DB Java Edition  
org.codehaus.activemq.store.bdbn Message persistence implemented using Berkeley DB, native C version  
org.codehaus.activemq.store.howl Message persistence using a high performance transaction log via implemented using Howl whichi is used for short term persistence with longer term storage being used at checkpoints. 
org.codehaus.activemq.store.jdbc Message persistence implemented using JDBC  
org.codehaus.activemq.store.jdbm Message persistence implemented using JDBM which is the default persistence mechanism shipped with Geronimo (due to its BSD licence)  
org.codehaus.activemq.store.vm VM based implementation of message persistence  
org.codehaus.activemq.transport.jabber   
 

Uses of ActiveMQMessage in org.codehaus.activemq
 

Methods in org.codehaus.activemq that return ActiveMQMessage
static ActiveMQMessage ActiveMQMessageTransformation.transformMessage(Message message)
           
 ActiveMQMessage ActiveMQConnectionConsumer.receive(long timeout)
          Receives the next message that arrives within the specified timeout interval.
 

Methods in org.codehaus.activemq with parameters of type ActiveMQMessage
 boolean ActiveMQSession.isTarget(ActiveMQMessage message)
          Tests to see if the Message Dispatcher is a target for this message
 void ActiveMQSession.dispatch(ActiveMQMessage message)
          Dispatch an ActiveMQMessage
protected  void ActiveMQSession.messageDelivered(boolean sendAcknowledge, ActiveMQMessage message, boolean messageConsumed, boolean doRemove)
           
 boolean ActiveMQMessageDispatcher.isTarget(ActiveMQMessage message)
          Tests to see if the Message Dispatcher is a target for this message
 void ActiveMQMessageDispatcher.dispatch(ActiveMQMessage message)
          Dispatch an ActiveMQMessage
protected  void ActiveMQMessageConsumer.processMessage(ActiveMQMessage message)
          Process a Message - passing either to the queue or message listener
 boolean ActiveMQConnectionConsumer.isTarget(ActiveMQMessage message)
          Tests to see if the Message Dispatcher is a target for this message
 void ActiveMQConnectionConsumer.dispatch(ActiveMQMessage message)
          Dispatch an ActiveMQMessage
 

Uses of ActiveMQMessage in org.codehaus.activemq.broker
 

Methods in org.codehaus.activemq.broker with parameters of type ActiveMQMessage
 void BrokerContainer.sendTransactedMessage(BrokerClient client, java.lang.String transactionId, ActiveMQMessage message)
          send message with a transaction context
 void BrokerContainer.sendMessage(BrokerClient client, ActiveMQMessage message)
          Send a non-transacted message to the Broker
 void BrokerConnector.sendTransactedMessage(BrokerClient client, java.lang.String transactionId, ActiveMQMessage message)
          send message with a transaction context
 void BrokerConnector.sendMessage(BrokerClient client, ActiveMQMessage message)
          Send a non-transacted message to the Broker
 void BrokerClient.dispatch(ActiveMQMessage message)
          Dispatch an ActiveMQMessage to the end client
 void Broker.sendMessage(BrokerClient client, ActiveMQMessage message)
          send a message to the broker
 void Broker.sendTransactedMessage(BrokerClient client, java.lang.String transactionId, ActiveMQMessage message)
          send a message to the broker within a transaction
 

Uses of ActiveMQMessage in org.codehaus.activemq.broker.impl
 

Methods in org.codehaus.activemq.broker.impl with parameters of type ActiveMQMessage
 void DefaultBroker.sendMessage(BrokerClient client, ActiveMQMessage message)
          send a message to the broker
 void DefaultBroker.sendTransactedMessage(BrokerClient client, java.lang.String transactionId, ActiveMQMessage message)
          send a message to the broker within a transaction
 void BrokerContainerImpl.sendTransactedMessage(BrokerClient client, java.lang.String transactionId, ActiveMQMessage message)
          send message with a transaction context
 void BrokerContainerImpl.sendMessage(BrokerClient client, ActiveMQMessage message)
          Send a non-transacted message to the Broker
 void BrokerConnectorImpl.sendTransactedMessage(BrokerClient client, java.lang.String transactionId, ActiveMQMessage message)
          send message with a transaction context
 void BrokerConnectorImpl.sendMessage(BrokerClient client, ActiveMQMessage message)
          Send a non-transacted message to the Broker
 void BrokerClientImpl.dispatch(ActiveMQMessage message)
          Dispatch an ActiveMQMessage to the end client
 

Uses of ActiveMQMessage in org.codehaus.activemq.message
 

Subclasses of ActiveMQMessage in org.codehaus.activemq.message
 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 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
          A TextMessage object is used to send a message containing a java.lang.String.
 

Methods in org.codehaus.activemq.message that return ActiveMQMessage
 ActiveMQMessage ActiveMQTextMessage.shallowCopy()
           
 ActiveMQMessage ActiveMQTextMessage.deepCopy()
           
 ActiveMQMessage ActiveMQStreamMessage.shallowCopy()
           
 ActiveMQMessage ActiveMQStreamMessage.deepCopy()
           
 ActiveMQMessage ActiveMQObjectMessage.shallowCopy()
           
 ActiveMQMessage ActiveMQObjectMessage.deepCopy()
           
 ActiveMQMessage ActiveMQMessage.shallowCopy()
           
 ActiveMQMessage ActiveMQMessage.deepCopy()
           
 ActiveMQMessage ActiveMQMapMessage.shallowCopy()
           
 ActiveMQMessage ActiveMQMapMessage.deepCopy()
           
 ActiveMQMessage ActiveMQBytesMessage.shallowCopy()
           
 ActiveMQMessage ActiveMQBytesMessage.deepCopy()
           
 

Methods in org.codehaus.activemq.message with parameters of type ActiveMQMessage
protected  void ActiveMQMessageWriter.writeMessage(ActiveMQMessage msg, java.io.DataOutput dataOut)
           
 int ActiveMQMessage.compareTo(ActiveMQMessage that)
          Sorted by destination and then messageId
protected  void ActiveMQMessage.initializeOther(ActiveMQMessage other)
          Initializes another message with current values from this instance
 

Uses of ActiveMQMessage in org.codehaus.activemq.ra
 

Fields in org.codehaus.activemq.ra declared as ActiveMQMessage
(package private)  ActiveMQMessage ActiveMQPollingEndpointWorker.InboundEndpointWork.message
           
 

Uses of ActiveMQMessage in org.codehaus.activemq.service
 

Methods in org.codehaus.activemq.service that return ActiveMQMessage
 ActiveMQMessage[] Subscription.getMessagesToDispatch()
          Retrieve messages to dispatch
 ActiveMQMessage QueueMessageContainer.poll()
          Some implementations may need to poll to fill subscriptions this returns the next message in the container
 ActiveMQMessage QueueMessageContainer.peekNext(MessageIdentity messageIdentity)
          Used for browsing a MessageContainer this returns the next message in the container after the messageId
 ActiveMQMessage MessageContainer.getMessage(MessageIdentity messageIdentity)
          Return the ActiveMQMessage that matches the Id
 

Methods in org.codehaus.activemq.service with parameters of type ActiveMQMessage
 boolean Subscription.isTarget(ActiveMQMessage message)
          determines if the Subscription is interested in the message
 void Subscription.addMessage(MessageContainer container, ActiveMQMessage message)
          If the Subscription is a target for the message, the subscription will add a reference to the message and register an interest in the message to the container
 void MessageContainerManager.sendMessage(BrokerClient client, ActiveMQMessage message)
           
 MessageIdentity MessageContainer.addMessage(ActiveMQMessage msg)
          Add an ActiveMQMessage to the message container
 

Uses of ActiveMQMessage in org.codehaus.activemq.service.boundedvm
 

Methods in org.codehaus.activemq.service.boundedvm with parameters of type ActiveMQMessage
 boolean TransientTopicSubscription.isTarget(ActiveMQMessage message)
          determines if the Subscription is interested in the message
 void TransientTopicBoundedMessageManager.sendMessage(BrokerClient client, ActiveMQMessage message)
           
 boolean TransientTopicBoundedMessageContainer.targetAndDispatch(ActiveMQMessage message)
          See if this container should get this message and dispatch it
 

Uses of ActiveMQMessage in org.codehaus.activemq.service.impl
 

Methods in org.codehaus.activemq.service.impl that return ActiveMQMessage
 ActiveMQMessage[] SubscriptionImpl.getMessagesToDispatch()
          Retrieve messages to dispatch
protected  ActiveMQMessage[] SubscriptionImpl.getMessagesWithPrefetch()
           
 ActiveMQMessage MessageEntry.getMessage()
           
 ActiveMQMessage DurableTopicMessageContainer.getMessage(MessageIdentity messageID)
           
 ActiveMQMessage DurableQueueMessageContainer.getMessage(MessageIdentity messageID)
           
 ActiveMQMessage DurableQueueMessageContainer.poll()
           
 ActiveMQMessage DurableQueueMessageContainer.peekNext(MessageIdentity messageID)
           
 

Methods in org.codehaus.activemq.service.impl with parameters of type ActiveMQMessage
 void TransientTopicMessageContainerManager.sendMessage(BrokerClient client, ActiveMQMessage message)
           
 boolean SubscriptionImpl.isTarget(ActiveMQMessage message)
          determines if the Subscription is interested in the message
 void SubscriptionImpl.addMessage(MessageContainer container, ActiveMQMessage message)
          If the Subscription is a target for the message, the subscription will add a reference to the message and register an interest in the message to the container
protected  boolean SubscriptionImpl.clientIDsEqual(ActiveMQMessage message)
           
 void QueueMessageContainerManager.sendMessage(BrokerClient client, ActiveMQMessage message)
           
 void ProxyMessageContainerManager.sendMessage(BrokerClient client, ActiveMQMessage message)
           
 void InitialImageMessageContainerManager.sendMessage(BrokerClient client, ActiveMQMessage message)
           
 void DurableTopicMessageContainerManager.sendMessage(BrokerClient client, ActiveMQMessage message)
           
 MessageIdentity DurableTopicMessageContainer.addMessage(ActiveMQMessage message)
           
 MessageIdentity DurableQueueMessageContainer.addMessage(ActiveMQMessage message)
           
 

Constructors in org.codehaus.activemq.service.impl with parameters of type ActiveMQMessage
SendMessageTransactionTask(BrokerClient brokerClient, ActiveMQMessage message)
           
MessageEntry(ActiveMQMessage msg)
           
 

Uses of ActiveMQMessage in org.codehaus.activemq.store
 

Methods in org.codehaus.activemq.store that return ActiveMQMessage
 ActiveMQMessage MessageStore.getMessage(MessageIdentity identity)
          Looks up a message using either the String messageID or the messageNumber.
 

Methods in org.codehaus.activemq.store with parameters of type ActiveMQMessage
 MessageIdentity MessageStore.addMessage(ActiveMQMessage message)
           
 

Uses of ActiveMQMessage in org.codehaus.activemq.store.bdb
 

Methods in org.codehaus.activemq.store.bdb that return ActiveMQMessage
 ActiveMQMessage BDbMessageStore.getMessage(MessageIdentity identity)
           
protected  ActiveMQMessage BDbMessageStore.extractMessage(com.sleepycat.je.DatabaseEntry value)
           
 

Methods in org.codehaus.activemq.store.bdb with parameters of type ActiveMQMessage
 MessageIdentity BDbMessageStore.addMessage(ActiveMQMessage message)
           
protected  byte[] BDbMessageStore.asBytes(ActiveMQMessage message)
           
 

Uses of ActiveMQMessage in org.codehaus.activemq.store.bdbn
 

Methods in org.codehaus.activemq.store.bdbn that return ActiveMQMessage
 ActiveMQMessage BDbMessageStore.getMessage(MessageIdentity identity)
           
protected  ActiveMQMessage BDbMessageStore.extractMessage(com.sleepycat.db.Dbt value)
           
 

Methods in org.codehaus.activemq.store.bdbn with parameters of type ActiveMQMessage
 MessageIdentity BDbMessageStore.addMessage(ActiveMQMessage message)
           
protected  byte[] BDbMessageStore.asBytes(ActiveMQMessage message)
           
 

Uses of ActiveMQMessage in org.codehaus.activemq.store.howl
 

Methods in org.codehaus.activemq.store.howl that return ActiveMQMessage
 ActiveMQMessage HowlMessageStore.getMessage(MessageIdentity identity)
          Lets ensure that readers don't block writers so there only synchronization on the cache and checkpointStore.
 

Methods in org.codehaus.activemq.store.howl with parameters of type ActiveMQMessage
 MessageIdentity HowlMessageStore.addMessage(ActiveMQMessage message)
          This method is synchronized to ensure that only 1 thread can write to the log and cache and possibly checkpoint at once, to preserve order across the transaction log, cache and checkpointStore.
protected  void HowlMessageStore.checkpoint(ActiveMQMessage message)
          Writes the current RAM image of the transaction log to stable, checkpoint store
protected  boolean HowlMessageStore.addMessageToCache(ActiveMQMessage message)
          Adds the given message to the cache if there is spare capacity
 

Uses of ActiveMQMessage in org.codehaus.activemq.store.jdbc
 

Methods in org.codehaus.activemq.store.jdbc that return ActiveMQMessage
 ActiveMQMessage JDBCMessageStore.getMessage(MessageIdentity identity)
           
 

Methods in org.codehaus.activemq.store.jdbc with parameters of type ActiveMQMessage
 MessageIdentity JDBCMessageStore.addMessage(ActiveMQMessage message)
           
 

Uses of ActiveMQMessage in org.codehaus.activemq.store.jdbm
 

Methods in org.codehaus.activemq.store.jdbm that return ActiveMQMessage
 ActiveMQMessage JdbmMessageStore.getMessage(MessageIdentity identity)
           
protected  ActiveMQMessage JdbmMessageStore.getMessageBySequenceNumber(java.lang.Long sequenceNumber)
          Looks up the message using the given sequence number
 

Methods in org.codehaus.activemq.store.jdbm with parameters of type ActiveMQMessage
 MessageIdentity JdbmMessageStore.addMessage(ActiveMQMessage message)
           
 

Uses of ActiveMQMessage in org.codehaus.activemq.store.vm
 

Methods in org.codehaus.activemq.store.vm that return ActiveMQMessage
 ActiveMQMessage VMMessageStore.getMessage(MessageIdentity identity)
           
 

Methods in org.codehaus.activemq.store.vm with parameters of type ActiveMQMessage
 MessageIdentity VMMessageStore.addMessage(ActiveMQMessage message)
           
 

Uses of ActiveMQMessage in org.codehaus.activemq.transport.jabber
 

Methods in org.codehaus.activemq.transport.jabber with parameters of type ActiveMQMessage
protected  void JabberWireFormat.writeMessage(ActiveMQMessage message, java.lang.String body, java.io.DataOutput out)
           
protected  java.lang.String JabberWireFormat.getXmppType(ActiveMQMessage message)
           
 



Copyright © 2004 Protique, Ltd.. All Rights Reserved.