org.springframework.amqp.rabbit.listener

Class ActiveObjectCounter<T>

java.lang.Object

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

public class ActiveObjectCounter<T>
extends Object

Author:

Dave Syer

Constructor Summary

Constructors

Constructor and Description
ActiveObjectCounter()

Method Summary

Methods

Modifier and Type	Method and Description
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()