Uses of Class
org.activemq.message.ActiveMQMessage

Packages that use ActiveMQMessage
org.activemq The core JMS client implementation classes 
org.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.activemq.broker.impl The default implementation of the JMS Broker 
org.activemq.io.util   
org.activemq.message Message implementations 
org.activemq.security Plugable Security Adapter framework along with default implementations such as the JAAS implementation. 
org.activemq.security.jassjacc   
org.activemq.service The core services which make up the JMS Message Broker such as the Store, MessageContainer and MessageContainerManager 
org.activemq.service.boundedvm   
org.activemq.service.impl Default implementations of the services 
org.activemq.store The APIs which need to be implemented for persistent message stores for durable messaging 
org.activemq.store.cache   
org.activemq.store.jdbc Message persistence implemented using JDBC 
org.activemq.store.journal Message persistence using a high performance transaction log via the Journal interface. 
org.activemq.store.vm VM based implementation of message persistence 
org.activemq.transport.jabber A transport using Jabber (XMPP) 
 

Uses of ActiveMQMessage in org.activemq
 

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

Methods in org.activemq with parameters of type ActiveMQMessage
 void ActiveMQSession.acknowledge(ActiveMQMessage caller)
          Acknowledges all consumed messages of the session of this consumed message.
protected  void ActiveMQConnection.addToTransientConsumedRedeliverCache(ActiveMQMessage message)
           
protected  void ActiveMQSession.afterMessageDelivered(boolean sendAcknowledge, ActiveMQMessage message, boolean messageConsumed, boolean messageExpired, boolean beforeCalled)
           
protected  void ActiveMQSession.beforeMessageDelivered(ActiveMQMessage message)
           
 void ActiveMQSession.dispatch(ActiveMQMessage message)
          Dispatch an ActiveMQMessage
 void ActiveMQMessageDispatcher.dispatch(ActiveMQMessage message)
          Dispatch an ActiveMQMessage
 void ActiveMQConnectionConsumer.dispatch(ActiveMQMessage message)
          Dispatch an ActiveMQMessage
 boolean ActiveMQSession.isTarget(ActiveMQMessage message)
          Tests to see if the Message Dispatcher is a target for this message
 boolean ActiveMQMessageDispatcher.isTarget(ActiveMQMessage message)
          Tests to see if the Message Dispatcher is a target for this message
 boolean ActiveMQConnectionConsumer.isTarget(ActiveMQMessage message)
          Tests to see if the Message Dispatcher is a target for this message
protected  void ActiveMQMessageConsumer.processMessage(ActiveMQMessage message)
          Process a Message - passing either to the queue or message listener
 

Uses of ActiveMQMessage in org.activemq.broker
 

Methods in org.activemq.broker with parameters of type ActiveMQMessage
 void BrokerClient.dispatch(ActiveMQMessage message)
          Dispatch an ActiveMQMessage to the end client
 void BrokerContainer.sendMessage(BrokerClient client, ActiveMQMessage message)
          Send a non-transacted message to the Broker
 void Broker.sendMessage(BrokerClient client, ActiveMQMessage message)
          send a message to the broker
 void BrokerConnector.sendMessage(BrokerClient client, ActiveMQMessage message)
          Send a non-transacted message to the Broker
 void Broker.sendToDeadLetterQueue(String deadLetterName, ActiveMQMessage message)
          Add a message to a dead letter queue
 

Uses of ActiveMQMessage in org.activemq.broker.impl
 

Methods in org.activemq.broker.impl with parameters of type ActiveMQMessage
 void BrokerClientImpl.dispatch(ActiveMQMessage message)
          Dispatch an ActiveMQMessage to the end client
protected  void DefaultBroker.doMessageSend(BrokerClient client, ActiveMQMessage message)
           
 void DefaultBroker.sendMessage(BrokerClient client, ActiveMQMessage message)
          send a message to the broker
 void BrokerContainerImpl.sendMessage(BrokerClient client, ActiveMQMessage message)
          Send a non-transacted message to the Broker
 void BrokerConnectorImpl.sendMessage(BrokerClient client, ActiveMQMessage message)
          Send a non-transacted message to the Broker
 void DefaultBroker.sendToDeadLetterQueue(String deadLetterName, ActiveMQMessage expiredMessage)
          Add a message to a dead letter queue
 

