Constructor and Description |
---|
QueueControlImpl(Queue queue,
String address,
ActiveMQServer server,
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 |
PageSubscription.getQueue() |
Queue |
PagedReferenceImpl.getQueue() |
Modifier and Type | Method and Description |
---|---|
MessageReference |
PagedReferenceImpl.copy(Queue queue) |
void |
PageSubscription.setQueue(Queue queue) |
Modifier and Type | Method and Description |
---|---|
Queue |
PageSubscriptionImpl.getQueue() |
Modifier and Type | Method and Description |
---|---|
void |
PageSubscriptionImpl.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.reload(Message message,
Queue queue,
Transaction tx) |
default MessageReference |
PostOffice.reroute(Message message,
Queue queue,
Transaction tx)
Deprecated.
|
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.reload(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)
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 |
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 |
QueueFactory.createQueue(long persistenceID,
SimpleString address,
SimpleString name,
Filter filter,
PageSubscription pageSubscription,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated)
Deprecated.
|
Queue |
ServerSession.createQueue(QueueConfiguration queueConfiguration)
This method invokes
ActiveMQServer.createQueue(QueueConfiguration) with a few client-specific additions: |
Queue |
ActiveMQServer.createQueue(QueueConfiguration queueConfiguration)
Overloaded version of
ActiveMQServer.createQueue(QueueConfiguration, boolean) where the boolean
parameter is always false (i.e. |
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 |
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 |
ActiveMQServer.createQueue(SimpleString address,
SimpleString queueName,
SimpleString filter,
boolean durable,
boolean temporary)
Deprecated.
|
Queue |
QueueFactory.createQueueWith(QueueConfig config)
Deprecated.
|
Queue |
QueueFactory.createQueueWith(QueueConfiguration config,
PagingManager pagingManager) |
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) |
default Queue |
ActiveMQServer.locateQueue(String queueName) |
Queue |
ActiveMQServer.updateQueue(QueueConfiguration queueConfiguration)
Update the queue named in the
QueueConfiguration with the corresponding properties. |
Queue |
ActiveMQServer.updateQueue(QueueConfiguration queueConfiguration,
boolean forceUpdate) |
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.
|
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,
PagingStore pageStore) |
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 |
BridgeImpl.getQueue() |
Queue |
RemoteQueueBindingImpl.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,
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,
StorageManager storageManager) |
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) |
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)
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,
Boolean exclusive,
Boolean lastValue,
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 |
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 |
QueueFactoryImpl.createQueue(long persistenceID,
SimpleString address,
SimpleString name,
Filter filter,
PageSubscription pageSubscription,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated)
Deprecated.
|
Queue |
ActiveMQServerImpl.createQueue(QueueConfiguration queueConfiguration) |
Queue |
ServerSessionImpl.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 |
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 |
ActiveMQServerImpl.createQueue(SimpleString address,
SimpleString queueName,
SimpleString filterString,
boolean durable,
boolean temporary)
Deprecated.
|
Queue |
ServerSessionImpl.createQueue(SimpleString address,
SimpleString name,
SimpleString filterString,
boolean temporary,
boolean durable)
Deprecated.
|
Queue |
QueueFactoryImpl.createQueueWith(QueueConfig config)
Deprecated.
|
Queue |
QueueFactoryImpl.createQueueWith(QueueConfiguration config,
PagingManager pagingManager) |
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(QueueConfiguration queueConfiguration) |
Queue |
ActiveMQServerImpl.updateQueue(QueueConfiguration queueConfiguration,
boolean forceUpdate) |
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.
|
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) |
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) |
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,
PagingStore owner) |
MessageReferenceImpl(MessageReferenceImpl other,
Queue queue) |
QueueMessageMetrics(Queue queue,
String name) |
RefsOperation(Queue queue,
AckReason reason,
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 |
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
|
default boolean |
ActiveMQServerFederationPlugin.federatedAddressConditionalCreateConsumer(Queue queue)
Conditionally create a federated queue consumer for a federated address.
|
Modifier and Type | Method and Description |
---|---|
void |
LoggingActiveMQServerPlugin.afterCreateQueue(Queue queue)
After a queue has been created
|
void |
LoggingActiveMQServerPluginLogger.afterCreateQueue(Queue queue) |
void |
LoggingActiveMQServerPluginLogger_$logger.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) |
void |
LoggingActiveMQServerPluginLogger_$logger.afterDestroyQueue(Queue queue,
SimpleString address,
SecurityAuth session,
boolean checkConsumerCount,
boolean removeConsumers,
boolean autoDeleteAddress) |
Modifier and Type | Method and Description |
---|---|
MessageReference |
ServerMessageImpl.createReference(Queue queue)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
RefsOperation |
Transaction.createRefsOperation(Queue queue,
AckReason reason) |
Modifier and Type | Method and Description |
---|---|
RefsOperation |
BindingsTransactionImpl.createRefsOperation(Queue queue,
AckReason reason) |
RefsOperation |
TransactionImpl.createRefsOperation(Queue queue,
AckReason reason) |
Copyright © 2021 JBoss by Red Hat. All rights reserved.