Uses of Interface
org.hornetq.core.server.Queue

Packages that use Queue

Package	Description
org.hornetq.core.management.impl
org.hornetq.core.messagecounter
org.hornetq.core.paging.cursor
org.hornetq.core.paging.cursor.impl
org.hornetq.core.persistence
org.hornetq.core.persistence.impl.journal
org.hornetq.core.persistence.impl.nullpm
org.hornetq.core.postoffice
org.hornetq.core.postoffice.impl
org.hornetq.core.server
org.hornetq.core.server.cluster
org.hornetq.core.server.cluster.impl
org.hornetq.core.server.impl
org.hornetq.core.server.management
org.hornetq.core.server.management.impl
org.hornetq.jms.server.management
org.hornetq.jms.server.management.impl

Uses of Queue in org.hornetq.core.management.impl

Constructors in org.hornetq.core.management.impl with parameters of type Queue

Constructor and Description
QueueControlImpl(Queue queue, String address, PostOffice postOffice, StorageManager storageManager, HierarchicalRepository<AddressSettings> addressSettingsRepository)

Uses of Queue in org.hornetq.core.messagecounter

Constructors in org.hornetq.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.hornetq.core.paging.cursor

Methods in org.hornetq.core.paging.cursor that return Queue

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

Methods in org.hornetq.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.hornetq.core.paging.cursor.impl

Methods in org.hornetq.core.paging.cursor.impl that return Queue

Modifier and Type	Method and Description
Queue	PageSubscriptionImpl.getQueue()

Methods in org.hornetq.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.hornetq.core.persistence

Method parameters in org.hornetq.core.persistence with type arguments of type Queue

Modifier and Type	Method and Description
JournalLoadInformation	StorageManager.loadMessageJournal(PostOffice postOffice, PagingManager pagingManager, ResourceManager resourceManager, Map<Long,Queue> queues, Map<Long,QueueBindingInfo> queueInfos, Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap, Set<Pair<Long,Long>> pendingLargeMessages)

Uses of Queue in org.hornetq.core.persistence.impl.journal

Method parameters in org.hornetq.core.persistence.impl.journal with type arguments of type Queue

Modifier and Type	Method and Description
JournalLoadInformation	JournalStorageManager.loadMessageJournal(PostOffice postOffice, PagingManager pagingManager, ResourceManager resourceManager, Map<Long,Queue> queues, Map<Long,QueueBindingInfo> queueInfos, Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap, Set<Pair<Long,Long>> pendingLargeMessages)

Uses of Queue in org.hornetq.core.persistence.impl.nullpm

Method parameters in org.hornetq.core.persistence.impl.nullpm with type arguments of type Queue

Modifier and Type	Method and Description
JournalLoadInformation	NullStorageManager.loadMessageJournal(PostOffice postOffice, PagingManager pagingManager, ResourceManager resourceManager, Map<Long,Queue> queues, Map<Long,QueueBindingInfo> queueInfos, Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap, Set<Pair<Long,Long>> pendingLM)

Uses of Queue in org.hornetq.core.postoffice

Methods in org.hornetq.core.postoffice that return Queue

Modifier and Type	Method and Description
Queue	QueueBinding.getQueue()

Methods in org.hornetq.core.postoffice with parameters of type Queue

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

Uses of Queue in org.hornetq.core.postoffice.impl

Methods in org.hornetq.core.postoffice.impl that return Queue

Modifier and Type	Method and Description
Queue	LocalQueueBinding.getQueue()

Methods in org.hornetq.core.postoffice.impl with parameters of type Queue

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

Constructors in org.hornetq.core.postoffice.impl with parameters of type Queue

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

Uses of Queue in org.hornetq.core.server

Methods in org.hornetq.core.server that return Queue

Modifier and Type	Method and Description
Queue	QueueFactory.createQueue(long persistenceID, SimpleString address, SimpleString name, Filter filter, PageSubscription pageSubscription, boolean durable, boolean temporary)
Queue	HornetQServer.createQueue(SimpleString address, SimpleString queueName, SimpleString filter, boolean durable, boolean temporary)
Queue	HornetQServer.deployQueue(SimpleString address, SimpleString queueName, SimpleString filterString, boolean durable, boolean temporary)
Queue	ServerConsumer.getQueue()
Queue	MessageReference.getQueue()
Queue	HornetQServer.locateQueue(SimpleString queueName)