Uses of ActiveMQMessage in org.activemq.io.util
 

Methods in org.activemq.io.util that return ActiveMQMessage
 ActiveMQMessage SpooledBoundedActiveMQMessageQueue.dequeue()
           
 ActiveMQMessage SpooledBoundedActiveMQMessageQueue.dequeue(long timeInMillis)
           
 ActiveMQMessage SpooledBoundedActiveMQMessageQueue.dequeueNoWait()
           
 ActiveMQMessage MemoryBoundedMessageCache.get(String msgid)
          Gets a message that was previously put into this object.
 

Methods in org.activemq.io.util with parameters of type ActiveMQMessage
 void SpooledBoundedActiveMQMessageQueue.enqueue(ActiveMQMessage packet)
          Place a ActiveMQMessage at the head of the Queue
 void SpooledBoundedActiveMQMessageQueue.enqueueNoBlock(ActiveMQMessage packet)
          Enqueue a ActiveMQMessage without checking usage limits
 void MemoryBoundedMessageCache.put(String messageID, ActiveMQMessage message)
          Puts a message into the cache.
 

Uses of ActiveMQMessage in org.activemq.message
 

Subclasses of ActiveMQMessage in org.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.activemq.message that return ActiveMQMessage
 ActiveMQMessage ActiveMQMessage.deepCopy()
           
 ActiveMQMessage ActiveMQBytesMessage.deepCopy()
           
 ActiveMQMessage ActiveMQMapMessage.deepCopy()
           
 ActiveMQMessage ActiveMQObjectMessage.deepCopy()
           
 ActiveMQMessage ActiveMQStreamMessage.deepCopy()
           
 ActiveMQMessage ActiveMQTextMessage.deepCopy()
           
 ActiveMQMessage ActiveMQMessage.shallowCopy()
           
 ActiveMQMessage ActiveMQBytesMessage.shallowCopy()
           
 ActiveMQMessage ActiveMQMapMessage.shallowCopy()
           
 ActiveMQMessage ActiveMQObjectMessage.shallowCopy()
           
 ActiveMQMessage ActiveMQStreamMessage.shallowCopy()
           
 ActiveMQMessage ActiveMQTextMessage.shallowCopy()
           
 

Methods in org.activemq.message with parameters of type ActiveMQMessage
 void MessageAcknowledge.acknowledge(ActiveMQMessage caller)
          Acknowledge receipt of this message
 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.activemq.security
 

Methods in org.activemq.security with parameters of type ActiveMQMessage
 boolean SecurityAdapter.authorizeReceive(BrokerClient client, ActiveMQMessage message)
          Returns true if the given client is authorized to receive the given message.
 void SecurityAdapter.authorizeSendMessage(BrokerClient client, ActiveMQMessage message)
          Authorizes on a per message basis whether or not the client is allowed to send the given message.
 

Uses of ActiveMQMessage in org.activemq.security.jassjacc
 

Methods in org.activemq.security.jassjacc with parameters of type ActiveMQMessage
 boolean JassJaccSecurityAdapter.authorizeReceive(BrokerClient client, ActiveMQMessage message)
           
 void JassJaccSecurityAdapter.authorizeSendMessage(BrokerClient client, ActiveMQMessage message)
           
 

Uses of ActiveMQMessage in org.activemq.service
 

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

Methods in org.activemq.service with parameters of type ActiveMQMessage
 void MessageContainer.addMessage(ActiveMQMessage msg)
          Add an ActiveMQMessage to the message container
 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
