org.apache.qpid.requestreply
Class PingPongProducer.PerCorrelationId

java.lang.Object
  extended by 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.


Field Summary
(package private)  Long timeOutStart
          Holds the last timestamp that the timeout was reset to.
(package private)  CountDownLatch trafficLight
          Holds a countdown on number of expected messages.
 
Constructor Summary
protected PingPongProducer.PerCorrelationId()
           
 
Method Summary
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

trafficLight

CountDownLatch trafficLight
Holds a countdown on number of expected messages.


timeOutStart

Long timeOutStart
Holds the last timestamp that the timeout was reset to.

Constructor Detail

PingPongProducer.PerCorrelationId

protected PingPongProducer.PerCorrelationId()


Licensed to the Apache Software Foundation