Joram ${version}

org.objectweb.joram.mom.util
Class MessagePersistenceModule

java.lang.Object
  extended byorg.objectweb.joram.mom.util.MessagePersistenceModule

public class MessagePersistenceModule
extends java.lang.Object

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


Constructor Summary
MessagePersistenceModule()
           
 
Method Summary
static void delete(MessagePersistent message)
          delete the message.
static void deleteAll(java.lang.String agentId)
          Deletes all persisted objects.
static java.lang.String getSaveName(java.lang.String agentId, MessagePersistent message)
           
static java.util.Vector loadAll(java.lang.String agentId)
          Loads all persisted messages.
static MessageBody loadBody(java.lang.String name)
          Load persisted message body.
static Message loadHeader(java.lang.String name)
          Load persisted message header.
static java.lang.String save(java.lang.String agentId, MessagePersistent message)
          save the message (header and body).
static java.lang.String saveBody(java.lang.String agentId, MessagePersistent message)
          save the message body.
static java.lang.String saveHeader(java.lang.String agentId, MessagePersistent message)
          save the message header.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

MessagePersistenceModule

public MessagePersistenceModule()
Method Detail

getSaveName

public static java.lang.String getSaveName(java.lang.String agentId,
                                           MessagePersistent message)

save

public static java.lang.String save(java.lang.String agentId,
                                    MessagePersistent message)
save the message (header and body).

Parameters:
agentId - id of agent.
message - Message to save.

saveHeader

public static java.lang.String saveHeader(java.lang.String agentId,
                                          MessagePersistent message)
save the message header.

Parameters:
agentId - id of agent.
message - Message to save header.

saveBody

public static java.lang.String saveBody(java.lang.String agentId,
                                        MessagePersistent message)
save the message body.

Parameters:
agentId - id of agent.
message - Message to save body.

loadHeader

public static Message loadHeader(java.lang.String name)
                          throws java.lang.ClassNotFoundException
Load persisted message header.

Throws:
java.lang.ClassNotFoundException

loadBody

public static MessageBody loadBody(java.lang.String name)
                            throws java.lang.ClassNotFoundException
Load persisted message body.

Throws:
java.lang.ClassNotFoundException

delete

public static void delete(MessagePersistent message)
delete the message.

Parameters:
message - Message to delete.

loadAll

public static java.util.Vector loadAll(java.lang.String agentId)
Loads all persisted messages.


deleteAll

public static void deleteAll(java.lang.String agentId)
Deletes all persisted objects.


Joram ${version}

Copyright © 2005 Scalagent - All rights reserved