Package org.apache.cxf.ws.rm
Interface RedeliveryQueue
-
- All Known Implementing Classes:
RedeliveryQueueImpl
public interface RedeliveryQueue
-
-
Field Summary
Fields Modifier and Type Field Description static String
DEFAULT_BASE_REDELIVERY_INTERVAL
static int
DEFAULT_EXPONENTIAL_BACKOFF
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
addUndelivered(org.apache.cxf.message.Message message)
Accepts a failed message for possible future redelivery.int
countUndelivered()
int
countUndelivered(DestinationSequence seq)
RetryStatus
getRedeliveryStatus(DestinationSequence seq, long num)
Returns the retransmission status for the specified message.Map<Long,RetryStatus>
getRedeliveryStatuses(DestinationSequence seq)
Return the retransmission status of all the messages assigned to the sequence.List<Long>
getUndeliveredMessageNumbers(DestinationSequence seq)
boolean
isEmpty()
void
purgeAll(DestinationSequence seq)
Purge all candiates for the given sequence.void
resume(DestinationSequence seq)
Resumes the redelivery attempts for the specified sequencevoid
start()
Initiate resends.void
stop(DestinationSequence seq)
Stops redelivery queue.void
suspend(DestinationSequence seq)
Suspends the redelivery attempts for the specified sequence
-
-
-
Field Detail
-
DEFAULT_BASE_REDELIVERY_INTERVAL
static final String DEFAULT_BASE_REDELIVERY_INTERVAL
- See Also:
- Constant Field Values
-
DEFAULT_EXPONENTIAL_BACKOFF
static final int DEFAULT_EXPONENTIAL_BACKOFF
- See Also:
- Constant Field Values
-
-
Method Detail
-
countUndelivered
int countUndelivered(DestinationSequence seq)
- Parameters:
seq
- the sequence under consideration- Returns:
- the number of unacknowledged messages for that sequence
-
countUndelivered
int countUndelivered()
- Returns:
- the total number of undelivered messages in this queue
-
isEmpty
boolean isEmpty()
- Returns:
- true if there are no unacknowledged messages in the queue
-
addUndelivered
void addUndelivered(org.apache.cxf.message.Message message)
Accepts a failed message for possible future redelivery.- Parameters:
message
- the message context.
-
purgeAll
void purgeAll(DestinationSequence seq)
Purge all candiates for the given sequence.- Parameters:
seq
- the sequence object
-
getUndeliveredMessageNumbers
List<Long> getUndeliveredMessageNumbers(DestinationSequence seq)
- Parameters:
seq
-- Returns:
-
getRedeliveryStatus
RetryStatus getRedeliveryStatus(DestinationSequence seq, long num)
Returns the retransmission status for the specified message.- Parameters:
seq
-num
-- Returns:
-
getRedeliveryStatuses
Map<Long,RetryStatus> getRedeliveryStatuses(DestinationSequence seq)
Return the retransmission status of all the messages assigned to the sequence.- Parameters:
seq
-- Returns:
-
start
void start()
Initiate resends.
-
stop
void stop(DestinationSequence seq)
Stops redelivery queue.- Parameters:
seq
-
-
suspend
void suspend(DestinationSequence seq)
Suspends the redelivery attempts for the specified sequence- Parameters:
seq
-
-
resume
void resume(DestinationSequence seq)
Resumes the redelivery attempts for the specified sequence- Parameters:
seq
-
-
-