protected  ActiveMQMessage DeadLetterPolicy.createDeadLetterMessage(String dlqName, ActiveMQMessage message)
           
 boolean Subscription.isTarget(ActiveMQMessage message)
          determines if the Subscription is interested in the message
 void MessageContainerManager.sendMessage(BrokerClient client, ActiveMQMessage message)
           
 void DeadLetterPolicy.sendToDeadLetter(ActiveMQMessage message)
          Send a message to a dead letter queue
 void QueueMessageContainerManager.sendToDeadLetterQueue(String deadLetterName, ActiveMQMessage message)
          Add a message to a dead letter queue
 

Uses of ActiveMQMessage in org.activemq.service.boundedvm
 

Methods in org.activemq.service.boundedvm that return ActiveMQMessage
 ActiveMQMessage TransientQueueSubscription.acknowledgeMessage(String id)
          Acknowledge the receipt of a message by a consumer
 ActiveMQMessage DurableMessagePointer.getMessage()
           
 ActiveMQMessage TransientQueueBoundedMessageContainer.getMessage(MessageIdentity messageIdentity)
           
 ActiveMQMessage TransientTopicBoundedMessageContainer.getMessage(MessageIdentity messageIdentity)
           
 

Methods in org.activemq.service.boundedvm with parameters of type ActiveMQMessage
 void TransientQueueSubscription.addAckedMessage(ActiveMQMessage message)
          Add an acked message.
 void TransientQueueBoundedMessageContainer.addMessage(ActiveMQMessage msg)
           
 void TransientTopicBoundedMessageContainer.addMessage(ActiveMQMessage msg)
           
 void TransientQueueSubscription.doDispatch(ActiveMQMessage message)
          Dispatch a message to the Consumer
 void TransientQueueBoundedMessageContainer.enqueue(ActiveMQMessage message)
          enqueue a message for dispatching
 void DurableQueueBoundedMessageContainer.enqueue(ActiveMQMessage message)
          enqueue a message for dispatching
 boolean TransientQueueSubscription.isTarget(ActiveMQMessage message)
          determines if the Subscription is interested in the message
abstract  boolean TransientSubscription.isTarget(ActiveMQMessage message)
          determines if the Subscription is interested in the message
 boolean DurableQueueSubscription.isTarget(ActiveMQMessage message)
          determines if the Subscription is interested in the message
abstract  boolean DurableSubscription.isTarget(ActiveMQMessage message)
          determines if the Subscription is interested in the message
 boolean TransientTopicSubscription.isTarget(ActiveMQMessage message)
          determines if the Subscription is interested in the message
 void TransientQueueBoundedMessageContainer.redeliver(ActiveMQMessage message)
          re-enqueue a message for dispatching
 void TransientQueueBoundedMessageManager.sendMessage(BrokerClient client, ActiveMQMessage message)
           
 void DurableQueueBoundedMessageManager.sendMessage(BrokerClient client, ActiveMQMessage message)
           
 void TransientTopicBoundedMessageManager.sendMessage(BrokerClient client, ActiveMQMessage message)
           
 void DurableQueueBoundedMessageManager.sendToDeadLetterQueue(String deadLetterName, ActiveMQMessage message)
           
 boolean TransientTopicBoundedMessageContainer.targetAndDispatch(BrokerClient sender, ActiveMQMessage message)
          See if this container should get this message and dispatch it
 

Constructors in org.activemq.service.boundedvm with parameters of type ActiveMQMessage
DurableMessagePointer(MessageStore messageStore, ActiveMQDestination destination, ActiveMQMessage message)
           
 

Uses of ActiveMQMessage in org.activemq.service.impl
 

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

Methods in org.activemq.service.impl with parameters of type ActiveMQMessage
 void DurableQueueMessageContainer.addMessage(ActiveMQMessage message)
           
 void DurableTopicMessageContainer.addMessage(ActiveMQMessage 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)
           
