Package org.apache.cxf.ws.rm.persistence
Interface RMStore
-
- All Known Implementing Classes:
RMTxStore
public interface RMStore
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
createDestinationSequence(DestinationSequence seq)
Create a destination sequence in the persistent store, with the sequence attributes as specified in theRMSDestinationSequence
object.void
createSourceSequence(SourceSequence seq)
Create a source sequence in the persistent store, with the sequence attributes as specified in theRMSourceSequence
object.DestinationSequence
getDestinationSequence(Identifier seq)
Retrieve the destination sequence with the specified identifier from persistent store.Collection<DestinationSequence>
getDestinationSequences(String endpointIdentifier)
Retrieves all sequences managed by the identified RM destination endpoint from persistent store.Collection<RMMessage>
getMessages(Identifier sid, boolean outbound)
Retrieves the outbound/inbound messages stored for the source/destination sequence with the given identifier.SourceSequence
getSourceSequence(Identifier seq)
Retrieve the source sequence with the specified identifier from persistent store.Collection<SourceSequence>
getSourceSequences(String endpointIdentifier)
Retrieves all sequences managed by the identified RM source endpoint from persistent store.void
persistIncoming(DestinationSequence seq, RMMessage msg)
Called by an RM source upon processing an outbound message.void
persistOutgoing(SourceSequence seq, RMMessage msg)
Called by an RM source upon processing an outbound message.void
removeDestinationSequence(Identifier seq)
Remove the destination sequence with the specified identifier from persistent store.void
removeMessages(Identifier sid, Collection<Long> messageNrs, boolean outbound)
Removes the messages with the given message numbers and identifiers from the store of outbound/inbound messages.void
removeSourceSequence(Identifier seq)
Remove the source sequence with the specified identifier from persistent store.
-
-
-
Method Detail
-
createSourceSequence
void createSourceSequence(SourceSequence seq)
Create a source sequence in the persistent store, with the sequence attributes as specified in theRMSourceSequence
object.- Parameters:
seq
- the sequence
-
createDestinationSequence
void createDestinationSequence(DestinationSequence seq)
Create a destination sequence in the persistent store, with the sequence attributes as specified in theRMSDestinationSequence
object.- Parameters:
seq
- the sequence
-
getSourceSequence
SourceSequence getSourceSequence(Identifier seq)
Retrieve the source sequence with the specified identifier from persistent store.- Parameters:
seq
- the sequence- Returns:
- the sequence if present; otherwise null
-
getDestinationSequence
DestinationSequence getDestinationSequence(Identifier seq)
Retrieve the destination sequence with the specified identifier from persistent store.- Parameters:
seq
- the sequence- Returns:
- the sequence if present; otherwise null
-
removeSourceSequence
void removeSourceSequence(Identifier seq)
Remove the source sequence with the specified identifier from persistent store.- Parameters:
seq
- the sequence
-
removeDestinationSequence
void removeDestinationSequence(Identifier seq)
Remove the destination sequence with the specified identifier from persistent store.- Parameters:
seq
- the sequence
-
getSourceSequences
Collection<SourceSequence> getSourceSequences(String endpointIdentifier)
Retrieves all sequences managed by the identified RM source endpoint from persistent store.- Parameters:
endpointIdentifier
- the identifier for the source- Returns:
- the collection of sequences
-
getDestinationSequences
Collection<DestinationSequence> getDestinationSequences(String endpointIdentifier)
Retrieves all sequences managed by the identified RM destination endpoint from persistent store.- Parameters:
endpointIdentifier
- the identifier for the destination- Returns:
- the collection of sequences
-
getMessages
Collection<RMMessage> getMessages(Identifier sid, boolean outbound)
Retrieves the outbound/inbound messages stored for the source/destination sequence with the given identifier.- Parameters:
sid
- the source sequence identifieroutbound
- true if the message is outbound- Returns:
- the collection of messages *
-
persistOutgoing
void persistOutgoing(SourceSequence seq, RMMessage msg)
Called by an RM source upon processing an outbound message. TheRMMessage
parameter is null for non application (RM protocol) messages.- Parameters:
seq
- the source sequencemsg
- the outgoing message
-
persistIncoming
void persistIncoming(DestinationSequence seq, RMMessage msg)
Called by an RM source upon processing an outbound message. TheRMMessage
parameter is null for non application (RM protocol) messages.- Parameters:
seq
- the destination sequencemsg
- the incoming message
-
removeMessages
void removeMessages(Identifier sid, Collection<Long> messageNrs, boolean outbound)
Removes the messages with the given message numbers and identifiers from the store of outbound/inbound messages.- Parameters:
sid
- the identifier of the source sequencemessageNrs
- the collection of message numbersoutbound
- true if the message is outbound
-
-