org.springframework.amqp.rabbit.listener
Class ActiveObjectCounter<T>

java.lang.Object
  extended by org.springframework.amqp.rabbit.listener.ActiveObjectCounter<T>

public class ActiveObjectCounter<T>
extends java.lang.Object


Constructor Summary
ActiveObjectCounter()
           
 
Method Summary
 void add(T object)
           
 boolean await(java.lang.Long timeout, java.util.concurrent.TimeUnit timeUnit)
           
 int getCount()
           
 void release(T object)
           
 void reset()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ActiveObjectCounter

public ActiveObjectCounter()
Method Detail

add

public void add(T object)

release

public void release(T object)

await

public boolean await(java.lang.Long timeout,
                     java.util.concurrent.TimeUnit timeUnit)
              throws java.lang.InterruptedException
Throws:
java.lang.InterruptedException

getCount

public int getCount()

reset

public void reset()