org.apache.qpid.requestreply
Class PingPongProducer.PerCorrelationId
java.lang.Object
org.apache.qpid.requestreply.PingPongProducer.PerCorrelationId
- Enclosing class:
- PingPongProducer
protected static class PingPongProducer.PerCorrelationId
- extends Object
Holds information on each correlation id. The countdown latch, the current timeout timer... More stuff to be
added to this: read/write lock to make onMessage more concurrent as described in class header comment.
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
trafficLight
CountDownLatch trafficLight
- Holds a countdown on number of expected messages.
timeOutStart
Long timeOutStart
- Holds the last timestamp that the timeout was reset to.
PingPongProducer.PerCorrelationId
protected PingPongProducer.PerCorrelationId()
Licensed to the Apache Software Foundation