| Package | Description |
|---|---|
| org.apache.cxf.ws.rm | |
| org.apache.cxf.ws.rm.persistence | |
| org.apache.cxf.ws.rm.persistence.jdbc | |
| org.apache.cxf.ws.rm.soap |
| Modifier and Type | Method and Description |
|---|---|
SourceSequence |
Source.getSequence(Identifier id) |
SourceSequence |
RMManager.getSequence(Identifier inSeqId,
Message message,
AddressingProperties maps) |
SourceSequence |
RMProperties.getSourceSequence() |
| Modifier and Type | Method and Description |
|---|---|
Collection<SourceSequence> |
Source.getAllSequences() |
Collection<SourceSequence> |
Source.getAllUnacknowledgedSequences()
Returns a collection of all sequences for which have not yet been
completely acknowledged.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
RMOutInterceptor.addAckRequest(Message msg,
RMProperties rmpsIn,
SourceSequence seq,
SequenceType sequence)
Add AcknowledgementRequested to message if needed.
|
void |
Source.addSequence(SourceSequence seq) |
void |
Source.addSequence(SourceSequence seq,
boolean persist) |
int |
RetransmissionQueue.countUnacknowledged(SourceSequence seq) |
RetryStatus |
RetransmissionQueue.getRetransmissionStatus(SourceSequence seq,
long num)
Returns the retransmission status for the specified message.
|
Map<Long,RetryStatus> |
RetransmissionQueue.getRetransmissionStatuses(SourceSequence seq)
Return the retransmission status of all the messages assigned to the sequence.
|
List<Long> |
RetransmissionQueue.getUnacknowledgedMessageNumbers(SourceSequence seq) |
void |
RetransmissionQueue.purgeAcknowledged(SourceSequence seq)
Purge all candidates for the given sequence that have been acknowledged.
|
void |
RetransmissionQueue.purgeAll(SourceSequence seq)
Purge all candidates for the given sequence.
|
void |
Source.removeSequence(SourceSequence seq) |
void |
RetransmissionQueue.resume(SourceSequence seq)
Resumes the retransmission attempts for the specified sequence
|
void |
Source.setCurrent(SourceSequence s)
Sets the current sequence used by a client side source.
|
void |
RMProperties.setSequence(SourceSequence seq) |
void |
RetransmissionQueue.stop(SourceSequence seq)
Stops retransmission queue.
|
void |
RetransmissionQueue.suspend(SourceSequence seq)
Suspends the retransmission attempts for the specified sequence
|
| Modifier and Type | Method and Description |
|---|---|
SourceSequence |
RMStore.getSourceSequence(Identifier seq)
Retrieve the source sequence with the specified identifier from persistent store.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<SourceSequence> |
RMStore.getSourceSequences(String endpointIdentifier)
Retrieves all sequences managed by the identified RM source endpoint
from persistent store.
|
| Modifier and Type | Method and Description |
|---|---|
void |
RMStore.createSourceSequence(SourceSequence seq)
Create a source sequence in the persistent store, with the sequence attributes as specified in the
RMSourceSequence object. |
void |
RMStore.persistOutgoing(SourceSequence seq,
RMMessage msg)
Called by an RM source upon processing an outbound message.
|
| Modifier and Type | Method and Description |
|---|---|
SourceSequence |
RMTxStore.getSourceSequence(Identifier sid) |
| Modifier and Type | Method and Description |
|---|---|
Collection<SourceSequence> |
RMTxStore.getSourceSequences(String endpointIdentifier) |
| Modifier and Type | Method and Description |
|---|---|
void |
RMTxStore.createSourceSequence(SourceSequence seq) |
void |
RMTxStore.persistOutgoing(SourceSequence seq,
RMMessage msg) |
protected void |
RMTxStore.updateSourceSequence(Connection con,
SourceSequence seq) |
protected void |
RMTxStore.updateSourceSequence(SourceSequence seq) |
| Modifier and Type | Method and Description |
|---|---|
int |
RetransmissionQueueImpl.countUnacknowledged(SourceSequence seq) |
RetryStatus |
RetransmissionQueueImpl.getRetransmissionStatus(SourceSequence seq,
long num) |
Map<Long,RetryStatus> |
RetransmissionQueueImpl.getRetransmissionStatuses(SourceSequence seq) |
protected List<RetransmissionQueueImpl.ResendCandidate> |
RetransmissionQueueImpl.getSequenceCandidates(SourceSequence seq) |
List<Long> |
RetransmissionQueueImpl.getUnacknowledgedMessageNumbers(SourceSequence seq) |
void |
RetransmissionQueueImpl.purgeAcknowledged(SourceSequence seq)
Purge all candidates for the given sequence that have been acknowledged.
|
void |
RetransmissionQueueImpl.purgeAll(SourceSequence seq)
Purge all candidates for the given sequence.
|
void |
RetransmissionQueueImpl.resume(SourceSequence seq) |
void |
RetransmissionQueueImpl.stop(SourceSequence seq)
Stops resending messages for the specified source sequence.
|
void |
RetransmissionQueueImpl.suspend(SourceSequence seq) |
Apache CXF