Uses of Interface
org.apache.activemq.artemis.core.server.Queue

Packages that use Queue

Package	Description
org.apache.activemq.artemis.core.management.impl
org.apache.activemq.artemis.core.messagecounter
org.apache.activemq.artemis.core.paging.cursor
org.apache.activemq.artemis.core.paging.cursor.impl
org.apache.activemq.artemis.core.postoffice
org.apache.activemq.artemis.core.postoffice.impl
org.apache.activemq.artemis.core.server
org.apache.activemq.artemis.core.server.cluster
org.apache.activemq.artemis.core.server.cluster.impl
org.apache.activemq.artemis.core.server.impl
org.apache.activemq.artemis.core.server.management
org.apache.activemq.artemis.core.server.management.impl
org.apache.activemq.artemis.core.server.plugin
org.apache.activemq.artemis.core.server.plugin.impl
org.apache.activemq.artemis.core.server.transformer
org.apache.activemq.artemis.core.transaction
org.apache.activemq.artemis.core.transaction.impl

Uses of Queue in org.apache.activemq.artemis.core.management.impl

Constructors in org.apache.activemq.artemis.core.management.impl with parameters of type Queue

Modifier	Constructor	Description
	QueueControlImpl(Queue queue, String address, ActiveMQServer server, StorageManager storageManager, SecurityStore securityStore, HierarchicalRepository<AddressSettings> addressSettingsRepository)

Uses of Queue in org.apache.activemq.artemis.core.messagecounter

Constructors in org.apache.activemq.artemis.core.messagecounter with parameters of type Queue

Modifier	Constructor	Description
	MessageCounter(String name, String subscription, Queue serverQueue, boolean topic, boolean durable, int daycountmax)	Constructor

Uses of Queue in org.apache.activemq.artemis.core.paging.cursor

Methods in org.apache.activemq.artemis.core.paging.cursor that return Queue

Modifier and Type	Method	Description
Queue	PagedReferenceImpl.getQueue()
Queue	PageSubscription.getQueue()

Methods in org.apache.activemq.artemis.core.paging.cursor with parameters of type Queue

Modifier and Type	Method	Description
MessageReference	PagedReferenceImpl.copy(Queue queue)
void	PageSubscription.setQueue(Queue queue)

Uses of Queue in org.apache.activemq.artemis.core.paging.cursor.impl

Methods in org.apache.activemq.artemis.core.paging.cursor.impl that return Queue

Modifier and Type	Method	Description
Queue	PageSubscriptionImpl.getQueue()

Methods in org.apache.activemq.artemis.core.paging.cursor.impl with parameters of type Queue

Modifier and Type	Method	Description
void	PageSubscriptionImpl.setQueue(Queue queue)

Uses of Queue in org.apache.activemq.artemis.core.postoffice

Methods in org.apache.activemq.artemis.core.postoffice that return Queue

Modifier and Type	Method	Description
default Queue	PostOffice.findQueue(long bindingID)
Queue	QueueBinding.getQueue()

Methods in org.apache.activemq.artemis.core.postoffice that return types with arguments of type Queue

Modifier and Type	Method	Description
List<Queue>	PostOffice.listQueuesForAddress(SimpleString address)

Methods in org.apache.activemq.artemis.core.postoffice with parameters of type Queue

Modifier and Type	Method	Description
Message	Bindings.redistribute(Message message, Queue originatingQueue, RoutingContext context)
Pair<RoutingContext,Message>	PostOffice.redistribute(Message message, Queue originatingQueue)
MessageReference	PostOffice.reload(Message message, Queue queue, Transaction tx)
default MessageReference	PostOffice.reroute(Message message, Queue queue, Transaction tx)	Deprecated.

Uses of Queue in org.apache.activemq.artemis.core.postoffice.impl

Methods in org.apache.activemq.artemis.core.postoffice.impl that return Queue

Modifier and Type	Method	Description
Queue	LocalQueueBinding.getQueue()

Methods in org.apache.activemq.artemis.core.postoffice.impl that return types with arguments of type Queue

Modifier and Type	Method	Description
List<Queue>	PostOfficeImpl.listQueuesForAddress(SimpleString address)

Methods in org.apache.activemq.artemis.core.postoffice.impl with parameters of type Queue

Modifier and Type	Method	Description
Message	BindingsImpl.redistribute(Message message, Queue originatingQueue, RoutingContext context)
Pair<RoutingContext,Message>	PostOfficeImpl.redistribute(Message message, Queue originatingQueue)	The redistribution can't process the route right away as we may be dealing with a large message which will need to be processed on a different thread
MessageReference	PostOfficeImpl.reload(Message message, Queue queue, Transaction tx)
static void	PostOfficeImpl.storeDurableReference(StorageManager storageManager, Message message, Transaction tx, Queue queue, boolean sync)

Constructors in org.apache.activemq.artemis.core.postoffice.impl with parameters of type Queue

Modifier	Constructor	Description
	LocalQueueBinding(SimpleString address, Queue queue, SimpleString nodeID)

Uses of Queue in org.apache.activemq.artemis.core.server

Methods in org.apache.activemq.artemis.core.server that return Queue

