Package org.apache.activemq.artemis.core.server.impl

Class QueueManagerImpl

java.lang.Object

org.apache.activemq.artemis.utils.ReferenceCounterUtil

org.apache.activemq.artemis.core.server.impl.QueueManagerImpl

All Implemented Interfaces:

AutoCloseable, QueueManager, ReferenceCounter

public class QueueManagerImpl
extends ReferenceCounterUtil
implements QueueManager

Constructor Summary

Constructors

Constructor	Description
QueueManagerImpl(ActiveMQServer server, SimpleString queueName)

Method Summary

Modifier and Type	Method	Description
static boolean	consumerCountCheck(Queue queue)
static boolean	delayCheck(Queue queue, AddressSettings settings)
SimpleString	getQueueName()
static boolean	messageCountCheck(Queue queue)
static void	performAutoDeleteQueue(ActiveMQServer server, Queue queue)

Methods inherited from class org.apache.activemq.artemis.utils.ReferenceCounterUtil

check, close, decrement, exhaust, getCount, getTask, increment, setTask

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.activemq.artemis.utils.ReferenceCounter

check, decrement, getCount, getTask, increment, setTask

Constructor Details

QueueManagerImpl

public QueueManagerImpl(ActiveMQServer server,
 SimpleString queueName)

Method Details

performAutoDeleteQueue

public static void performAutoDeleteQueue(ActiveMQServer server,
 Queue queue)

messageCountCheck

public static boolean messageCountCheck(Queue queue)

delayCheck

public static boolean delayCheck(Queue queue,
 AddressSettings settings)

consumerCountCheck

public static boolean consumerCountCheck(Queue queue)

getQueueName

public SimpleString getQueueName()

Specified by:

getQueueName in interface QueueManager