public class Source extends AbstractEndpoint
completedSequenceCount, processingSequenceCount
Modifier and Type | Method and Description |
---|---|
void |
addSequence(SourceSequence seq) |
void |
addSequence(SourceSequence seq,
boolean persist) |
Collection<SourceSequence> |
getAllSequences() |
Collection<SourceSequence> |
getAllUnacknowledgedSequences()
Returns a collection of all sequences for which have not yet been
completely acknowledged.
|
SourceSequence |
getSequence(Identifier id) |
void |
removeSequence(SourceSequence seq) |
void |
setCurrent(SourceSequence s)
Sets the current sequence used by a client side source.
|
generateSequenceIdentifier, getEndpoint, getManager, getName, getReliableEndpoint
public SourceSequence getSequence(Identifier id)
public Collection<SourceSequence> getAllSequences()
public void addSequence(SourceSequence seq)
public void addSequence(SourceSequence seq, boolean persist)
public void removeSequence(SourceSequence seq)
public Collection<SourceSequence> getAllUnacknowledgedSequences()
public void setCurrent(SourceSequence s)
s
- the current sequence.Apache CXF