Modifier and Type	Method	Description
Queue	ActiveMQServer.createQueue(QueueConfiguration queueConfiguration)	Overloaded version of ActiveMQServer.createQueue(QueueConfiguration, boolean) where the boolean parameter is always false (i.e. if the queue already exists then an exception will be thrown).
Queue	ActiveMQServer.createQueue(QueueConfiguration queueConfiguration, boolean ignoreIfExists)	This method creates a queue based on the QueueConfiguration input.
Queue	ActiveMQServer.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable, boolean temporary)	Deprecated.
Queue	ActiveMQServer.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable, boolean temporary, int maxConsumers, boolean purgeOnNoConsumers, boolean autoCreateAddress)	Deprecated.
Queue	ActiveMQServer.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable, boolean temporary, int maxConsumers, boolean purgeOnNoConsumers, boolean exclusive, boolean groupRebalance, int groupBuckets, boolean lastValue, SimpleString lastValueKey, boolean nonDestructive, int consumersBeforeDispatch, long delayBeforeDispatch, boolean autoDelete, long autoDeleteDelay, long autoDeleteMessageCount, boolean autoCreateAddress)	Deprecated.
Queue	ActiveMQServer.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable, boolean temporary, int maxConsumers, boolean purgeOnNoConsumers, boolean exclusive, boolean groupRebalance, int groupBuckets, SimpleString groupFirstKey, boolean lastValue, SimpleString lastValueKey, boolean nonDestructive, int consumersBeforeDispatch, long delayBeforeDispatch, boolean autoDelete, long autoDeleteDelay, long autoDeleteMessageCount, boolean autoCreateAddress)	Deprecated.
Queue	ActiveMQServer.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable, boolean temporary, int maxConsumers, boolean purgeOnNoConsumers, boolean exclusive, boolean groupRebalance, int groupBuckets, SimpleString groupFirstKey, boolean lastValue, SimpleString lastValueKey, boolean nonDestructive, int consumersBeforeDispatch, long delayBeforeDispatch, boolean autoDelete, long autoDeleteDelay, long autoDeleteMessageCount, boolean autoCreateAddress, long ringSize)	Deprecated.
Queue	ActiveMQServer.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString user, SimpleString filterString, boolean durable, boolean temporary)	Deprecated.
Queue	ActiveMQServer.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, SimpleString user, boolean durable, boolean temporary, boolean ignoreIfExists, boolean transientQueue, boolean autoCreated, int maxConsumers, boolean purgeOnNoConsumers, boolean autoCreateAddress)	Deprecated.
Queue	ActiveMQServer.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, SimpleString user, boolean durable, boolean temporary, boolean ignoreIfExists, boolean transientQueue, boolean autoCreated, int maxConsumers, boolean purgeOnNoConsumers, boolean exclusive, boolean lastValue, boolean autoCreateAddress)	Deprecated.
Queue	ActiveMQServer.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, SimpleString user, boolean durable, boolean temporary, boolean ignoreIfExists, boolean transientQueue, boolean autoCreated, int maxConsumers, boolean purgeOnNoConsumers, boolean exclusive, boolean groupRebalance, int groupBuckets, boolean lastValue, SimpleString lastValueKey, boolean nonDestructive, int consumersBeforeDispatch, long delayBeforeDispatch, boolean autoDelete, long autoDeleteDelay, long autoDeleteMessageCount, boolean autoCreateAddress)	Deprecated.
Queue	ActiveMQServer.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, SimpleString user, boolean durable, boolean temporary, boolean ignoreIfExists, boolean transientQueue, boolean autoCreated, int maxConsumers, boolean purgeOnNoConsumers, boolean exclusive, boolean groupRebalance, int groupBuckets, SimpleString groupFirstKey, boolean lastValue, SimpleString lastValueKey, boolean nonDestructive, int consumersBeforeDispatch, long delayBeforeDispatch, boolean autoDelete, long autoDeleteDelay, long autoDeleteMessageCount, boolean autoCreateAddress)	Deprecated.
Queue	ActiveMQServer.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, SimpleString user, boolean durable, boolean temporary, boolean ignoreIfExists, boolean transientQueue, boolean autoCreated, int maxConsumers, boolean purgeOnNoConsumers, boolean exclusive, boolean groupRebalance, int groupBuckets, SimpleString groupFirstKey, boolean lastValue, SimpleString lastValueKey, boolean nonDestructive, int consumersBeforeDispatch, long delayBeforeDispatch, boolean autoDelete, long autoDeleteDelay, long autoDeleteMessageCount, boolean autoCreateAddress, long ringSize)	Deprecated.
Queue	ActiveMQServer.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, SimpleString user, boolean durable, boolean temporary, boolean autoCreated, Integer maxConsumers, Boolean purgeOnNoConsumers, boolean autoCreateAddress)	Deprecated.
Queue	ActiveMQServer.createQueue(SimpleString address, SimpleString queueName, SimpleString filter, boolean durable, boolean temporary)	Deprecated.
Queue	ActiveMQServer.createQueue(AddressInfo addressInfo, SimpleString queueName, SimpleString filter, SimpleString user, boolean durable, boolean temporary, boolean autoCreated, Integer maxConsumers, Boolean purgeOnNoConsumers, boolean autoCreateAddress)	Deprecated.
Queue	ActiveMQServer.createQueue(AddressInfo addressInfo, SimpleString queueName, SimpleString filter, SimpleString user, boolean durable, boolean temporary, boolean autoCreated, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean lastValue, boolean autoCreateAddress)	Deprecated.
Queue	ActiveMQServer.createQueue(AddressInfo addressInfo, SimpleString queueName, SimpleString filter, SimpleString user, boolean durable, boolean temporary, boolean autoCreated, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, Boolean lastValue, SimpleString lastValueKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, Boolean autoDelete, Long autoDeleteDelay, Long autoDeleteMessageCount, boolean autoCreateAddress)	Deprecated.
Queue	ActiveMQServer.createQueue(AddressInfo addressInfo, SimpleString queueName, SimpleString filter, SimpleString user, boolean durable, boolean temporary, boolean autoCreated, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, SimpleString groupFirstKey, Boolean lastValue, SimpleString lastValueKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, Boolean autoDelete, Long autoDeleteDelay, Long autoDeleteMessageCount, boolean autoCreateAddress)	Deprecated.
Queue	ActiveMQServer.createQueue(AddressInfo addressInfo, SimpleString queueName, SimpleString filter, SimpleString user, boolean durable, boolean temporary, boolean autoCreated, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, SimpleString groupFirstKey, Boolean lastValue, SimpleString lastValueKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, Boolean autoDelete, Long autoDeleteDelay, Long autoDeleteMessageCount, boolean autoCreateAddress, Long ringSize)	Deprecated.
Queue	ServerSession.createQueue(QueueConfiguration queueConfiguration)	This method invokes ActiveMQServer.createQueue(QueueConfiguration) with a few client-specific additions: set the routing type based on the prefixes configured on the acceptor used by the client strip any prefixes from the address and queue names (if applicable) check authorization based on the client's credentials enforce queue creation resource limit set up callbacks to clean up temporary queues once the client disconnects
Queue	ServerSession.createQueue(SimpleString address, SimpleString name, RoutingType routingType, SimpleString filterString, boolean temporary, boolean durable)	Deprecated.
Queue	ServerSession.createQueue(SimpleString address, SimpleString name, RoutingType routingType, SimpleString filterString, boolean temporary, boolean durable, boolean autoCreated)	Deprecated.
Queue	ServerSession.createQueue(SimpleString address, SimpleString name, RoutingType routingType, SimpleString filterString, boolean temporary, boolean durable, int maxConsumers, boolean purgeOnNoConsumers, boolean autoCreated)	Deprecated.
Queue	ServerSession.createQueue(SimpleString address, SimpleString name, RoutingType routingType, SimpleString filterString, boolean temporary, boolean durable, int maxConsumers, boolean purgeOnNoConsumers, Boolean exclusive, Boolean lastValue, boolean autoCreated)	Deprecated.
Queue	ServerSession.createQueue(SimpleString address, SimpleString name, RoutingType routingType, SimpleString filterString, boolean temporary, boolean durable, int maxConsumers, boolean purgeOnNoConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, Boolean lastValue, SimpleString lastValueKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, Boolean autoDelete, Long autoDeleteDelay, Long autoDeleteMessageCount, boolean autoCreated)	Deprecated.
Queue	ServerSession.createQueue(SimpleString address, SimpleString name, RoutingType routingType, SimpleString filterString, boolean temporary, boolean durable, int maxConsumers, boolean purgeOnNoConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, SimpleString groupFirstKey, Boolean lastValue, SimpleString lastValueKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, Boolean autoDelete, Long autoDeleteDelay, Long autoDeleteMessageCount, boolean autoCreated)	Deprecated.
Queue	ServerSession.createQueue(SimpleString address, SimpleString name, RoutingType routingType, SimpleString filterString, boolean temporary, boolean durable, int maxConsumers, boolean purgeOnNoConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, SimpleString groupFirstKey, Boolean lastValue, SimpleString lastValueKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, Boolean autoDelete, Long autoDeleteDelay, Long autoDeleteMessageCount, boolean autoCreated, Long ringSize)	Deprecated.
Queue	ServerSession.createQueue(SimpleString address, SimpleString name, SimpleString filterString, boolean temporary, boolean durable)	Deprecated.
Queue	ServerSession.createQueue(AddressInfo address, SimpleString name, SimpleString filterString, boolean temporary, boolean durable)	Deprecated.
Queue	ServerSession.createQueue(AddressInfo addressInfo, SimpleString name, SimpleString filterString, boolean temporary, boolean durable, boolean autoCreated)	Deprecated.
Queue	ServerSession.createQueue(AddressInfo addressInfo, SimpleString name, SimpleString filterString, boolean temporary, boolean durable, Boolean exclusive, Boolean lastValue, boolean autoCreated)	Deprecated.
Queue	QueueFactory.createQueueWith(QueueConfiguration config, PagingManager pagingManager, Filter filter)
Queue	ActiveMQServer.deployQueue(String address, String queue, String filter, boolean durable, boolean temporary)	Deprecated.
Queue	ActiveMQServer.deployQueue(SimpleString address, SimpleString queue, SimpleString filter, boolean durable, boolean temporary)	Deprecated.
Queue	MessageReference.getQueue()
Queue	ServerConsumer.getQueue()
default Queue	ActiveMQServer.locateQueue(String queueName)
default Queue	ActiveMQServer.locateQueue(String address, String queue)
Queue	ActiveMQServer.locateQueue(SimpleString queueName)
Queue	ActiveMQServer.updateQueue(String name, RoutingType routingType, Integer maxConsumers, Boolean purgeOnNoConsumers)	Deprecated.
Queue	ActiveMQServer.updateQueue(String name, RoutingType routingType, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive)	Deprecated.
Queue	ActiveMQServer.updateQueue(String name, RoutingType routingType, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, String user)	Deprecated.
Queue	ActiveMQServer.updateQueue(String name, RoutingType routingType, String filterString, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, String user)	Deprecated.
Queue	ActiveMQServer.updateQueue(String name, RoutingType routingType, String filterString, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, String groupFirstQueue, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, String user)	Deprecated.
Queue	ActiveMQServer.updateQueue(String name, RoutingType routingType, String filterString, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, String groupFirstQueue, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, String user, Long ringSize)	Deprecated.
Queue	ActiveMQServer.updateQueue(QueueConfiguration queueConfiguration)	Update the queue named in the QueueConfiguration with the corresponding properties.
Queue	ActiveMQServer.updateQueue(QueueConfiguration queueConfiguration, boolean forceUpdate)	Update a queue's configuration.

