public interface RetransmissionQueue
Modifier and Type | Field and Description |
---|---|
static String |
DEFAULT_BASE_RETRANSMISSION_INTERVAL |
static int |
DEFAULT_EXPONENTIAL_BACKOFF |
Modifier and Type | Method and Description |
---|---|
void |
addUnacknowledged(Message message)
Accepts a new context for posible future retransmission.
|
int |
countUnacknowledged(SourceSequence seq) |
boolean |
isEmpty() |
void |
purgeAcknowledged(SourceSequence seq)
Purge all candidates for the given sequence that have been acknowledged.
|
void |
start()
Initiate resends.
|
void |
stop(SourceSequence seq)
Stops retransmission queue.
|
static final String DEFAULT_BASE_RETRANSMISSION_INTERVAL
static final int DEFAULT_EXPONENTIAL_BACKOFF
int countUnacknowledged(SourceSequence seq)
seq
- the sequence under considerationboolean isEmpty()
void addUnacknowledged(Message message)
ctx
- the message context.void purgeAcknowledged(SourceSequence seq)
seq
- the sequence object.void start()
void stop(SourceSequence seq)
Apache CXF