org.objectweb.joram.mom.util

Class MessagePersistenceModule

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.
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.

Constructor Details

MessagePersistenceModule

public MessagePersistenceModule(AgentId agentId)
Constructs a MessagePersistenceModule instance.

Parameters:
agentId - Identifier of the agent building the module.

Method Details

commit

public void commit()
Commits the registered savings and deletions.


delete

public void delete(Message message)
Registers a message for future deletion.

Parameters:
message - Message to delete.


deleteAll

public void deleteAll()
Deletes all persisted objects.


loadAll

public Vector loadAll()
Loads all persisted objects.


rollback

public void rollback()
Rolls back all the registered saving and deletion requests.


save

public void save(Message message)
Registers a message for future saving.

Parameters:
message - Message to persist.


Copyright B) 2004 Scalagent - All rights reserved