Methods in org.apache.activemq.artemis.core.server that return types with arguments of type Queue

Modifier and Type	Method	Description
List<Queue>	RouteContextList.getDurableQueues()
List<Queue>	RoutingContext.getDurableQueues(SimpleString address)
List<Queue>	RouteContextList.getNonDurableQueues()
List<Queue>	RoutingContext.getNonDurableQueues(SimpleString address)

Methods in org.apache.activemq.artemis.core.server with parameters of type Queue

Modifier and Type	Method	Description
void	RouteContextList.addAckedQueue(Queue queue)
void	RoutingContext.addQueue(SimpleString address, Queue queue)
void	RoutingContext.addQueueWithAck(SimpleString address, Queue queue)
MessageReference	MessageReference.copy(Queue queue)
static MessageReference	MessageReference.Factory.createReference(Message encode, Queue queue)
MessageReference	ServerMessage.createReference(Queue queue)	Deprecated.
boolean	RouteContextList.isAlreadyAcked(Queue queue)
boolean	RoutingContext.isAlreadyAcked(Message message, Queue queue)
default void	QueueFactory.queueRemoved(Queue queue)
void	ActiveMQServer.registerQueueOnManagement(Queue queue)

Method parameters in org.apache.activemq.artemis.core.server with type arguments of type Queue

