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

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

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
MessageImpl	PersistentMessageHandle.getMessage() Return the associated message or null if it is invalid
protected MessageImpl	TopicDestinationCache.resolveExpiredMessage(MessageHandle handle) Resolve an expired message through its handle
MessageImpl	TransientMessageHandle.getMessage() Return the associated message or null if it is invalid

Methods in org.exolab.jms.messagemgr with parameters of type MessageImpl

boolean	ConsumerEndpoint.messageAdded(MessageImpl message)
boolean	ConsumerEndpoint.messageRemoved(MessageImpl message)
boolean	ConsumerEndpoint.persistentMessageAdded(java.sql.Connection connection, MessageImpl message)
boolean	ConsumerEndpoint.persistentMessageRemoved(java.sql.Connection connection, MessageImpl message)
protected void	ConsumerEndpoint.addMessage(MessageHandle handle, MessageImpl message) Cache a handle and its corresponding message
boolean	ConsumerManager.messageAdded(MessageImpl message)
boolean	ConsumerManager.messageRemoved(MessageImpl message)
boolean	ConsumerManager.persistentMessageAdded(java.sql.Connection connection, MessageImpl message)
boolean	ConsumerManager.persistentMessageRemoved(java.sql.Connection connection, 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
abstract void	DestinationCache.messageRemoved(JmsDestination destination, MessageImpl message) This method is called when the MessageMgr removes a message from the cache.
boolean	DestinationCacheEventListener.messageAdded(MessageImpl message) This event is called when a non-persistent message is added to the DestinationCache.
boolean	DestinationCacheEventListener.messageRemoved(MessageImpl message) This event is called when a message is removed from the DestinationCache.
boolean	DestinationCacheEventListener.persistentMessageAdded(java.sql.Connection connection, MessageImpl message) This event is called when a persistent message is added to the DestinationCache.
boolean	DestinationCacheEventListener.persistentMessageRemoved(java.sql.Connection connection, MessageImpl message) This event is called when a message is removed from the DestinationCache.
DestinationCache	DestinationManager.getDestinationCache(MessageImpl message) Return the DestinationCache for this message.
boolean	DestinationManager.messageAdded(JmsDestination destination, MessageImpl message)
void	DestinationManager.messageRemoved(JmsDestination destination, MessageImpl message)
boolean	DestinationManager.persistentMessageAdded(java.sql.Connection connection, JmsDestination destination, MessageImpl message)
void	DestinationManager.persistentMessageRemoved(java.sql.Connection connection, JmsDestination destination, MessageImpl message)
boolean	DestinationManager.isMessageForAdministeredDestination(MessageImpl msg) Test whether the specified message is for an administered destination.
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.
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(ConsumerEndpoint consumer, MessageImpl message) Retrieve a message handle for the specified ConsumerEndpoint and message.
static MessageHandle	MessageHandleFactory.createHandle(QueueDestinationCache queue, MessageImpl message) Create a transient handle for a message belonging to a queue.
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.createPersistentHandle(java.sql.Connection connection, QueueDestinationCache queue, MessageImpl message) Create a persistent message handle 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 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
void	MessageLeaseHelper.addLease(MessageImpl message) Add a lease for message to notify listener when message expires.
void	MessageLeaseHelper.removeLease(MessageImpl message) Remove a lease for a message
boolean	MessageManagerEventListener.messageAdded(JmsDestination destination, MessageImpl message) This method is called when the MessageMgr adds a message for this destination to the cache
void	MessageManagerEventListener.messageRemoved(JmsDestination destination, MessageImpl message) This method is called when the MessageMgr removes a message from the cache.
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.
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.
void	MessageMgr.add(MessageImpl message) Add a message to the message manager for the specified destination.
protected void	MessageMgr.addNonPersistentMessage(MessageImpl message) This method is used to process non-persistent messages.
protected void	MessageMgr.addPersistentMessage(MessageImpl message) This method is used to process 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.
void	QueueBrowserEndpoint.onMessage(MessageImpl message)
boolean	QueueConsumerEndpoint.messageAdded(MessageImpl message)
boolean	QueueConsumerEndpoint.persistentMessageAdded(java.sql.Connection connection, MessageImpl message)
boolean	QueueConsumerEndpoint.messageRemoved(MessageImpl message)
boolean	QueueDestinationCache.messageAdded(JmsDestination destination, MessageImpl message)
void	QueueDestinationCache.messageRemoved(JmsDestination destination, MessageImpl message) This method is called when the MessageMgr removes a message from the cache.
boolean	QueueDestinationCache.persistentMessageAdded(java.sql.Connection connection, JmsDestination destination, MessageImpl message)
void	QueueDestinationCache.persistentMessageRemoved(java.sql.Connection connection, JmsDestination destination, MessageImpl message)
void	QueueListener.onMessage(MessageImpl message) This method is called when a new message is added to a queue cache
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	TopicConsumerEndpoint.messageRemoved(MessageImpl message)
boolean	TopicConsumerEndpoint.persistentMessageRemoved(java.sql.Connection connection, MessageImpl message)
boolean	TopicDestinationCache.messageAdded(JmsDestination destination, MessageImpl message)
void	TopicDestinationCache.messageRemoved(JmsDestination destination, MessageImpl message)
boolean	TopicDestinationCache.persistentMessageAdded(java.sql.Connection connection, JmsDestination destination, MessageImpl message)
void	TopicDestinationCache.persistentMessageRemoved(java.sql.Connection connection, JmsDestination destination, MessageImpl 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	BatchingRdbmsAdapter.getMessage(java.sql.Connection connection, java.lang.String id)
MessageImpl	Messages.get(java.sql.Connection connection, java.lang.String messageId) Return the message identified by the message Id
MessageImpl	Messages.deserialize(byte[] blob) Set the message from a serialized blob
MessageImpl	ObjectAdapter.getMessage(java.sql.Connection connection, java.lang.String id)
abstract MessageImpl	PersistenceAdapter.getMessage(java.sql.Connection connection, java.lang.String id) Get a message from the persistence store.
MessageImpl	PersistentMessage.getMessage() return the held message from the persistent object.
MessageImpl	RDBMSAdapter.getMessage(java.sql.Connection connection, java.lang.String id)

Methods in org.exolab.jms.persistence with parameters of type MessageImpl

void	BatchingRdbmsAdapter.addMessage(java.sql.Connection connection, MessageImpl message)
void	BatchingRdbmsAdapter.updateMessage(java.sql.Connection connection, MessageImpl message)
void	Messages.add(java.sql.Connection connection, MessageImpl message) Add a message to the database, in the context of the specified transaction and connection.
void	Messages.update(java.sql.Connection connection, MessageImpl message) Update the message state in the database.
byte[]	Messages.serialize(MessageImpl message) Get the message as a serialized blob
void	ObjectAdapter.addMessage(java.sql.Connection connection, MessageImpl message)
void	ObjectAdapter.updateMessage(java.sql.Connection connection, MessageImpl message)
abstract void	PersistenceAdapter.addMessage(java.sql.Connection connection, MessageImpl message) Add a new message to the database.
abstract void	PersistenceAdapter.updateMessage(java.sql.Connection connection, MessageImpl message) Update this message in the database
void	PersistentMessage.setMessage(MessageImpl message) Set the message held by this persistent object
void	RDBMSAdapter.addMessage(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.