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.federation.address
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

Constructor and 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

Constructor and 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 and Description
Queue	PageSubscription.getQueue()
Queue	PagedReferenceImpl.getQueue()

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

Modifier and Type	Method and 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 and Description
Queue	PageSubscriptionImpl.getQueue()

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

Modifier and Type	Method and 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 and Description
Queue	QueueBinding.getQueue()

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

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

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

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

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 and 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 and 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 and Description
boolean	BindingsImpl.redistribute(Message message, Queue originatingQueue, RoutingContext context)
Pair<RoutingContext,Message>	PostOfficeImpl.redistribute(Message message, Queue originatingQueue, Transaction tx) 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.reroute(Message message, Queue queue, Transaction tx)

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

Constructor and 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 and Description
Queue	ServerSession.createQueue(AddressInfo address, SimpleString name, SimpleString filterString, boolean temporary, boolean durable)
Queue	ServerSession.createQueue(AddressInfo addressInfo, SimpleString name, SimpleString filterString, boolean temporary, boolean durable, boolean autoCreated)
Queue	ServerSession.createQueue(AddressInfo addressInfo, SimpleString name, SimpleString filterString, boolean temporary, boolean durable, Boolean exclusive, Boolean lastValue, boolean autoCreated)
Queue	ActiveMQServer.createQueue(AddressInfo addressInfo, SimpleString queueName, SimpleString filter, SimpleString user, boolean durable, boolean temporary, boolean autoCreated, Integer maxConsumers, Boolean purgeOnNoConsumers, boolean autoCreateAddress)
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)
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)
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)
Queue	QueueFactory.createQueue(long persistenceID, SimpleString address, SimpleString name, Filter filter, PageSubscription pageSubscription, SimpleString user, boolean durable, boolean temporary, boolean autoCreated) Deprecated. Replaced by QueueFactory.createQueueWith(org.apache.activemq.artemis.core.server.QueueConfig)
Queue	ActiveMQServer.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable, boolean temporary)
Queue	ActiveMQServer.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable, boolean temporary, int maxConsumers, boolean purgeOnNoConsumers, boolean autoCreateAddress)
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)
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)
Queue	ActiveMQServer.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString user, SimpleString filterString, boolean durable, boolean temporary)
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)
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)
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)
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)
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)
Queue	ServerSession.createQueue(SimpleString address, SimpleString name, RoutingType routingType, SimpleString filterString, boolean temporary, boolean durable)
Queue	ServerSession.createQueue(SimpleString address, SimpleString name, RoutingType routingType, SimpleString filterString, boolean temporary, boolean durable, boolean autoCreated)
Queue	ServerSession.createQueue(SimpleString address, SimpleString name, RoutingType routingType, SimpleString filterString, boolean temporary, boolean durable, int maxConsumers, boolean purgeOnNoConsumers, boolean autoCreated)
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)
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)
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)
Queue	ActiveMQServer.createQueue(SimpleString address, SimpleString queueName, SimpleString filter, boolean durable, boolean temporary) Deprecated.
Queue	ServerSession.createQueue(SimpleString address, SimpleString name, SimpleString filterString, boolean temporary, boolean durable) Create queue with default delivery mode
Queue	QueueFactory.createQueueWith(QueueConfig config)
Queue	ActiveMQServer.deployQueue(SimpleString address, SimpleString queue, SimpleString filter, boolean durable, boolean temporary) Deprecated.
Queue	ActiveMQServer.deployQueue(String address, String queue, String filter, boolean durable, boolean temporary) Deprecated.
Queue	MessageReference.getQueue()
Queue	ServerConsumer.getQueue()
Queue	ActiveMQServer.locateQueue(SimpleString queueName)
Queue	ActiveMQServer.updateQueue(String name, RoutingType routingType, Integer maxConsumers, Boolean purgeOnNoConsumers)
Queue	ActiveMQServer.updateQueue(String name, RoutingType routingType, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive)
Queue	ActiveMQServer.updateQueue(String name, RoutingType routingType, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, String user)
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)
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)

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

Modifier and Type	Method and 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 and 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(SimpleString address, Queue queue)
default void	QueueFactory.queueRemoved(Queue queue)

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 and 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 and Description
protected Queue	BridgeImpl.queue

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

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

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

Constructor and Description
BridgeImpl(ServerLocatorInternal serverLocator, int initialConnectAttempts, int reconnectAttempts, int reconnectAttemptsSameNode, long retryInterval, double retryMultiplier, long maxRetryInterval, UUID nodeUUID, SimpleString name, Queue queue, Executor executor, Filter filter, SimpleString forwardingAddress, ScheduledExecutorService scheduledExecutor, Transformer transformer, boolean useDuplicateDetection, String user, String password, ActiveMQServer server, ComponentConfigurationRoutingType routingType)
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, Transformer transformer, boolean useDuplicateDetection, String user, String password, ActiveMQServer server, SimpleString managementAddress, SimpleString managementNotificationAddress, MessageFlowRecord flowRecord, TransportConfiguration connector, String storeAndForwardPrefix)
Redistributor(Queue queue, StorageManager storageManager, PostOffice postOffice, Executor executor, int batchSize)
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.federation.address

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

