org.springframework.amqp.rabbit.listener

Class ActiveObjectCounter<T>

java.lang.Object

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

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

Field Summary

Fields

Modifier and Type	Field and Description
private java.util.concurrent.ConcurrentMap<T,java.util.concurrent.CountDownLatch>	locks

Constructor Summary

Constructors

Constructor and Description
ActiveObjectCounter()

Method Summary

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

Field Detail

locks

private final java.util.concurrent.ConcurrentMap<T,java.util.concurrent.CountDownLatch> locks

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()