| org.objectweb.celtix.ws.rm.persistence.RMStore
All known Subclasses: org.objectweb.celtix.bus.ws.rm.persistence.file.RMFileStore, org.objectweb.celtix.bus.ws.rm.persistence.jdbc.RMTxStore,
| RMStore | | public interface RMStore (Code) | | |
| createDestinationSequence | | void createDestinationSequence(RMDestinationSequence seq)(Code) | | Create a destination sequence in the persistent store, with the sequence attributes as specified in the
RMSDestinationSequence object.
Parameters:
seq - the sequence |
| createSourceSequence | | void createSourceSequence(RMSourceSequence seq)(Code) | | Create a source sequence in the persistent store, with the sequence attributes as specified in the
RMSourceSequence object.
Parameters:
seq - the sequence |
| getDestinationSequences | | Collection<RMDestinationSequence> getDestinationSequences(String endpointIdentifier)(Code) | | Retrieves all sequences managed by the identified RM destination endpoint
from persistent store.
Parameters:
endpointIdentifier - the identifier for the destination the collection of sequences |
| getMessages | | Collection<RMMessage> getMessages(Identifier sid, boolean outbound)(Code) | | Retrieves the outbound/inbound messages stored for the source/destination sequence with
the given identifier.
Parameters:
sid - the source sequence identifier
Parameters:
outbound - true if the message is outbound the collection of messages |
| getSourceSequences | | Collection<RMSourceSequence> getSourceSequences(String endpointIdentifier)(Code) | | Retrieves all sequences managed by the identified RM source endpoint
from persistent store.
Parameters:
endpointIdentifier - the identifier for the source the collection of sequences |
| init | | void init(Map<String, String> params)(Code) | | Initialises the store.
Parameters:
params - the store initialisation parameters |
| persistIncoming | | void persistIncoming(RMDestinationSequence seq, RMMessage msg)(Code) | | Called by an RM source upon processing an outbound message. The RMMessage
parameter is null for non application (RM protocol) messages.
Parameters:
seq - the destination sequence
Parameters:
msg - the incoming message |
| persistOutgoing | | void persistOutgoing(RMSourceSequence seq, RMMessage msg)(Code) | | Called by an RM source upon processing an outbound message. The RMMessage
parameter is null for non application (RM protocol) messages.
Parameters:
seq - the source sequence
Parameters:
msg - the outgoing message |
| removeDestinationSequence | | void removeDestinationSequence(Identifier seq)(Code) | | Remove the destination sequence with the specified identifier from persistent store.
Parameters:
seq - the sequence |
| removeMessages | | void removeMessages(Identifier sid, Collection<BigInteger> messageNrs, boolean outbound)(Code) | | Removes the messages with the given message numbers and identifiers from the store of
outbound/inbound messages.
Parameters:
sid - the identifier of the source sequence
Parameters:
messageNr - the collection of message numbers
Parameters:
outbound - true if the message is outbound |
| removeSourceSequence | | void removeSourceSequence(Identifier seq)(Code) | | Remove the source sequence with the specified identifier from persistent store.
Parameters:
seq - the sequence |
|
|