| java.lang.Object
 org.apache.cxf.ws.rm.AbstractSequence
org.apache.cxf.ws.rm.DestinationSequence
| Inner Class :final class DeferredAcknowledgment extends TimerTask | |
| Inner Class :final class SequenceTermination extends TimerTask | |
| DestinationSequence | | public DestinationSequence(Identifier i, EndpointReferenceType a, Destination d)(Code) | | |
| DestinationSequence | | public DestinationSequence(Identifier i, EndpointReferenceType a, BigInteger lmn, SequenceAcknowledgement ac)(Code) | | |
| acknowledgmentSent | | void acknowledgmentSent()(Code) | | Called after an acknowledgement header for this sequence has been added to an outgoing message.
|
| allPredecessorsAcknowledged | | synchronized boolean allPredecessorsAcknowledged(BigInteger mn)(Code) | | |
| applyDeliveryAssurance | | void applyDeliveryAssurance(BigInteger mn) throws RMException(Code) | | Ensures that the delivery assurance is honored, e.g. by throwing an
exception if the message had already been delivered and the delivery
assurance is AtMostOnce.
This method blocks in case the delivery assurance is
InOrder and and not all messages with lower message numbers have been
delivered.
Parameters:
s - the SequenceType object including identifier and message number
throws:
Fault - if message had already been acknowledged |
| canPiggybackAckOnPartialResponse | | boolean canPiggybackAckOnPartialResponse()(Code) | | |
| cancelDeferredAcknowledgments | | synchronized void cancelDeferredAcknowledgments()(Code) | | |
| cancelTermination | | synchronized void cancelTermination()(Code) | | |
| getAcknowledgment | | public SequenceAcknowledgement getAcknowledgment()(Code) | | the sequence acknowledgement presenting the sequences thus far received by a destination |
| getAcksTo | | public EndpointReferenceType getAcksTo()(Code) | | the acksTo address for the sequence |
| getEndpointIdentifier | | public String getEndpointIdentifier()(Code) | | the identifier of the rm destination |
| getLastMessageNumber | | public BigInteger getLastMessageNumber()(Code) | | the message number of the last message or null if the last message had not been received. |
| getMonitor | | SequenceMonitor getMonitor()(Code) | | Returns the monitor for this sequence.
the sequence monitor. |
| mergeRanges | | void mergeRanges()(Code) | | |
| scheduleAcknowledgement | | void scheduleAcknowledgement(long acknowledgementInterval)(Code) | | |
| scheduleDeferredAcknowledgement | | synchronized void scheduleDeferredAcknowledgement(long delay)(Code) | | |
| scheduleImmediateAcknowledgement | | void scheduleImmediateAcknowledgement()(Code) | | |
| scheduleSequenceTermination | | synchronized void scheduleSequenceTermination(long inactivityTimeout)(Code) | | |
| sendAcknowledgement | | public boolean sendAcknowledgement()(Code) | | |
| setCorrelationID | | void setCorrelationID(String cid)(Code) | | The correlation of the incoming CreateSequence call used to create this
sequence is recorded so that in the absence of an offer, the corresponding
outgoing CreateSeqeunce can be correlated.
|
| Fields inherited from org.apache.cxf.ws.rm.AbstractSequence | protected SequenceAcknowledgement acknowledgement(Code)(Java Doc)
final protected Identifier id(Code)(Java Doc)
|
|
|