Constructor and Description |
---|
QueueControlImpl(Queue queue,
String address,
PostOffice postOffice,
StorageManager storageManager,
SecurityStore securityStore,
HierarchicalRepository<AddressSettings> addressSettingsRepository) |
Constructor and Description |
---|
MessageCounter(String name,
String subscription,
Queue serverQueue,
boolean topic,
boolean durable,
int daycountmax)
Constructor
|
Modifier and Type | Method and Description |
---|---|
Queue |
PagedReferenceImpl.getQueue() |
Queue |
PageSubscription.getQueue() |
Modifier and Type | Method and Description |
---|---|
MessageReference |
PagedReferenceImpl.copy(Queue queue) |
void |
PageSubscription.setQueue(Queue queue) |
Modifier and Type | Method and Description |
---|---|
Queue |
QueueBinding.getQueue() |
Modifier and Type | Method and Description |
---|---|
List<Queue> |
PostOffice.listQueuesForAddress(SimpleString address) |
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) |
Modifier and Type | Method and Description |
---|---|
Queue |
LocalQueueBinding.getQueue() |
Modifier and Type | Method and Description |
---|---|
List<Queue> |
PostOfficeImpl.listQueuesForAddress(SimpleString address) |
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) |
Constructor and Description |
---|
LocalQueueBinding(SimpleString address,
Queue queue,
SimpleString nodeID) |
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 |
QueueFactory.createQueue(long persistenceID,
SimpleString address,
SimpleString name,
Filter filter,
PageSubscription pageSubscription,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated)
Deprecated.
|
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 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 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,
SimpleString filterString,
boolean temporary,
boolean durable)
Create queue with default delivery mode
|
Queue |
ActiveMQServer.createQueue(SimpleString address,
SimpleString queueName,
SimpleString filter,
boolean durable,
boolean temporary)
Deprecated.
|
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 |
ServerConsumer.getQueue() |
Queue |
MessageReference.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) |
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) |
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) |
Modifier and Type | Method and Description |
---|---|
Queue |
Bridge.getQueue() |
Modifier and Type | Field and Description |
---|---|
protected Queue |
BridgeImpl.queue |
Modifier and Type | Method and Description |
---|---|
Queue |
RemoteQueueBindingImpl.getQueue() |
Queue |
BridgeImpl.getQueue() |
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) |
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) |
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
|
Modifier and Type | Field and Description |
---|---|
protected Queue |
ServerConsumerImpl.messageQueue |
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 lastValue,
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 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 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 |
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 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 filterString,
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 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,
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 |
ServerConsumerImpl.getQueue() |
Queue |
MessageReferenceImpl.getQueue() |
Queue |
ActiveMQServerImpl.locateQueue(SimpleString queueName) |
Queue |
ActiveMQServerImpl.updateQueue(String name,
RoutingType routingType,
Integer maxConsumers,
Boolean purgeOnNoConsumers) |
Queue |
ActiveMQServerImpl.updateQueue(String name,
RoutingType routingType,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
Boolean exclusive) |
Modifier and Type | Method and Description |
---|---|
List<Queue> |
RoutingContextImpl.getDurableQueues(SimpleString address) |
List<Queue> |
RoutingContextImpl.getNonDurableQueues(SimpleString address) |
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) |
MessageReference |
MessageReferenceImpl.copy(Queue queue) |
boolean |
RoutingContextImpl.isAlreadyAcked(SimpleString address,
Queue queue) |
void |
QueueFactoryImpl.queueRemoved(Queue queue) |
Modifier and Type | Method and Description |
---|---|
long |
ScaleDownHandler.scaleDownRegularMessages(SimpleString address,
Set<Queue> queues,
ClientSession clientSession,
ClientProducer producer) |
Constructor and Description |
---|
MessageReferenceImpl(Message message,
Queue queue) |
MessageReferenceImpl(MessageReferenceImpl other,
Queue queue) |
QueuePendingMessageMetrics(Queue queue) |
RefsOperation(Queue queue,
StorageManager storageManager) |
ScheduledDeliveryHandlerImpl(ScheduledExecutorService scheduledExecutor,
Queue 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) |
Modifier and Type | Method and Description |
---|---|
void |
ManagementService.registerQueue(Queue queue,
SimpleString address,
StorageManager storageManager) |
Modifier and Type | Method and Description |
---|---|
void |
ManagementServiceImpl.registerQueue(Queue queue,
AddressInfo addressInfo,
StorageManager storageManager) |
void |
ManagementServiceImpl.registerQueue(Queue queue,
SimpleString address,
StorageManager storageManager) |
Modifier and Type | Method and Description |
---|---|
default void |
ActiveMQServerPlugin.afterCreateQueue(Queue queue)
After a queue has been created
|
default void |
ActiveMQServerPlugin.afterDestroyQueue(Queue queue,
SimpleString address,
SecurityAuth session,
boolean checkConsumerCount,
boolean removeConsumers,
boolean autoDeleteAddress)
After a queue has been destroyed
|
Modifier and Type | Method and Description |
---|---|
void |
LoggingActiveMQServerPluginLogger.afterCreateQueue(Queue queue) |
void |
LoggingActiveMQServerPlugin.afterCreateQueue(Queue queue)
After a queue has been created
|
void |
LoggingActiveMQServerPluginLogger.afterDestroyQueue(Queue queue,
SimpleString address,
SecurityAuth session,
boolean checkConsumerCount,
boolean removeConsumers,
boolean autoDeleteAddress) |
void |
LoggingActiveMQServerPlugin.afterDestroyQueue(Queue queue,
SimpleString address,
SecurityAuth session,
boolean checkConsumerCount,
boolean removeConsumers,
boolean autoDeleteAddress)
After a queue has been destroyed
|
Modifier and Type | Method and Description |
---|---|
MessageReference |
ServerMessageImpl.createReference(Queue queue)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
RefsOperation |
Transaction.createRefsOperation(Queue queue) |
Modifier and Type | Method and Description |
---|---|
RefsOperation |
TransactionImpl.createRefsOperation(Queue queue) |
RefsOperation |
BindingsTransactionImpl.createRefsOperation(Queue queue) |
Copyright © 2019 JBoss by Red Hat. All rights reserved.