org.apache.activemq.transport.reliable
Class DefaultReplayStrategy

java.lang.Object
  extended by org.apache.activemq.transport.reliable.DefaultReplayStrategy
All Implemented Interfaces:
ReplayStrategy

public class DefaultReplayStrategy
extends Object
implements ReplayStrategy

Throws an exception if packets are dropped causing the transport to be closed.


Constructor Summary
DefaultReplayStrategy()
           
DefaultReplayStrategy(int maximumDifference)
           
 
Method Summary
 int getMaximumDifference()
           
 boolean onDroppedPackets(ReliableTransport transport, int expectedCounter, int actualCounter, int nextAvailableCounter)
          Deals with a dropped packet.
 void onReceivedPacket(ReliableTransport transport, long expectedCounter)
           
 void setMaximumDifference(int maximumDifference)
          Sets the maximum allowed difference between an expected packet and an actual packet before an error occurs
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

DefaultReplayStrategy

public DefaultReplayStrategy()

DefaultReplayStrategy

public DefaultReplayStrategy(int maximumDifference)
Method Detail

onDroppedPackets

public boolean onDroppedPackets(ReliableTransport transport,
                                int expectedCounter,
                                int actualCounter,
                                int nextAvailableCounter)
                         throws IOException
Description copied from interface: ReplayStrategy
Deals with a dropped packet.

Specified by:
onDroppedPackets in interface ReplayStrategy
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:
IOException

onReceivedPacket

public void onReceivedPacket(ReliableTransport transport,
                             long expectedCounter)
Specified by:
onReceivedPacket in interface ReplayStrategy

getMaximumDifference

public int getMaximumDifference()

setMaximumDifference

public void setMaximumDifference(int maximumDifference)
Sets the maximum allowed difference between an expected packet and an actual packet before an error occurs



Copyright © 2005-2013 The Apache Software Foundation. All Rights Reserved.