Uses of Class
org.exolab.jms.message.MessageImpl

Packages that use MessageImpl
org.exolab.jms.message   
org.exolab.jms.messagemgr   
org.exolab.jms.persistence   
 

Uses of MessageImpl in org.exolab.jms.message
 

Subclasses of MessageImpl in org.exolab.jms.message
 class BytesMessageImpl
          This class implements the BytesMessage interface
 class MapMessageImpl
          This class implements the MapMessage interface.
 class ObjectMessageImpl
          This class implements the javax.jms.ObjectMessage interface.
 class StreamMessageImpl
          This class implements the StreamMessage interface.
 class TextMessageImpl
          This class implements the javax.jms.TextMessage interface
 

Methods in org.exolab.jms.message that return MessageImpl
 MessageImpl MessageHandle.getMessage()
          Return the associated message or null if it is invalid
 

Uses of MessageImpl in org.exolab.jms.messagemgr
 

Methods in org.exolab.jms.messagemgr that return MessageImpl
 MessageImpl TransientMessageHandle.getMessage()
          Return the associated message or null if it is invalid
 MessageImpl PersistentMessageHandle.getMessage()
          Return the associated message or null if it is invalid
protected  MessageImpl ConsumerEndpoint.getMessage(MessageHandle handle)
          Return the message for the specified handle
protected  MessageImpl DestinationCache.resolveExpiredMessage(MessageHandle handle)
          Resolve an expired message through its handle
protected  MessageImpl TopicDestinationCache.resolveExpiredMessage(MessageHandle handle)
          Resolve an expired message through its handle
 

Methods in org.exolab.jms.messagemgr with parameters of type MessageImpl
 void MessageMgr.add(MessageImpl message)
          Add a message to the message manager for the specified destination.
 void MessageLeaseHelper.addLease(MessageImpl message)
          Add a lease for message to notify listener when message expires.
protected  void ConsumerEndpoint.addMessage(MessageHandle handle, MessageImpl message)
          Cache a handle and its corresponding message
protected  void MessageMgr.addNonPersistentMessage(MessageImpl message)
          This method is used to process non-persistent messages.
protected  void MessageMgr.addPersistentMessage(java.sql.Connection connection, MessageImpl message)
          This method is used to process persistent messages published through the resource manager.
protected  void MessageMgr.addPersistentMessage(MessageImpl message)
          This method is used to process persistent messages.
static MessageHandle MessageHandleFactory.createHandle(DurableConsumerEndpoint durable, MessageImpl message)
          Create a transient message handle for a durable consumer
static MessageHandle MessageHandleFactory.createHandle(JmsDestination dest, java.lang.String name, MessageImpl message)
          Create a transient message handle.
static MessageHandle MessageHandleFactory.createHandle(QueueDestinationCache queue, MessageImpl message)
          Create a transient handle for a message belonging to a queue.
static MessageHandle MessageHandleFactory.createPersistentHandle(java.sql.Connection connection, DurableConsumerEndpoint durable, MessageImpl message)
          Create a persistent handle for a message belonging to a particular durable consumer
static MessageHandle MessageHandleFactory.createPersistentHandle(java.sql.Connection connection, JmsDestination dest, java.lang.String name, MessageImpl message)
          Create a persistent message handle from the destination and consumer name
static MessageHandle MessageHandleFactory.createPersistentHandle(java.sql.Connection connection, QueueDestinationCache queue, MessageImpl message)
          Create a persistent message handle belonging to a queue.
static void MessageHandleFactory.destroyPersistentHandle(java.sql.Connection connection, JmsDestination destination, java.lang.String name, MessageImpl message)
          Destroy a persistent handle associated with a destination, consumer name and message
 DestinationCache DestinationManager.getDestinationCache(MessageImpl message)
          Return the DestinationCache for this message.
static MessageHandle MessageHandleFactory.getHandle(ConsumerEndpoint consumer, MessageImpl message)
          Retrieve a message handle for the specified ConsumerEndpoint and message.
