org.objectweb.joram.mom.util
Class MessagePersistenceModule

java.lang.Object
  org.objectweb.joram.mom.util.MessagePersistenceModule

All Implemented Interfaces:

java.io.Serializable

public class MessagePersistenceModule

extends java.lang.Object

implements java.io.Serializable

The MessagePersistenceModule class is a utility class used by queues and proxies for persisting, retrieving and deleting messages.

Messages are either persisted individually, or grouped into vectors.

See Also:

Serialized Form

Constructor Summary

MessagePersistenceModule(AgentId agentId)
Constructs a MessagePersistenceModule instance.

Method Summary

void	commit() Commits the registered savings and deletions.
void	delete(Message message) Registers a message for future deletion.
void	deleteAll() Deletes all persisted objects.
java.util.Vector	loadAll() Loads all persisted objects.
void	rollback() Rolls back all the registered saving and deletion requests.
void	save(Message message) Registers a message for future saving.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MessagePersistenceModule

public MessagePersistenceModule(AgentId agentId)

Constructs a MessagePersistenceModule instance.

Parameters:

agentId - Identifier of the agent building the module.

Method Detail

save

public void save(Message message)

Registers a message for future saving.

Parameters:

message - Message to persist.

delete

public void delete(Message message)

Registers a message for future deletion.

Parameters:

message - Message to delete.

commit

public void commit()

Commits the registered savings and deletions.

rollback

public void rollback()

Rolls back all the registered saving and deletion requests.

loadAll

public java.util.Vector loadAll()

Loads all persisted objects.

deleteAll

public void deleteAll()

Deletes all persisted objects.