Modifier and Type	Method	Description
void	RoutingContext.forEachDurable(Consumer<Queue> consumer)

Uses of Queue in org.apache.activemq.artemis.core.server.cluster

Methods in org.apache.activemq.artemis.core.server.cluster that return Queue

Modifier and Type	Method	Description
Queue	Bridge.getQueue()

Uses of Queue in org.apache.activemq.artemis.core.server.cluster.impl

Fields in org.apache.activemq.artemis.core.server.cluster.impl declared as Queue

Modifier and Type	Field	Description
protected final Queue	BridgeImpl.queue

Methods in org.apache.activemq.artemis.core.server.cluster.impl that return Queue

Modifier and Type	Method	Description
Queue	BridgeImpl.getQueue()
Queue	RemoteQueueBindingImpl.getQueue()

Constructors in org.apache.activemq.artemis.core.server.cluster.impl with parameters of type Queue

Modifier	Constructor	Description
	BridgeImpl(ServerLocatorInternal serverLocator, BridgeConfiguration configuration, UUID nodeUUID, Queue queue, Executor executor, ScheduledExecutorService scheduledExecutor, ActiveMQServer server)
	ClusterConnectionBridge(ClusterConnection clusterConnection, ClusterManager clusterManager, ServerLocatorInternal targetLocator, ServerLocatorInternal discoveryLocator, int initialConnectAttempts, int reconnectAttempts, long retryInterval, double retryMultiplier, long maxRetryInterval, UUID nodeUUID, long targetNodeEventUID, String targetNodeID, SimpleString name, Queue queue, Executor executor, Filter filterString, SimpleString forwardingAddress, ScheduledExecutorService scheduledExecutor, TransformerConfiguration transformer, boolean useDuplicateDetection, String user, String password, ActiveMQServer server, SimpleString managementAddress, SimpleString managementNotificationAddress, MessageFlowRecord flowRecord, TransportConfiguration connector, String storeAndForwardPrefix, StorageManager storageManager, String clientId)
	Redistributor(Queue queue, long sequentialID, PostOffice postOffice)
	RemoteQueueBindingImpl(long id, SimpleString address, SimpleString uniqueName, SimpleString routingName, Long remoteQueueID, SimpleString filterString, Queue storeAndForwardQueue, SimpleString bridgeName, int distance, MessageLoadBalancingType messageLoadBalancingType)