static MessageHandle MessageHandleFactory.getHandle(JmsDestination dest, java.lang.String name, MessageImpl message)
          Use the message, destination and optionally, the consumer name to retrieve a message handle.
static MessageHandle MessageHandleFactory.getHandle(MessageImpl message)
          Retrieve a TransientMessageHandle given the specified message, irrespective of whether it is a persistent or non-persistent message.
static MessageHandle MessageHandleFactory.getHandle(QueueDestinationCache queue, MessageImpl message)
          Retrieve a MessageHandle from the specified QueueConsumerEndpoint and message.
 boolean DestinationManager.isMessageForAdministeredDestination(MessageImpl msg)
          Test whether the specified message is for an administered destination.
 void ResourceManager.logPublishedMessage(javax.transaction.xa.Xid xid, MessageImpl message)
          Log this published message so that it can be passed through the system when the associated global transaction commits.
 boolean DestinationManager.messageAdded(JmsDestination destination, MessageImpl message)
           
abstract  boolean DestinationCache.messageAdded(JmsDestination destination, MessageImpl message)
          This method is called when the MessageMgr adds a message for this destination to the cache
 boolean QueueDestinationCache.messageAdded(JmsDestination destination, MessageImpl message)
           
 boolean TopicDestinationCache.messageAdded(JmsDestination destination, MessageImpl message)
           
 boolean MessageManagerEventListener.messageAdded(JmsDestination destination, MessageImpl message)
          This method is called when the MessageMgr adds a message for this destination to the cache
 boolean ConsumerManager.messageAdded(MessageImpl message)
           
 boolean ConsumerEndpoint.messageAdded(MessageImpl message)
           
 boolean QueueConsumerEndpoint.messageAdded(MessageImpl message)
           
 boolean DestinationCacheEventListener.messageAdded(MessageImpl message)
          This event is called when a non-persistent message is added to the DestinationCache.
 void DestinationManager.messageRemoved(JmsDestination destination, MessageImpl message)
           
abstract  void DestinationCache.messageRemoved(JmsDestination destination, MessageImpl message)
          This method is called when the MessageMgr removes a message from the cache.
 void QueueDestinationCache.messageRemoved(JmsDestination destination, MessageImpl message)
          This method is called when the MessageMgr removes a message from the cache.
 void TopicDestinationCache.messageRemoved(JmsDestination destination, MessageImpl message)
           
 void MessageManagerEventListener.messageRemoved(JmsDestination destination, MessageImpl message)
          This method is called when the MessageMgr removes a message from the cache.
 boolean ConsumerManager.messageRemoved(MessageImpl message)
           
 boolean TopicConsumerEndpoint.messageRemoved(MessageImpl message)
           
 boolean ConsumerEndpoint.messageRemoved(MessageImpl message)
           
 boolean QueueConsumerEndpoint.messageRemoved(MessageImpl message)
           
 boolean DestinationCacheEventListener.messageRemoved(MessageImpl message)
          This event is called when a message is removed from the DestinationCache.
 void QueueListener.onMessage(MessageImpl message)
          This method is called when a new message is added to a queue cache
 void QueueBrowserEndpoint.onMessage(MessageImpl message)
           
 boolean DestinationManager.persistentMessageAdded(java.sql.Connection connection, JmsDestination destination, MessageImpl message)
           
 boolean QueueDestinationCache.persistentMessageAdded(java.sql.Connection connection, JmsDestination destination, MessageImpl message)
           
 boolean TopicDestinationCache.persistentMessageAdded(java.sql.Connection connection, JmsDestination destination, MessageImpl message)
           
 boolean MessageManagerEventListener.persistentMessageAdded(java.sql.Connection connection, JmsDestination destination, MessageImpl message)
          This event is called when the MessageMgr adds a persistent message to the cache.
 boolean ConsumerManager.persistentMessageAdded(java.sql.Connection connection, MessageImpl message)
           
 boolean ConsumerEndpoint.persistentMessageAdded(java.sql.Connection connection, MessageImpl message)
           
 boolean QueueConsumerEndpoint.persistentMessageAdded(java.sql.Connection connection, MessageImpl message)
           
 boolean DestinationCacheEventListener.persistentMessageAdded(java.sql.Connection connection, MessageImpl message)
          This event is called when a persistent message is added to the DestinationCache.
 void DestinationManager.persistentMessageRemoved(java.sql.Connection connection, JmsDestination destination, MessageImpl message)
           
 void QueueDestinationCache.persistentMessageRemoved(java.sql.Connection connection, JmsDestination destination, MessageImpl message)
           
 void TopicDestinationCache.persistentMessageRemoved(java.sql.Connection connection, JmsDestination destination, MessageImpl message)
           
 void MessageManagerEventListener.persistentMessageRemoved(java.sql.Connection connection, JmsDestination destination, MessageImpl message)
          This event is called when the MessageMgr removes a persistent message from the cache.
 boolean ConsumerManager.persistentMessageRemoved(java.sql.Connection connection, MessageImpl message)
           
 boolean TopicConsumerEndpoint.persistentMessageRemoved(java.sql.Connection connection, MessageImpl message)
           
 boolean ConsumerEndpoint.persistentMessageRemoved(java.sql.Connection connection, MessageImpl message)
           
 boolean DestinationCacheEventListener.persistentMessageRemoved(java.sql.Connection connection, MessageImpl message)
          This event is called when a message is removed from the DestinationCache.
 void MessageLeaseHelper.removeLease(MessageImpl message)
          Remove a lease for a message
 

