org.apache.activemq.transport.reliable

Interface ReplayStrategy

All Known Implementing Classes:

DefaultReplayStrategy, ExceptionIfDroppedReplayStrategy

public interface ReplayStrategy

A pluggable strategy for how to deal with dropped packets.

Method Summary

Methods

Modifier and Type	Method and Description
boolean	onDroppedPackets(ReliableTransport transport, int expectedCounter, int actualCounter, int nextAvailableCounter) Deals with a dropped packet.
void	onReceivedPacket(ReliableTransport transport, long expectedCounter)

Method Detail

onDroppedPackets

boolean onDroppedPackets(ReliableTransport transport,
                       int expectedCounter,
                       int actualCounter,
                       int nextAvailableCounter)
                         throws java.io.IOException

Deals with a dropped packet.

Parameters:

transport - the transport on which the packet was dropped

expectedCounter - the expected command counter

actualCounter - the actual command counter

nextAvailableCounter - TODO

Returns:

true if the command should be buffered or false if it should be discarded

Throws:

java.io.IOException

onReceivedPacket

void onReceivedPacket(ReliableTransport transport,
                    long expectedCounter)