| Modifier and Type | Method and Description |
|---|---|
static QueueConfiguration |
QueueConfiguration.fromJSON(String jsonString)
This method returns a
QueueConfiguration created from the JSON-formatted input String. |
QueueConfiguration |
ParameterisedAddress.getQueueConfiguration() |
QueueConfiguration |
QueueConfiguration.set(String key,
String value)
Set the value of a parameter based on its "key"
String. |
QueueConfiguration |
QueueConfiguration.setAddress(SimpleString address)
Set the name.
|
QueueConfiguration |
QueueConfiguration.setAddress(String address) |
QueueConfiguration |
QueueConfiguration.setAutoCreateAddress(Boolean autoCreateAddress) |
QueueConfiguration |
QueueConfiguration.setAutoCreated(Boolean autoCreated) |
QueueConfiguration |
QueueConfiguration.setAutoDelete(Boolean autoDelete) |
QueueConfiguration |
QueueConfiguration.setAutoDeleteDelay(Long autoDeleteDelay) |
QueueConfiguration |
QueueConfiguration.setAutoDeleteMessageCount(Long autoDeleteMessageCount) |
QueueConfiguration |
QueueConfiguration.setConfigurationManaged(Boolean configurationManaged) |
QueueConfiguration |
QueueConfiguration.setConsumerPriority(Integer consumerPriority) |
QueueConfiguration |
QueueConfiguration.setConsumersBeforeDispatch(Integer consumersBeforeDispatch) |
QueueConfiguration |
QueueConfiguration.setDelayBeforeDispatch(Long delayBeforeDispatch) |
QueueConfiguration |
QueueConfiguration.setDurable(Boolean durable) |
QueueConfiguration |
QueueConfiguration.setEnabled(Boolean enabled) |
QueueConfiguration |
QueueConfiguration.setExclusive(Boolean exclusive) |
QueueConfiguration |
QueueConfiguration.setFilterString(SimpleString filterString) |
QueueConfiguration |
QueueConfiguration.setFilterString(String filterString) |
QueueConfiguration |
QueueConfiguration.setGroupBuckets(Integer groupBuckets) |
QueueConfiguration |
QueueConfiguration.setGroupFirstKey(SimpleString groupFirstKey) |
QueueConfiguration |
QueueConfiguration.setGroupFirstKey(String groupFirstKey) |
QueueConfiguration |
QueueConfiguration.setGroupRebalance(Boolean groupRebalance) |
QueueConfiguration |
QueueConfiguration.setGroupRebalancePauseDispatch(Boolean groupRebalancePauseDispatch) |
QueueConfiguration |
QueueConfiguration.setId(Long id) |
QueueConfiguration |
QueueConfiguration.setInternal(Boolean internal) |
QueueConfiguration |
QueueConfiguration.setLastValue(Boolean lastValue) |
QueueConfiguration |
QueueConfiguration.setLastValueKey(SimpleString lastValueKey) |
QueueConfiguration |
QueueConfiguration.setLastValueKey(String lastValueKey) |
QueueConfiguration |
QueueConfiguration.setMaxConsumers(Integer maxConsumers) |
QueueConfiguration |
QueueConfiguration.setName(SimpleString name)
Set the name.
|
QueueConfiguration |
QueueConfiguration.setName(String name) |
QueueConfiguration |
QueueConfiguration.setNonDestructive(Boolean nonDestructive) |
QueueConfiguration |
QueueConfiguration.setPurgeOnNoConsumers(Boolean purgeOnNoConsumers) |
QueueConfiguration |
QueueConfiguration.setRingSize(Long ringSize) |
QueueConfiguration |
QueueConfiguration.setRoutingType(RoutingType routingType) |
QueueConfiguration |
QueueConfiguration.setTemporary(Boolean temporary) |
QueueConfiguration |
QueueConfiguration.setTransient(Boolean _transient) |
QueueConfiguration |
QueueConfiguration.setUser(SimpleString user) |
QueueConfiguration |
QueueConfiguration.setUser(String user) |
QueueConfiguration |
QueueAttributes.toQueueConfiguration()
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
static QueueAttributes |
QueueAttributes.fromQueueConfiguration(QueueConfiguration queueConfiguration)
Deprecated.
|
| Constructor and Description |
|---|
ParameterisedAddress(SimpleString address,
QueueConfiguration queueConfiguration) |
ParameterisedAddress(String address,
QueueConfiguration queueConfiguration) |
| Modifier and Type | Method and Description |
|---|---|
void |
ClientSession.createQueue(QueueConfiguration queueConfiguration)
This method creates a queue based on the
QueueConfiguration input. |
void |
ClientSession.createSharedQueue(QueueConfiguration queueConfiguration)
This method is essentially the same as
ClientSession.createQueue(QueueConfiguration) with a few key exceptions. |
| Modifier and Type | Method and Description |
|---|---|
void |
ClientSessionImpl.createQueue(QueueConfiguration queueConfiguration) |
void |
ClientSessionImpl.createSharedQueue(QueueConfiguration queueConfiguration) |
| Modifier and Type | Method and Description |
|---|---|
QueueConfiguration |
CoreQueueConfiguration.toQueueConfiguration()
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
List<QueueConfiguration> |
Configuration.getQueueConfigs() |
List<QueueConfiguration> |
CoreAddressConfiguration.getQueueConfigs() |
| Modifier and Type | Method and Description |
|---|---|
Configuration |
Configuration.addQueueConfiguration(QueueConfiguration config) |
CoreAddressConfiguration |
CoreAddressConfiguration.addQueueConfiguration(QueueConfiguration queueConfiguration) |
static CoreQueueConfiguration |
CoreQueueConfiguration.fromQueueConfiguration(QueueConfiguration queueConfiguration)
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
Configuration |
Configuration.setQueueConfigs(List<QueueConfiguration> configs)
Sets the queues configured for this server.
|
CoreAddressConfiguration |
CoreAddressConfiguration.setQueueConfigs(List<QueueConfiguration> queueConfigurations) |
| Modifier and Type | Method and Description |
|---|---|
List<QueueConfiguration> |
ConfigurationImpl.getQueueConfigs() |
| Modifier and Type | Method and Description |
|---|---|
ConfigurationImpl |
ConfigurationImpl.addQueueConfiguration(QueueConfiguration config) |
| Modifier and Type | Method and Description |
|---|---|
ConfigurationImpl |
ConfigurationImpl.setQueueConfigs(List<QueueConfiguration> configs) |
| Modifier and Type | Method and Description |
|---|---|
protected QueueConfiguration |
FileConfigurationParser.parseQueueConfiguration(Node node) |
| Modifier and Type | Method and Description |
|---|---|
QueueBinding |
PostOffice.updateQueue(QueueConfiguration queueConfiguration) |
QueueBinding |
PostOffice.updateQueue(QueueConfiguration queueConfiguration,
boolean forceUpdate) |
| Modifier and Type | Method and Description |
|---|---|
QueueBinding |
PostOfficeImpl.updateQueue(QueueConfiguration queueConfiguration) |
QueueBinding |
PostOfficeImpl.updateQueue(QueueConfiguration queueConfiguration,
boolean forceUpdate) |
| Modifier and Type | Method and Description |
|---|---|
void |
ActiveMQSessionContext.createQueue(QueueConfiguration queueConfiguration) |
void |
ActiveMQSessionContext.createSharedQueue(QueueConfiguration queueConfiguration) |
| Modifier and Type | Method and Description |
|---|---|
QueueConfiguration |
CreateQueueMessage_V2.toQueueConfiguration() |
QueueConfiguration |
CreateSharedQueueMessage_V2.toQueueConfiguration() |
| Constructor and Description |
|---|
CreateQueueMessage_V2(QueueConfiguration queueConfiguration,
boolean requiresResponse) |
CreateQueueMessage(QueueConfiguration queueConfiguration,
boolean requiresResponse) |
CreateSharedQueueMessage_V2(QueueConfiguration queueConfiguration,
boolean requiresResponse) |
| Modifier and Type | Method and Description |
|---|---|
default QueueConfiguration |
Queue.getQueueConfiguration() |
| Modifier and Type | Method and Description |
|---|---|
Queue |
ActiveMQServer.createQueue(QueueConfiguration queueConfiguration)
Overloaded version of
ActiveMQServer.createQueue(QueueConfiguration, boolean) where the boolean
parameter is always false (i.e. |
Queue |
ServerSession.createQueue(QueueConfiguration queueConfiguration)
This method invokes
ActiveMQServer.createQueue(QueueConfiguration) with a few client-specific additions: |
Queue |
ActiveMQServer.createQueue(QueueConfiguration queueConfiguration,
boolean ignoreIfExists)
This method creates a queue based on the
QueueConfiguration input. |
Queue |
QueueFactory.createQueueWith(QueueConfiguration config,
PagingManager pagingManager) |
void |
ActiveMQServer.createSharedQueue(QueueConfiguration queueConfiguration)
This method is essentially the same as
ActiveMQServer.createQueue(QueueConfiguration, boolean) with a few key exceptions. |
void |
ServerSession.createSharedQueue(QueueConfiguration queueConfiguration) |
static QueueConfig |
QueueConfig.fromQueueConfiguration(QueueConfiguration queueConfiguration)
Deprecated.
|
Queue |
ActiveMQServer.updateQueue(QueueConfiguration queueConfiguration)
Update the queue named in the
QueueConfiguration with the corresponding properties. |
Queue |
ActiveMQServer.updateQueue(QueueConfiguration queueConfiguration,
boolean forceUpdate) |
| Modifier and Type | Method and Description |
|---|---|
QueueConfiguration |
LastValueQueue.getQueueConfiguration() |
QueueConfiguration |
QueueImpl.getQueueConfiguration() |
| Modifier and Type | Method and Description |
|---|---|
static void |
QueueConfigurationUtils.applyDynamicQueueDefaults(QueueConfiguration config,
AddressSettings as) |
Queue |
ActiveMQServerImpl.createQueue(QueueConfiguration queueConfiguration) |
Queue |
ServerSessionImpl.createQueue(QueueConfiguration queueConfiguration) |
Queue |
ActiveMQServerImpl.createQueue(QueueConfiguration queueConfiguration,
boolean ignoreIfExists) |
Queue |
QueueFactoryImpl.createQueueWith(QueueConfiguration config,
PagingManager pagingManager) |
void |
ActiveMQServerImpl.createSharedQueue(QueueConfiguration queueConfiguration) |
void |
ServerSessionImpl.createSharedQueue(QueueConfiguration queueConfiguration) |
static PageSubscription |
QueueFactoryImpl.getPageSubscription(QueueConfiguration queueConfiguration,
PagingManager pagingManager) |
Queue |
ActiveMQServerImpl.updateQueue(QueueConfiguration queueConfiguration) |
Queue |
ActiveMQServerImpl.updateQueue(QueueConfiguration queueConfiguration,
boolean forceUpdate) |
| Constructor and Description |
|---|
LastValueQueue(QueueConfiguration queueConfiguration,
PagingStore pagingStore,
PageSubscription pageSubscription,
ScheduledExecutorService scheduledExecutor,
PostOffice postOffice,
StorageManager storageManager,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
ArtemisExecutor executor,
ActiveMQServer server,
QueueFactory factory) |
QueueImpl(QueueConfiguration queueConfiguration,
PagingStore pagingStore,
PageSubscription pageSubscription,
ScheduledExecutorService scheduledExecutor,
PostOffice postOffice,
StorageManager storageManager,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
ArtemisExecutor executor,
ActiveMQServer server,
QueueFactory factory) |
| Modifier and Type | Method and Description |
|---|---|
void |
MirrorController.createQueue(QueueConfiguration queueConfiguration) |
| Modifier and Type | Method and Description |
|---|---|
default void |
ActiveMQServerQueuePlugin.beforeCreateQueue(QueueConfiguration queueConfig)
Before a queue is created
|
| Modifier and Type | Method and Description |
|---|---|
void |
LoggingActiveMQServerPlugin.beforeCreateQueue(QueueConfiguration queueConfig)
Before a queue is created
|
void |
LoggingActiveMQServerPluginLogger.beforeCreateQueue(QueueConfiguration queueConfig) |
void |
LoggingActiveMQServerPluginLogger_$logger.beforeCreateQueue(QueueConfiguration queueConfig) |
| Modifier and Type | Method and Description |
|---|---|
QueueConfiguration |
ActiveMQDestination.getQueueConfiguration() |
| Modifier and Type | Method and Description |
|---|---|
abstract void |
SessionContext.createQueue(QueueConfiguration queueConfiguration) |
abstract void |
SessionContext.createSharedQueue(QueueConfiguration queueConfiguration) |
| Modifier and Type | Method and Description |
|---|---|
static void |
AutoCreateUtil.setRequiredQueueConfigurationIfNotSet(QueueConfiguration queueConfiguration,
ClientSession.AddressQuery addressQuery,
RoutingType routingType,
SimpleString filter,
boolean durable)
Set the non nullable (CreateQueueMessage_V2) queue attributes (all others have static defaults or get defaulted if null by address settings server side).
|
Copyright © 2025 JBoss by Red Hat. All rights reserved.