Uses of Queue in org.apache.activemq.artemis.core.server.impl

Classes in org.apache.activemq.artemis.core.server.impl that implement Queue

Modifier and Type	Class	Description
class	LastValueQueue	A queue that will discard messages if a newer message with the same Message.HDR_LAST_VALUE_NAME property value.
class	QueueImpl	Implementation of a Queue

Fields in org.apache.activemq.artemis.core.server.impl declared as Queue

Modifier and Type	Field	Description
protected final Queue	ServerConsumerImpl.messageQueue

Methods in org.apache.activemq.artemis.core.server.impl that return Queue

Modifier and Type	Method	Description
Queue	ActiveMQServerImpl.createQueue(QueueConfiguration queueConfiguration)
Queue	ActiveMQServerImpl.createQueue(QueueConfiguration queueConfiguration, boolean ignoreIfExists)
Queue	ActiveMQServerImpl.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filterString, boolean durable, boolean temporary)	Deprecated.
Queue	ActiveMQServerImpl.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable, boolean temporary, int maxConsumers, boolean purgeOnNoConsumers, boolean autoCreateAddress)	Deprecated.
Queue	ActiveMQServerImpl.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable, boolean temporary, int maxConsumers, boolean purgeOnNoConsumers, boolean exclusive, boolean groupRebalance, int groupBuckets, boolean lastValue, SimpleString lastValueKey, boolean nonDestructive, int consumersBeforeDispatch, long delayBeforeDispatch, boolean autoDelete, long autoDeleteDelay, long autoDeleteMessageCount, boolean autoCreateAddress)	Deprecated.
Queue	ActiveMQServerImpl.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable, boolean temporary, int maxConsumers, boolean purgeOnNoConsumers, boolean exclusive, boolean groupRebalance, int groupBuckets, SimpleString groupFirstKey, boolean lastValue, SimpleString lastValueKey, boolean nonDestructive, int consumersBeforeDispatch, long delayBeforeDispatch, boolean autoDelete, long autoDeleteDelay, long autoDeleteMessageCount, boolean autoCreateAddress)	Deprecated.
Queue	ActiveMQServerImpl.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable, boolean temporary, int maxConsumers, boolean purgeOnNoConsumers, boolean exclusive, boolean groupRebalance, int groupBuckets, SimpleString groupFirstKey, boolean lastValue, SimpleString lastValueKey, boolean nonDestructive, int consumersBeforeDispatch, long delayBeforeDispatch, boolean autoDelete, long autoDeleteDelay, long autoDeleteMessageCount, boolean autoCreateAddress, long ringSize)	Deprecated.
Queue	ActiveMQServerImpl.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString user, SimpleString filterString, boolean durable, boolean temporary)	Deprecated.
Queue	ActiveMQServerImpl.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, SimpleString user, boolean durable, boolean temporary, boolean ignoreIfExists, boolean transientQueue, boolean autoCreated, int maxConsumers, boolean purgeOnNoConsumers, boolean autoCreateAddress)	Deprecated.
Queue	ActiveMQServerImpl.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, SimpleString user, boolean durable, boolean temporary, boolean ignoreIfExists, boolean transientQueue, boolean autoCreated, int maxConsumers, boolean purgeOnNoConsumers, boolean exclusive, boolean lastValue, boolean autoCreateAddress)	Deprecated.
Queue	ActiveMQServerImpl.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filterString, SimpleString user, boolean durable, boolean temporary, boolean ignoreIfExists, boolean transientQueue, boolean autoCreated, int maxConsumers, boolean purgeOnNoConsumers, boolean exclusive, boolean groupRebalance, int groupBuckets, boolean lastValue, SimpleString lastValueKey, boolean nonDestructive, int consumersBeforeDispatch, long delayBeforeDispatch, boolean autoDelete, long autoDeleteDelay, long autoDeleteMessageCount, boolean autoCreateAddress)	Deprecated.
Queue	ActiveMQServerImpl.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filterString, SimpleString user, boolean durable, boolean temporary, boolean ignoreIfExists, boolean transientQueue, boolean autoCreated, int maxConsumers, boolean purgeOnNoConsumers, boolean exclusive, boolean groupRebalance, int groupBuckets, SimpleString groupFirstKey, boolean lastValue, SimpleString lastValueKey, boolean nonDestructive, int consumersBeforeDispatch, long delayBeforeDispatch, boolean autoDelete, long autoDeleteDelay, long autoDeleteMessageCount, boolean autoCreateAddress)	Deprecated.
Queue	ActiveMQServerImpl.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filterString, SimpleString user, boolean durable, boolean temporary, boolean ignoreIfExists, boolean transientQueue, boolean autoCreated, int maxConsumers, boolean purgeOnNoConsumers, boolean exclusive, boolean groupRebalance, int groupBuckets, SimpleString groupFirstKey, boolean lastValue, SimpleString lastValueKey, boolean nonDestructive, int consumersBeforeDispatch, long delayBeforeDispatch, boolean autoDelete, long autoDeleteDelay, long autoDeleteMessageCount, boolean autoCreateAddress, long ringSize)	Deprecated.
Queue	ActiveMQServerImpl.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, SimpleString user, boolean durable, boolean temporary, boolean autoCreated, Integer maxConsumers, Boolean purgeOnNoConsumers, boolean autoCreateAddress)	Deprecated.
Queue	ActiveMQServerImpl.createQueue(SimpleString address, SimpleString queueName, SimpleString filterString, boolean durable, boolean temporary)	Deprecated.
Queue	ActiveMQServerImpl.createQueue(AddressInfo addrInfo, SimpleString queueName, SimpleString filterString, SimpleString user, boolean durable, boolean temporary, boolean ignoreIfExists, boolean transientQueue, boolean autoCreated, int maxConsumers, boolean purgeOnNoConsumers, boolean exclusive, boolean groupRebalance, int groupBuckets, SimpleString groupFirstKey, boolean lastValue, SimpleString lastValueKey, boolean nonDestructive, int consumersBeforeDispatch, long delayBeforeDispatch, boolean autoDelete, long autoDeleteDelay, long autoDeleteMessageCount, boolean autoCreateAddress, boolean configurationManaged, long ringSize)	Deprecated.
Queue	ActiveMQServerImpl.createQueue(AddressInfo addressInfo, SimpleString queueName, SimpleString filter, SimpleString user, boolean durable, boolean temporary, boolean autoCreated, Integer maxConsumers, Boolean purgeOnNoConsumers, boolean autoCreateAddress)	Deprecated.
Queue	ActiveMQServerImpl.createQueue(AddressInfo addressInfo, SimpleString queueName, SimpleString filter, SimpleString user, boolean durable, boolean temporary, boolean autoCreated, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean lastValue, boolean autoCreateAddress)	Deprecated.
Queue	ActiveMQServerImpl.createQueue(AddressInfo addressInfo, SimpleString queueName, SimpleString filter, SimpleString user, boolean durable, boolean temporary, boolean autoCreated, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, Boolean lastValue, SimpleString lastValueKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, Boolean autoDelete, Long autoDeleteDelay, Long autoDeleteMessageCount, boolean autoCreateAddress)	Deprecated.
Queue	ActiveMQServerImpl.createQueue(AddressInfo addressInfo, SimpleString queueName, SimpleString filter, SimpleString user, boolean durable, boolean temporary, boolean autoCreated, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, SimpleString groupFirstKey, Boolean lastValue, SimpleString lastValueKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, Boolean autoDelete, Long autoDeleteDelay, Long autoDeleteMessageCount, boolean autoCreateAddress)	Deprecated.
Queue	ActiveMQServerImpl.createQueue(AddressInfo addressInfo, SimpleString queueName, SimpleString filter, SimpleString user, boolean durable, boolean temporary, boolean autoCreated, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, SimpleString groupFirstKey, Boolean lastValue, SimpleString lastValueKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, Boolean autoDelete, Long autoDeleteDelay, Long autoDeleteMessageCount, boolean autoCreateAddress, Long ringSize)	Deprecated.
Queue	ServerSessionImpl.createQueue(QueueConfiguration queueConfiguration)
Queue	ServerSessionImpl.createQueue(SimpleString address, SimpleString name, RoutingType routingType, SimpleString filterString, boolean temporary, boolean durable)	Deprecated.
Queue	ServerSessionImpl.createQueue(SimpleString address, SimpleString name, RoutingType routingType, SimpleString filterString, boolean temporary, boolean durable, boolean autoCreated)	Deprecated.
Queue	ServerSessionImpl.createQueue(SimpleString address, SimpleString name, RoutingType routingType, SimpleString filterString, boolean temporary, boolean durable, int maxConsumers, boolean purgeOnNoConsumers, boolean autoCreated)	Deprecated.
Queue	ServerSessionImpl.createQueue(SimpleString address, SimpleString name, RoutingType routingType, SimpleString filterString, boolean temporary, boolean durable, int maxConsumers, boolean purgeOnNoConsumers, Boolean exclusive, Boolean lastValue, boolean autoCreated)	Deprecated.
Queue	ServerSessionImpl.createQueue(SimpleString address, SimpleString name, RoutingType routingType, SimpleString filterString, boolean temporary, boolean durable, int maxConsumers, boolean purgeOnNoConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, Boolean lastValue, SimpleString lastValueKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, Boolean autoDelete, Long autoDeleteDelay, Long autoDeleteMessageCount, boolean autoCreated)	Deprecated.
Queue	ServerSessionImpl.createQueue(SimpleString address, SimpleString name, RoutingType routingType, SimpleString filterString, boolean temporary, boolean durable, int maxConsumers, boolean purgeOnNoConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, SimpleString groupFirstKey, Boolean lastValue, SimpleString lastValueKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, Boolean autoDelete, Long autoDeleteDelay, Long autoDeleteMessageCount, boolean autoCreated)	Deprecated.
Queue	ServerSessionImpl.createQueue(SimpleString address, SimpleString name, RoutingType routingType, SimpleString filterString, boolean temporary, boolean durable, int maxConsumers, boolean purgeOnNoConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, SimpleString groupFirstKey, Boolean lastValue, SimpleString lastValueKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, Boolean autoDelete, Long autoDeleteDelay, Long autoDeleteMessageCount, boolean autoCreated, Long ringSize)	Deprecated.
Queue	ServerSessionImpl.createQueue(SimpleString address, SimpleString name, SimpleString filterString, boolean temporary, boolean durable)	Deprecated.
Queue	ServerSessionImpl.createQueue(AddressInfo addressInfo, SimpleString name, SimpleString filterString, boolean temporary, boolean durable)	Deprecated.
Queue	ServerSessionImpl.createQueue(AddressInfo addressInfo, SimpleString name, SimpleString filterString, boolean temporary, boolean durable, boolean autoCreated)	Deprecated.
Queue	ServerSessionImpl.createQueue(AddressInfo addressInfo, SimpleString name, SimpleString filterString, boolean temporary, boolean durable, int maxConsumers, boolean purgeOnNoConsumers, boolean exclusive, boolean groupRebalance, int groupBuckets, SimpleString groupFirstKey, boolean lastValue, SimpleString lastValueKey, boolean nonDestructive, int consumersBeforeDispatch, long delayBeforeDispatch, boolean autoDelete, long autoDeleteDelay, long autoDeleteMessageCount, boolean autoCreated, long ringSize)	Deprecated.
Queue	ServerSessionImpl.createQueue(AddressInfo addressInfo, SimpleString name, SimpleString filterString, boolean temporary, boolean durable, Boolean exclusive, Boolean lastValue, boolean autoCreated)	Deprecated.
Queue	QueueFactoryImpl.createQueueWith(QueueConfiguration config, PagingManager pagingManager, Filter filter)
Queue	ActiveMQServerImpl.deployQueue(String address, String resourceName, String filterString, boolean durable, boolean temporary)	Deprecated.
Queue	ActiveMQServerImpl.deployQueue(SimpleString address, SimpleString resourceName, SimpleString filterString, boolean durable, boolean temporary)	Deprecated.
Queue	GroupFirstMessageReference.getQueue()
Queue	MessageReferenceImpl.getQueue()
Queue	ServerConsumerImpl.getQueue()
Queue	ActiveMQServerImpl.locateQueue(String address, String queue)
Queue	ActiveMQServerImpl.locateQueue(SimpleString queueName)
Queue	ActiveMQServerImpl.updateQueue(String name, RoutingType routingType, Integer maxConsumers, Boolean purgeOnNoConsumers)	Deprecated.
Queue	ActiveMQServerImpl.updateQueue(String name, RoutingType routingType, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive)	Deprecated.
Queue	ActiveMQServerImpl.updateQueue(String name, RoutingType routingType, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, String user)	Deprecated.
Queue	ActiveMQServerImpl.updateQueue(String name, RoutingType routingType, String filterString, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, String user)	Deprecated.
Queue	ActiveMQServerImpl.updateQueue(String name, RoutingType routingType, String filterString, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, String groupFirstKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, String user)	Deprecated.
Queue	ActiveMQServerImpl.updateQueue(String name, RoutingType routingType, String filterString, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, String groupFirstKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, String user, Long ringSize)	Deprecated.
Queue	ActiveMQServerImpl.updateQueue(QueueConfiguration queueConfiguration)
Queue	ActiveMQServerImpl.updateQueue(QueueConfiguration queueConfiguration, boolean forceUpdate)

