org.objectweb.joram.mom.util
Class MessagePersistenceModule
java.lang.Object
org.objectweb.joram.mom.util.MessagePersistenceModule
- 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.
- Serialized Form
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.
|
MessagePersistenceModule
public MessagePersistenceModule(AgentId agentId)
Constructs a MessagePersistenceModule
instance.
agentId
- Identifier of the agent building the module.
commit
public void commit()
Commits the registered savings and deletions.
delete
public void delete(Message message)
Registers a message for future deletion.
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.
message
- Message to persist.
Copyright B) 2004 Scalagent - All rights reserved