protected  boolean SubscriptionImpl.isAuthorizedForMessage(ActiveMQMessage message)
          Returns whether or not the consumer can receive the given message
 boolean SubscriptionImpl.isTarget(ActiveMQMessage message)
          determines if the Subscription is interested in the message
 void DurableQueueMessageContainerManager.sendMessage(BrokerClient client, ActiveMQMessage message)
           
 void DurableTopicMessageContainerManager.sendMessage(BrokerClient client, ActiveMQMessage message)
           
 void InitialImageMessageContainerManager.sendMessage(BrokerClient client, ActiveMQMessage message)
           
 void ProxyMessageContainerManager.sendMessage(BrokerClient client, ActiveMQMessage message)
           
 void TransientTopicMessageContainerManager.sendMessage(BrokerClient client, ActiveMQMessage message)
           
 void DurableQueueMessageContainerManager.sendToDeadLetterQueue(String deadLetterName, ActiveMQMessage message)
          Add a message to a dead letter queue
protected  void MessageContainerManagerSupport.updateSendStats(BrokerClient client, ActiveMQMessage message)
          Updates the message sending stats
 

Constructors in org.activemq.service.impl with parameters of type ActiveMQMessage
MessageEntry(ActiveMQMessage msg)
           
 

Uses of ActiveMQMessage in org.activemq.store
 

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

Methods in org.activemq.store with parameters of type ActiveMQMessage
 void MessageStore.addMessage(ActiveMQMessage message)
          Adds a message to the message store
 void ProxyMessageStore.addMessage(ActiveMQMessage message)
           
 void ProxyTopicMessageStore.addMessage(ActiveMQMessage message)
           
 void TransactionStore.RecoveryListener.recover(ActiveMQXid xid, ActiveMQMessage[] addedMessages, MessageAck[] aks)
           
 

Uses of ActiveMQMessage in org.activemq.store.cache
 

Methods in org.activemq.store.cache that return ActiveMQMessage
 ActiveMQMessage MessageCache.get(String msgid)
          Gets a message that was previously put into this object.
 ActiveMQMessage SimpleMessageCache.get(String msgid)
          Gets a message that was previously put into this object.
 ActiveMQMessage CacheMessageStore.getMessage(MessageIdentity identity)
          Return the message from the cache or go to the longTermStore if it is not in there.
 

Methods in org.activemq.store.cache with parameters of type ActiveMQMessage
 void CacheMessageStore.addMessage(ActiveMQMessage message)
          Add the meessage to the long term store and cache it.
 void MessageCache.put(String messageID, ActiveMQMessage message)
          Puts a message into the cache.
 void SimpleMessageCache.put(String messageID, ActiveMQMessage message)
          Puts a message into the cache.
 

Uses of ActiveMQMessage in org.activemq.store.jdbc
 

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

Methods in org.activemq.store.jdbc with parameters of type ActiveMQMessage
 void JDBCMessageStore.addMessage(ActiveMQMessage message)
           
protected  void JDBCPersistenceAdapter.sendToDeadLetter(ActiveMQMessage message)
           
 

Uses of ActiveMQMessage in org.activemq.store.journal
 

Methods in org.activemq.store.journal that return ActiveMQMessage
 ActiveMQMessage JournalTransactionStore.AddMessageCommand.getMessage()
           
 ActiveMQMessage JournalMessageStore.getMessage(MessageIdentity identity)
           
 ActiveMQMessage[] JournalTransactionStore.Tx.getMessages()
           
 

Methods in org.activemq.store.journal with parameters of type ActiveMQMessage
 void JournalTransactionStore.Tx.add(JournalMessageStore store, ActiveMQMessage msg)
           
 void JournalMessageStore.addMessage(ActiveMQMessage message)
          Not synchronized since the Journal has better throughput if you increase the number of conncurrent writes that it is doing.
 void JournalMessageStore.replayAddMessage(ActiveMQMessage msg)
           
 

Uses of ActiveMQMessage in org.activemq.store.vm
 

Methods in org.activemq.store.vm that return ActiveMQMessage
 ActiveMQMessage VMTransactionStore.AddMessageCommand.getMessage()
           
 ActiveMQMessage VMMessageStore.getMessage(MessageIdentity identity)
           
 ActiveMQMessage[] VMTransactionStore.Tx.getMessages()
           
 

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

Uses of ActiveMQMessage in org.activemq.transport.jabber
 

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



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