Modifier and Type	Method and Description
void	FederatedAddress.afterCreateQueue(Queue queue) After a queue has been created
void	FederatedAddress.beforeDestroyQueue(Queue queue, SecurityAuth session, boolean checkConsumerCount, boolean removeConsumers, boolean autoDeleteAddress) Before an address is removed
boolean	FederatedAddress.Matcher.test(Queue queue)

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 and 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 and Description
protected Queue	ServerConsumerImpl.messageQueue

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

Modifier and Type	Method and Description
Queue	ServerSessionImpl.createQueue(AddressInfo addressInfo, SimpleString name, SimpleString filterString, boolean temporary, boolean durable)
Queue	ServerSessionImpl.createQueue(AddressInfo addressInfo, SimpleString name, SimpleString filterString, boolean temporary, boolean durable, boolean autoCreated)
Queue	ServerSessionImpl.createQueue(AddressInfo addressInfo, SimpleString name, SimpleString filterString, boolean temporary, boolean durable, Boolean exclusive, Boolean lastValue, boolean autoCreated)
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)
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)
Queue	ActiveMQServerImpl.createQueue(AddressInfo addressInfo, SimpleString queueName, SimpleString filter, SimpleString user, boolean durable, boolean temporary, boolean autoCreated, Integer maxConsumers, Boolean purgeOnNoConsumers, boolean autoCreateAddress)
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)
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)
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)
Queue	QueueFactoryImpl.createQueue(long persistenceID, SimpleString address, SimpleString name, Filter filter, PageSubscription pageSubscription, SimpleString user, boolean durable, boolean temporary, boolean autoCreated) Deprecated.
Queue	ActiveMQServerImpl.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filterString, boolean durable, boolean temporary)
Queue	ActiveMQServerImpl.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable, boolean temporary, int maxConsumers, boolean purgeOnNoConsumers, boolean autoCreateAddress)
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)
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)
Queue	ActiveMQServerImpl.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString user, SimpleString filterString, boolean durable, boolean temporary)
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)
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)
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)
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)
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	ServerSessionImpl.createQueue(SimpleString address, SimpleString name, RoutingType routingType, SimpleString filterString, boolean temporary, boolean durable)
Queue	ServerSessionImpl.createQueue(SimpleString address, SimpleString name, RoutingType routingType, SimpleString filterString, boolean temporary, boolean durable, boolean autoCreated)
Queue	ServerSessionImpl.createQueue(SimpleString address, SimpleString name, RoutingType routingType, SimpleString filterString, boolean temporary, boolean durable, int maxConsumers, boolean purgeOnNoConsumers, boolean autoCreated)
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)
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)
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)
Queue	ServerSessionImpl.createQueue(SimpleString address, SimpleString name, SimpleString filterString, boolean temporary, boolean durable)
Queue	ActiveMQServerImpl.createQueue(SimpleString address, SimpleString queueName, SimpleString filterString, boolean durable, boolean temporary) Deprecated.
Queue	QueueFactoryImpl.createQueueWith(QueueConfig config)
Queue	ActiveMQServerImpl.deployQueue(SimpleString address, SimpleString resourceName, SimpleString filterString, boolean durable, boolean temporary) Deprecated.
Queue	ActiveMQServerImpl.deployQueue(String address, String resourceName, String filterString, boolean durable, boolean temporary) Deprecated.
Queue	GroupFirstMessageReference.getQueue()
Queue	MessageReferenceImpl.getQueue()
Queue	ServerConsumerImpl.getQueue()
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)
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)

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

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

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

Modifier and Type	Method and Description
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)
boolean	RoutingContextImpl.isAlreadyAcked(SimpleString address, Queue queue)
static boolean	QueueManagerImpl.isAutoDelete(Queue queue)
static boolean	QueueManagerImpl.messageCountCheck(Queue queue)
static void	QueueManagerImpl.performAutoDeleteQueue(ActiveMQServer server, Queue queue)
void	QueueFactoryImpl.queueRemoved(Queue queue)

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

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

Constructor and Description
MessageReferenceImpl(Message message, Queue queue)
MessageReferenceImpl(MessageReferenceImpl other, Queue queue)
QueuePendingMessageMetrics(Queue queue)
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

Constructor and 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 and 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 and Description
void	ManagementServiceImpl.registerQueue(Queue queue, AddressInfo addressInfo, StorageManager storageManager)
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 and 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.beforeDestroyQueue(Queue queue, SecurityAuth session, boolean checkConsumerCount, boolean removeConsumers, boolean autoDeleteAddress) Before a queue is destroyed

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 and Description
void	LoggingActiveMQServerPlugin.afterCreateQueue(Queue queue) After a queue has been created
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.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 and 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 and 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 and Description
RefsOperation	BindingsTransactionImpl.createRefsOperation(Queue queue, AckReason reason)
RefsOperation	TransactionImpl.createRefsOperation(Queue queue, AckReason reason)