Spring AMQP

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 Object

Author:
Dave Syer

Constructor Summary
ActiveObjectCounter()
           
 
Method Summary
 void add(T object)
           
 boolean await(Long timeout, 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(Long timeout,
                     TimeUnit timeUnit)
              throws InterruptedException
Throws:
InterruptedException

getCount

public int getCount()

reset

public void reset()

Spring AMQP

Copyright © 2011. All Rights Reserved.