Methods in org.hornetq.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.hornetq.core.server with parameters of type Queue

Modifier and Type	Method and Description
void	RoutingContext.addQueue(SimpleString address, Queue queue)
MessageReference	MessageReference.copy(Queue queue)
MessageReference	ServerMessage.createReference(Queue queue)

Uses of Queue in org.hornetq.core.server.cluster

Methods in org.hornetq.core.server.cluster that return Queue

Modifier and Type	Method and Description
Queue	Bridge.getQueue()

Uses of Queue in org.hornetq.core.server.cluster.impl

Methods in org.hornetq.core.server.cluster.impl that return Queue

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

Constructors in org.hornetq.core.server.cluster.impl with parameters of type Queue

Constructor and Description
BridgeImpl(ServerLocatorInternal serverLocator, int reconnectAttempts, long retryInterval, double retryMultiplier, long maxRetryInterval, UUID nodeUUID, SimpleString name, Queue queue, Executor executor, SimpleString filterString, SimpleString forwardingAddress, ScheduledExecutorService scheduledExecutor, Transformer transformer, boolean useDuplicateDetection, String user, String password, boolean activated, StorageManager storageManager)
ClusterConnectionBridge(ClusterConnection clusterConnection, ClusterManagerInternal clusterManager, ServerLocatorInternal targetLocator, ServerLocatorInternal discoveryLocator, int reconnectAttempts, long retryInterval, double retryMultiplier, long maxRetryInterval, UUID nodeUUID, long targetNodeEventUID, String targetNodeID, SimpleString name, Queue queue, Executor executor, SimpleString filterString, SimpleString forwardingAddress, ScheduledExecutorService scheduledExecutor, Transformer transformer, boolean useDuplicateDetection, String user, String password, boolean activated, StorageManager storageManager, SimpleString managementAddress, SimpleString managementNotificationAddress, MessageFlowRecord flowRecord, TransportConfiguration connector)
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)

Uses of Queue in org.hornetq.core.server.impl

Classes in org.hornetq.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 MessageImpl.HDR_LAST_VALUE_NAME property value.
class	QueueImpl Implementation of a Queue Completely non blocking between adding to queue and delivering to consumers.

Methods in org.hornetq.core.server.impl that return Queue

Modifier and Type	Method and Description
Queue	QueueFactoryImpl.createQueue(long persistenceID, SimpleString address, SimpleString name, Filter filter, PageSubscription pageSubscription, boolean durable, boolean temporary)
Queue	HornetQServerImpl.createQueue(SimpleString address, SimpleString queueName, SimpleString filterString, boolean durable, boolean temporary)
Queue	HornetQServerImpl.deployQueue(SimpleString address, SimpleString queueName, SimpleString filterString, boolean durable, boolean temporary)
Queue	ServerConsumerImpl.getQueue()
Queue	MessageReferenceImpl.getQueue()
Queue	HornetQServerImpl.locateQueue(SimpleString queueName)

Methods in org.hornetq.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.hornetq.core.server.impl with parameters of type Queue

Modifier and Type	Method and Description
void	RoutingContextImpl.addQueue(SimpleString address, Queue queue)
MessageReference	MessageReferenceImpl.copy(Queue queue)
MessageReference	ServerMessageImpl.createReference(Queue queue)

Constructors in org.hornetq.core.server.impl with parameters of type Queue

Constructor and Description
MessageReferenceImpl(MessageReferenceImpl other, Queue queue)
MessageReferenceImpl(ServerMessage message, Queue queue)

Uses of Queue in org.hornetq.core.server.management

Methods in org.hornetq.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.hornetq.core.server.management.impl

Methods in org.hornetq.core.server.management.impl with parameters of type Queue

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

Uses of Queue in org.hornetq.jms.server.management

Methods in org.hornetq.jms.server.management with parameters of type Queue

Modifier and Type	Method and Description
void	JMSManagementService.registerQueue(HornetQQueue queue, Queue serverQueue)

Uses of Queue in org.hornetq.jms.server.management.impl

Methods in org.hornetq.jms.server.management.impl with parameters of type Queue

Modifier and Type	Method and Description
void	JMSManagementServiceImpl.registerQueue(HornetQQueue queue, Queue serverQueue)