Methods in org.apache.activemq.artemis.core.server.impl that return types with arguments of type Queue

Modifier and Type	Method	Description
List<Queue>	RoutingContextImpl.ContextListing.getDurableQueues()
List<Queue>	RoutingContextImpl.getDurableQueues(SimpleString address)
List<Queue>	RoutingContextImpl.ContextListing.getNonDurableQueues()
List<Queue>	RoutingContextImpl.getNonDurableQueues(SimpleString address)

Methods in org.apache.activemq.artemis.core.server.impl with parameters of type Queue

Modifier and Type	Method	Description
void	RoutingContextImpl.ContextListing.addAckedQueue(Queue queue)
void	RoutingContextImpl.addQueue(SimpleString address, Queue queue)
void	RoutingContextImpl.addQueueWithAck(SimpleString address, Queue queue)
int	ScaleDownHandler.OrderQueueByNumberOfReferencesComparator.compare(Queue queue1, Queue queue2)
static boolean	QueueManagerImpl.consumerCountCheck(Queue queue)
MessageReference	GroupFirstMessageReference.copy(Queue queue)
MessageReference	MessageReferenceImpl.copy(Queue queue)
static boolean	QueueManagerImpl.delayCheck(Queue queue, AddressSettings settings)
boolean	RoutingContextImpl.ContextListing.isAlreadyAcked(Queue queue)
boolean	RoutingContextImpl.isAlreadyAcked(Message message, Queue queue)
static boolean	QueueManagerImpl.messageCountCheck(Queue queue)
static void	QueueManagerImpl.performAutoDeleteQueue(ActiveMQServer server, Queue queue)
void	QueueFactoryImpl.queueRemoved(Queue queue)
void	ActiveMQServerImpl.registerQueueOnManagement(Queue queue)	Register a queue on the management registry

