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 |
---|---|
DestinationSequence |
Destination.getSequence(Identifier id) |
Modifier and Type | Method and Description |
---|---|
Collection<DestinationSequence> |
Destination.getAllSequences() |
Modifier and Type | Method and Description |
---|---|
void |
RMProperties.addAck(DestinationSequence seq) |
void |
Destination.addSequence(DestinationSequence seq) |
void |
Destination.addSequence(DestinationSequence seq,
boolean persist) |
int |
RedeliveryQueue.countUndelivered(DestinationSequence seq) |
RetryStatus |
RedeliveryQueue.getRedeliveryStatus(DestinationSequence seq,
long num)
Returns the retransmission status for the specified message.
|
Map<Long,RetryStatus> |
RedeliveryQueue.getRedeliveryStatuses(DestinationSequence seq)
Return the retransmission status of all the messages assigned to the sequence.
|
List<Long> |
RedeliveryQueue.getUndeliveredMessageNumbers(DestinationSequence seq) |
void |
RedeliveryQueue.purgeAll(DestinationSequence seq)
Purge all candiates for the given sequence.
|
void |
Destination.removeSequence(DestinationSequence seq) |
void |
RedeliveryQueue.resume(DestinationSequence seq)
Resumes the redelivery attempts for the specified sequence
|
void |
RedeliveryQueue.stop(DestinationSequence seq)
Stops redelivery queue.
|
void |
RedeliveryQueue.suspend(DestinationSequence seq)
Suspends the redelivery attempts for the specified sequence
|
void |
Destination.terminateSequence(DestinationSequence seq) |
void |
Destination.terminateSequence(DestinationSequence seq,
boolean forceRemove) |
Modifier and Type | Method and Description |
---|---|
DestinationSequence |
RMStore.getDestinationSequence(Identifier seq)
Retrieve the destination sequence with the specified identifier from persistent store.
|
Modifier and Type | Method and Description |
---|---|
Collection<DestinationSequence> |
RMStore.getDestinationSequences(String endpointIdentifier)
Retrieves all sequences managed by the identified RM destination endpoint
from persistent store.
|
Modifier and Type | Method and Description |
---|---|
void |
RMStore.createDestinationSequence(DestinationSequence seq)
Create a destination sequence in the persistent store, with the sequence attributes as specified in the
RMSDestinationSequence object. |
void |
RMStore.persistIncoming(DestinationSequence seq,
RMMessage msg)
Called by an RM source upon processing an outbound message.
|
Modifier and Type | Method and Description |
---|---|
DestinationSequence |
RMTxStore.getDestinationSequence(Identifier sid) |
Modifier and Type | Method and Description |
---|---|
Collection<DestinationSequence> |
RMTxStore.getDestinationSequences(String endpointIdentifier) |
Modifier and Type | Method and Description |
---|---|
void |
RMTxStore.createDestinationSequence(DestinationSequence seq) |
void |
RMTxStore.persistIncoming(DestinationSequence seq,
RMMessage msg) |
protected void |
RMTxStore.updateDestinationSequence(Connection con,
DestinationSequence seq) |
protected void |
RMTxStore.updateDestinationSequence(DestinationSequence seq) |
Modifier and Type | Method and Description |
---|---|
int |
RedeliveryQueueImpl.countUndelivered(DestinationSequence seq) |
RetryStatus |
RedeliveryQueueImpl.getRedeliveryStatus(DestinationSequence seq,
long num) |
Map<Long,RetryStatus> |
RedeliveryQueueImpl.getRedeliveryStatuses(DestinationSequence seq) |
protected List<RedeliveryQueueImpl.RedeliverCandidate> |
RedeliveryQueueImpl.getSequenceCandidates(DestinationSequence seq) |
List<Long> |
RedeliveryQueueImpl.getUndeliveredMessageNumbers(DestinationSequence seq) |
void |
RedeliveryQueueImpl.purgeAll(DestinationSequence seq) |
void |
RedeliveryQueueImpl.resume(DestinationSequence seq) |
void |
RedeliveryQueueImpl.stop(DestinationSequence seq) |
void |
RedeliveryQueueImpl.suspend(DestinationSequence seq) |
Apache CXF