Constructors in org.exolab.jms.messagemgr with parameters of type MessageImpl
PersistentMessageHandle(MessageImpl message)
          Create a persistent handle from a message
 

Uses of MessageImpl in org.exolab.jms.persistence
 

Methods in org.exolab.jms.persistence that return MessageImpl
 MessageImpl Messages.deserialize(byte[] blob)
          Set the message from a serialized blob
 MessageImpl Messages.get(java.sql.Connection connection, java.lang.String messageId)
          Return the message identified by the message Id
 MessageImpl PersistentMessage.getMessage()
          return the held message from the persistent object.
abstract  MessageImpl PersistenceAdapter.getMessage(java.sql.Connection connection, java.lang.String id)
          Get a message from the persistence store.
 MessageImpl ObjectAdapter.getMessage(java.sql.Connection connection, java.lang.String id)
           
 MessageImpl BatchingRdbmsAdapter.getMessage(java.sql.Connection connection, java.lang.String id)
           
 MessageImpl RDBMSAdapter.getMessage(java.sql.Connection connection, java.lang.String id)
           
 

Methods in org.exolab.jms.persistence with parameters of type MessageImpl
 void Messages.add(java.sql.Connection connection, MessageImpl message)
          Add a message to the database, in the context of the specified transaction and connection.
abstract  void PersistenceAdapter.addMessage(java.sql.Connection connection, MessageImpl message)
          Add a new message to the database.
 void ObjectAdapter.addMessage(java.sql.Connection connection, MessageImpl message)
           
 void BatchingRdbmsAdapter.addMessage(java.sql.Connection connection, MessageImpl message)
           
 void RDBMSAdapter.addMessage(java.sql.Connection connection, MessageImpl message)
           
 byte[] Messages.serialize(MessageImpl message)
          Get the message as a serialized blob
 void PersistentMessage.setMessage(MessageImpl message)
          Set the message held by this persistent object
 void Messages.update(java.sql.Connection connection, MessageImpl message)
          Update the message state in the database.
abstract  void PersistenceAdapter.updateMessage(java.sql.Connection connection, MessageImpl message)
          Update this message in the database
 void ObjectAdapter.updateMessage(java.sql.Connection connection, MessageImpl message)
           
 void BatchingRdbmsAdapter.updateMessage(java.sql.Connection connection, MessageImpl message)
           
 void RDBMSAdapter.updateMessage(java.sql.Connection connection, MessageImpl message)
           
 

Constructors in org.exolab.jms.persistence with parameters of type MessageImpl
PersistentMessage(MessageImpl message)
          Store the message to be persisted.
 



Copyright © 1999-2005 The OpenJMS Group. All Rights Reserved.