org.apache.activemq.transport.reliable
Class ExceptionIfDroppedReplayStrategy
java.lang.Object
org.apache.activemq.transport.reliable.ExceptionIfDroppedReplayStrategy
- All Implemented Interfaces:
- ReplayStrategy
public class ExceptionIfDroppedReplayStrategy
- extends Object
- implements ReplayStrategy
Throws an exception if packets are dropped causing the transport to be
closed.
- Version:
- $Revision: 426366 $
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ExceptionIfDroppedReplayStrategy
public ExceptionIfDroppedReplayStrategy()
ExceptionIfDroppedReplayStrategy
public ExceptionIfDroppedReplayStrategy(int maximumDifference)
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 droppedexpectedCounter
- the expected command counteractualCounter
- the actual command counternextAvailableCounter
- 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 © 2011 Apache Software Foundation. All Rights Reserved.