Method parameters in org.apache.activemq.artemis.core.server.impl with type arguments of type Queue

Modifier and Type	Method	Description
void	RoutingContextImpl.forEachDurable(Consumer<Queue> queueConsumer)
long	ScaleDownHandler.scaleDownRegularMessages(SimpleString address, Set<Queue> queues, ClientSession clientSession, ClientProducer producer)

Constructors in org.apache.activemq.artemis.core.server.impl with parameters of type Queue

Modifier	Constructor	Description
	MessageReferenceImpl(Message message, Queue queue)
	MessageReferenceImpl(MessageReferenceImpl other, Queue queue)
	QueueMessageMetrics(Queue queue, String name)
	RefsOperation(Queue queue, AckReason reason, StorageManager storageManager)
	ScheduledDeliveryHandlerImpl(ScheduledExecutorService scheduledExecutor, Queue queue)

Constructor parameters in org.apache.activemq.artemis.core.server.impl with type arguments of type Queue

Modifier	Constructor	Description
	PostOfficeJournalLoader(PostOffice postOffice, PagingManager pagingManager, StorageManager storageManager, QueueFactory queueFactory, NodeManager nodeManager, ManagementService managementService, GroupingHandler groupingHandler, Configuration configuration, Map<Long,Queue> queues)

Uses of Queue in org.apache.activemq.artemis.core.server.management

