org.apache.activemq.artemis.utils

Class ReferenceCounterUtil

java.lang.Object

org.apache.activemq.artemis.utils.ReferenceCounterUtil

All Implemented Interfaces:

ReferenceCounter

Direct Known Subclasses:

QueueManagerImpl, TransientQueueManagerImpl

public class ReferenceCounterUtil
extends Object
implements ReferenceCounter

Constructor Summary

Constructors

Constructor and Description
ReferenceCounterUtil()
ReferenceCounterUtil(Executor executor)
ReferenceCounterUtil(Runnable runnable)
ReferenceCounterUtil(Runnable runnable, Executor executor)

Method Summary

Modifier and Type	Method and Description
void	check() Some asynchronous operations (like ack) may delay certain conditions.
int	decrement()
int	getCount()
Runnable	getTask()
int	increment()
void	setTask(Runnable task)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ReferenceCounterUtil

public ReferenceCounterUtil()

ReferenceCounterUtil

public ReferenceCounterUtil(Executor executor)

ReferenceCounterUtil

public ReferenceCounterUtil(Runnable runnable,
                            Executor executor)

ReferenceCounterUtil

public ReferenceCounterUtil(Runnable runnable)

Method Detail

setTask

public void setTask(Runnable task)

Specified by:

setTask in interface ReferenceCounter

getTask

public Runnable getTask()

Specified by:

getTask in interface ReferenceCounter

increment

public int increment()

Specified by:

increment in interface ReferenceCounter

decrement

public int decrement()

Specified by:

decrement in interface ReferenceCounter

check

public void check()

Description copied from interface: ReferenceCounter

Some asynchronous operations (like ack) may delay certain conditions. After met, during afterCompletion we may need to recheck certain values to make sure we won't get into a situation where the condition was met asynchronously and queues not removed.

Specified by:

check in interface ReferenceCounter

getCount

public int getCount()

Specified by:

getCount in interface ReferenceCounter