Methods in org.apache.activemq.artemis.core.server.management with parameters of type Queue

Modifier and Type	Method	Description
void	ManagementService.registerQueue(Queue queue, SimpleString address, StorageManager storageManager)

Uses of Queue in org.apache.activemq.artemis.core.server.management.impl

Methods in org.apache.activemq.artemis.core.server.management.impl with parameters of type Queue

Modifier and Type	Method	Description
void	ManagementServiceImpl.registerQueue(Queue queue, SimpleString address, StorageManager storageManager)

Uses of Queue in org.apache.activemq.artemis.core.server.plugin

Methods in org.apache.activemq.artemis.core.server.plugin with parameters of type Queue

Modifier and Type	Method	Description
default void	ActiveMQServerQueuePlugin.afterCreateQueue(Queue queue)	After a queue has been created
default void	ActiveMQServerQueuePlugin.afterDestroyQueue(Queue queue, SimpleString address, SecurityAuth session, boolean checkConsumerCount, boolean removeConsumers, boolean autoDeleteAddress)	After a queue has been destroyed
default void	ActiveMQServerQueuePlugin.afterExpiryScan(Queue queue)	To be called before starting expiry scan on the queue
default void	ActiveMQServerQueuePlugin.beforeDestroyQueue(Queue queue, SecurityAuth session, boolean checkConsumerCount, boolean removeConsumers, boolean autoDeleteAddress)	Before a queue is destroyed
default void	ActiveMQServerQueuePlugin.beforeExpiryScan(Queue queue)	To be called before starting expiry scan on the queue
default boolean	ActiveMQServerFederationPlugin.federatedAddressConditionalCreateConsumer(Queue queue)	Conditionally create a federated queue consumer for a federated address.

Uses of Queue in org.apache.activemq.artemis.core.server.plugin.impl

Methods in org.apache.activemq.artemis.core.server.plugin.impl with parameters of type Queue

Modifier and Type	Method	Description
void	LoggingActiveMQServerPlugin.afterCreateQueue(Queue queue)	After a queue has been created
void	LoggingActiveMQServerPluginLogger_impl.afterCreateQueue(Queue queue)
void	LoggingActiveMQServerPluginLogger.afterCreateQueue(Queue queue)
void	LoggingActiveMQServerPlugin.afterDestroyQueue(Queue queue, SimpleString address, SecurityAuth session, boolean checkConsumerCount, boolean removeConsumers, boolean autoDeleteAddress)	After a queue has been destroyed
void	LoggingActiveMQServerPluginLogger_impl.afterDestroyQueue(Queue queue, SimpleString address, SecurityAuth session, boolean checkConsumerCount, boolean removeConsumers, boolean autoDeleteAddress)
void	LoggingActiveMQServerPluginLogger.afterDestroyQueue(Queue queue, SimpleString address, SecurityAuth session, boolean checkConsumerCount, boolean removeConsumers, boolean autoDeleteAddress)

Uses of Queue in org.apache.activemq.artemis.core.server.transformer

Methods in org.apache.activemq.artemis.core.server.transformer with parameters of type Queue

Modifier and Type	Method	Description
MessageReference	ServerMessageImpl.createReference(Queue queue)	Deprecated.

Uses of Queue in org.apache.activemq.artemis.core.transaction

Methods in org.apache.activemq.artemis.core.transaction with parameters of type Queue

Modifier and Type	Method	Description
RefsOperation	Transaction.createRefsOperation(Queue queue, AckReason reason)

Uses of Queue in org.apache.activemq.artemis.core.transaction.impl

Methods in org.apache.activemq.artemis.core.transaction.impl with parameters of type Queue

Modifier and Type	Method	Description
RefsOperation	TransactionImpl.createRefsOperation(Queue queue, AckReason reason)