| Modifier and Type | Field and Description |
|---|---|
static RoutingType |
ActiveMQDefaultConfiguration.DEFAULT_ROUTING_TYPE |
| Modifier and Type | Method and Description |
|---|---|
static RoutingType |
ActiveMQDefaultConfiguration.getDefaultRoutingType() |
| Modifier and Type | Method and Description |
|---|---|
RoutingType |
QueueAttributes.getRoutingType()
Deprecated.
|
RoutingType |
QueueConfiguration.getRoutingType() |
default RoutingType |
Message.getRoutingType() |
static RoutingType |
RoutingType.getType(byte type) |
static RoutingType |
RoutingType.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static RoutingType[] |
RoutingType.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
| Modifier and Type | Method and Description |
|---|---|
QueueAttributes |
QueueAttributes.setRoutingType(RoutingType routingType)
Deprecated.
|
QueueConfiguration |
QueueConfiguration.setRoutingType(RoutingType routingType) |
default Message |
Message.setRoutingType(RoutingType routingType) |
| Modifier and Type | Method and Description |
|---|---|
RoutingType |
ClientSession.QueueQuery.getRoutingType() |
| Modifier and Type | Method and Description |
|---|---|
void |
ClientSession.createAddress(SimpleString address,
RoutingType routingType,
boolean autoCreated)
Create Address with a single initial routing type
|
void |
ClientSession.createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName)
Deprecated.
|
void |
ClientSession.createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
boolean durable)
Deprecated.
|
void |
ClientSession.createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filter,
boolean durable)
Deprecated.
|
void |
ClientSession.createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filter,
boolean durable,
boolean autoCreated)
Deprecated.
|
void |
ClientSession.createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filter,
boolean durable,
boolean autoCreated,
int maxConsumers,
boolean purgeOnNoConsumers)
Deprecated.
|
void |
ClientSession.createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filter,
boolean durable,
boolean autoCreated,
int maxConsumers,
boolean purgeOnNoConsumers,
Boolean exclusive,
Boolean lastValue)
Deprecated.
|
void |
ClientSession.createQueue(String address,
RoutingType routingType,
String queueName)
Deprecated.
|
void |
ClientSession.createQueue(String address,
RoutingType routingType,
String queueName,
boolean durable)
Deprecated.
|
void |
ClientSession.createQueue(String address,
RoutingType routingType,
String queueName,
String filter,
boolean durable)
Deprecated.
|
void |
ClientSession.createQueue(String address,
RoutingType routingType,
String queueName,
String filter,
boolean durable,
boolean autoCreated)
Deprecated.
|
void |
ClientSession.createQueue(String address,
RoutingType routingType,
String queueName,
String filter,
boolean durable,
boolean autoCreated,
int maxConsumers,
boolean purgeOnNoConsumers)
Deprecated.
|
void |
ClientSession.createQueue(String address,
RoutingType routingType,
String queueName,
String filter,
boolean durable,
boolean autoCreated,
int maxConsumers,
boolean purgeOnNoConsumers,
Boolean exclusive,
Boolean lastValue)
Deprecated.
|
void |
ClientSession.createSharedQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
boolean durable)
Deprecated.
|
void |
ClientSession.createSharedQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filter,
boolean durable)
Deprecated.
|
void |
ClientSession.createSharedQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filter,
boolean durable,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
Boolean exclusive,
Boolean lastValue)
Deprecated.
|
void |
ClientSession.createTemporaryQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName)
Deprecated.
|
void |
ClientSession.createTemporaryQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filter)
Deprecated.
|
void |
ClientSession.createTemporaryQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filter,
int maxConsumers,
boolean purgeOnNoConsumers,
Boolean exclusive,
Boolean lastValue)
Deprecated.
|
void |
ClientSession.createTemporaryQueue(String address,
RoutingType routingType,
String queueName)
Deprecated.
|
void |
ClientSession.createTemporaryQueue(String address,
RoutingType routingType,
String queueName,
String filter)
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
void |
ClientSession.createAddress(SimpleString address,
EnumSet<RoutingType> routingTypes,
boolean autoCreated)
Create Address with a single initial routing type
|
void |
ClientSession.createAddress(SimpleString address,
Set<RoutingType> routingTypes,
boolean autoCreated)
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
ObjectName |
ObjectNameBuilder.getQueueObjectName(SimpleString address,
SimpleString name,
RoutingType routingType)
Returns the ObjectName used by QueueControl.
|
static SimpleString |
ResourceNames.getRetroactiveResourceQueueName(String prefix,
String delimiter,
SimpleString address,
RoutingType routingType) |
| Modifier and Type | Method and Description |
|---|---|
RoutingType |
QueueQueryImpl.getRoutingType() |
| Modifier and Type | Method and Description |
|---|---|
void |
ClientSessionImpl.createAddress(SimpleString address,
RoutingType routingType,
boolean autoCreated) |
void |
ClientSessionImpl.createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName)
Deprecated.
|
void |
ClientSessionImpl.createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
boolean durable)
Deprecated.
|
void |
ClientSessionImpl.createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filter,
boolean durable)
Deprecated.
|
void |
ClientSessionImpl.createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filterString,
boolean durable,
boolean autoCreated)
Deprecated.
|
void |
ClientSessionImpl.createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filterString,
boolean durable,
boolean autoCreated,
int maxConsumers,
boolean purgeOnNoConsumers)
Deprecated.
|
void |
ClientSessionImpl.createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filterString,
boolean durable,
boolean autoCreated,
int maxConsumers,
boolean purgeOnNoConsumers,
Boolean exclusive,
Boolean lastValue)
Deprecated.
|
void |
ClientSessionImpl.createQueue(String address,
RoutingType routingType,
String queueName)
Deprecated.
|
void |
ClientSessionImpl.createQueue(String address,
RoutingType routingType,
String queueName,
boolean durable)
Creates a non-temporary queue.
|
void |
ClientSessionImpl.createQueue(String address,
RoutingType routingType,
String queueName,
String filter,
boolean durable)
Creates a non-temporaryqueue.
|
void |
ClientSessionImpl.createQueue(String address,
RoutingType routingType,
String queueName,
String filterString,
boolean durable,
boolean autoCreated) |
void |
ClientSessionImpl.createQueue(String address,
RoutingType routingType,
String queueName,
String filterString,
boolean durable,
boolean autoCreated,
int maxConsumers,
boolean purgeOnNoConsumers)
Deprecated.
|
void |
ClientSessionImpl.createQueue(String address,
RoutingType routingType,
String queueName,
String filterString,
boolean durable,
boolean autoCreated,
int maxConsumers,
boolean purgeOnNoConsumers,
Boolean exclusive,
Boolean lastValue) |
void |
ClientSessionImpl.createSharedQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
boolean durable)
Creates a transient queue.
|
void |
ClientSessionImpl.createSharedQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filter,
boolean durable)
Creates a transient queue.
|
void |
ClientSessionImpl.createSharedQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filter,
boolean durable,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
Boolean exclusive,
Boolean lastValue)
Deprecated.
|
void |
ClientSessionImpl.createTemporaryQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName) |
void |
ClientSessionImpl.createTemporaryQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filter)
Deprecated.
|
void |
ClientSessionImpl.createTemporaryQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filter,
int maxConsumers,
boolean purgeOnNoConsumers,
Boolean exclusive,
Boolean lastValue)
Deprecated.
|
void |
ClientSessionImpl.createTemporaryQueue(String address,
RoutingType routingType,
String queueName) |
void |
ClientSessionImpl.createTemporaryQueue(String address,
RoutingType routingType,
String queueName,
String filter) |
| Modifier and Type | Method and Description |
|---|---|
void |
ClientSessionImpl.createAddress(SimpleString address,
EnumSet<RoutingType> routingTypes,
boolean autoCreated) |
void |
ClientSessionImpl.createAddress(SimpleString address,
Set<RoutingType> routingTypes,
boolean autoCreated) |
| Constructor and Description |
|---|
QueueQueryImpl(boolean durable,
boolean temporary,
int consumerCount,
long messageCount,
SimpleString filterString,
SimpleString address,
SimpleString name,
boolean exists,
boolean autoCreateQueues,
int maxConsumers,
boolean autoCreated,
boolean purgeOnNoConsumers,
RoutingType routingType) |
QueueQueryImpl(boolean durable,
boolean temporary,
int consumerCount,
long messageCount,
SimpleString filterString,
SimpleString address,
SimpleString name,
boolean exists,
boolean autoCreateQueues,
int maxConsumers,
boolean autoCreated,
boolean purgeOnNoConsumers,
RoutingType routingType,
Boolean exclusive,
Boolean groupRebalance,
Boolean groupRebalancePauseDispatch,
Integer groupBuckets,
SimpleString groupFirstKey,
Boolean lastValue,
SimpleString lastValueKey,
Boolean nonDestructive,
Integer consumersBeforeDispatch,
Long delayBeforeDispatch,
Boolean autoDelete,
Long autoDeleteDelay,
Long autoDeleteMessageCount,
Integer defaultConsumerWindowSize,
Long ringSize,
Boolean enabled,
Boolean configurationManaged) |
QueueQueryImpl(boolean durable,
boolean temporary,
int consumerCount,
long messageCount,
SimpleString filterString,
SimpleString address,
SimpleString name,
boolean exists,
boolean autoCreateQueues,
int maxConsumers,
boolean autoCreated,
boolean purgeOnNoConsumers,
RoutingType routingType,
Boolean exclusive,
Boolean lastValue,
Integer defaultConsumerWindowSize) |
QueueQueryImpl(boolean durable,
boolean temporary,
int consumerCount,
long messageCount,
SimpleString filterString,
SimpleString address,
SimpleString name,
boolean exists,
boolean autoCreateQueues,
int maxConsumers,
boolean autoCreated,
boolean purgeOnNoConsumers,
RoutingType routingType,
Boolean exclusive,
Boolean groupRebalance,
Integer groupBuckets,
Boolean lastValue,
SimpleString lastValueKey,
Boolean nonDestructive,
Integer consumersBeforeDispatch,
Long delayBeforeDispatch,
Boolean autoDelete,
Long autoDeleteDelay,
Long autoDeleteMessageCount,
Integer defaultConsumerWindowSize) |
| Modifier and Type | Method and Description |
|---|---|
RoutingType |
CoreQueueConfiguration.getRoutingType()
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
EnumSet<RoutingType> |
CoreAddressConfiguration.getRoutingTypes() |
| Modifier and Type | Method and Description |
|---|---|
CoreAddressConfiguration |
CoreAddressConfiguration.addRoutingType(RoutingType routingType) |
CoreQueueConfiguration |
CoreQueueConfiguration.setRoutingType(RoutingType routingType)
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
RoutingType |
CoreMessage.getRoutingType() |
| Modifier and Type | Method and Description |
|---|---|
Message |
CoreMessage.setRoutingType(RoutingType routingType) |
| Modifier and Type | Method and Description |
|---|---|
EnumSet<RoutingType> |
AddressBindingInfo.getRoutingTypes() |
| Modifier and Type | Field and Description |
|---|---|
EnumSet<RoutingType> |
PersistentAddressBindingEncoding.routingTypes |
| Modifier and Type | Method and Description |
|---|---|
EnumSet<RoutingType> |
PersistentAddressBindingEncoding.getRoutingTypes() |
| Constructor and Description |
|---|
PersistentAddressBindingEncoding(SimpleString name,
EnumSet<RoutingType> routingTypes,
boolean autoCreated) |
| Modifier and Type | Method and Description |
|---|---|
SimpleString |
AddressManager.getMatchingQueue(SimpleString address,
RoutingType routingType) |
SimpleString |
PostOffice.getMatchingQueue(SimpleString address,
RoutingType routingType) |
SimpleString |
AddressManager.getMatchingQueue(SimpleString address,
SimpleString queueName,
RoutingType routingType) |
SimpleString |
PostOffice.getMatchingQueue(SimpleString address,
SimpleString queueName,
RoutingType routingType) |
QueueBinding |
PostOffice.updateQueue(SimpleString name,
RoutingType routingType,
Filter filter,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
Boolean exclusive,
Boolean groupRebalance,
Integer groupBuckets,
SimpleString groupFirstKey,
Boolean nonDestructive,
Integer consumersBeforeDispatch,
Long delayBeforeDispatch,
SimpleString user,
Boolean configurationManaged)
Deprecated.
|
QueueBinding |
PostOffice.updateQueue(SimpleString name,
RoutingType routingType,
Filter filter,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
Boolean exclusive,
Boolean groupRebalance,
Integer groupBuckets,
SimpleString groupFirstKey,
Boolean nonDestructive,
Integer consumersBeforeDispatch,
Long delayBeforeDispatch,
SimpleString user,
Boolean configurationManaged,
Long ringSize)
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
AddressInfo |
AddressManager.updateAddressInfo(SimpleString addressName,
EnumSet<RoutingType> routingTypes)
it will return null if there are no updates.
|
AddressInfo |
PostOffice.updateAddressInfo(SimpleString addressName,
EnumSet<RoutingType> routingTypes) |
| Modifier and Type | Method and Description |
|---|---|
SimpleString |
PostOfficeImpl.getMatchingQueue(SimpleString address,
RoutingType routingType) |
SimpleString |
SimpleAddressManager.getMatchingQueue(SimpleString address,
RoutingType routingType) |
SimpleString |
PostOfficeImpl.getMatchingQueue(SimpleString address,
SimpleString queueName,
RoutingType routingType) |
SimpleString |
SimpleAddressManager.getMatchingQueue(SimpleString address,
SimpleString queueName,
RoutingType routingType) |
QueueBinding |
PostOfficeImpl.updateQueue(SimpleString name,
RoutingType routingType,
Filter filter,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
Boolean exclusive,
Boolean groupRebalance,
Integer groupBuckets,
SimpleString groupFirstKey,
Boolean nonDestructive,
Integer consumersBeforeDispatch,
Long delayBeforeDispatch,
SimpleString user,
Boolean configurationManaged)
Deprecated.
|
QueueBinding |
PostOfficeImpl.updateQueue(SimpleString name,
RoutingType routingType,
Filter filter,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
Boolean exclusive,
Boolean groupRebalance,
Integer groupBuckets,
SimpleString groupFirstKey,
Boolean nonDestructive,
Integer consumersBeforeDispatch,
Long delayBeforeDispatch,
SimpleString user,
Boolean configurationManaged,
Long ringSize)
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
AddressInfo |
PostOfficeImpl.updateAddressInfo(SimpleString addressName,
EnumSet<RoutingType> routingTypes) |
AddressInfo |
SimpleAddressManager.updateAddressInfo(SimpleString addressName,
EnumSet<RoutingType> routingTypes) |
| Modifier and Type | Method and Description |
|---|---|
Map<SimpleString,RoutingType> |
CoreProtocolManager.getPrefixes() |
| Modifier and Type | Method and Description |
|---|---|
void |
ActiveMQSessionContext.createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filterString,
boolean durable,
boolean temp,
int maxConsumers,
boolean purgeOnNoConsumers,
boolean autoCreated)
Deprecated.
|
void |
ActiveMQSessionContext.createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filterString,
boolean durable,
boolean temp,
int maxConsumers,
boolean purgeOnNoConsumers,
boolean autoCreated,
Boolean exclusive,
Boolean lastValue)
Deprecated.
|
void |
ActiveMQSessionContext.createSharedQueue(SimpleString address,
SimpleString queueName,
RoutingType routingType,
SimpleString filterString,
boolean durable)
Deprecated.
|
void |
ActiveMQSessionContext.createSharedQueue(SimpleString address,
SimpleString queueName,
RoutingType routingType,
SimpleString filterString,
boolean durable,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
Boolean exclusive,
Boolean lastValue)
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
void |
ActiveMQSessionContext.createAddress(SimpleString address,
EnumSet<RoutingType> routingTypes,
boolean autoCreated) |
void |
ActiveMQSessionContext.createAddress(SimpleString address,
Set<RoutingType> routingTypes,
boolean autoCreated) |
| Modifier and Type | Field and Description |
|---|---|
protected RoutingType |
SessionQueueQueryResponseMessage_V3.routingType |
| Modifier and Type | Method and Description |
|---|---|
RoutingType |
CreateQueueMessage_V2.getRoutingType() |
RoutingType |
CreateSharedQueueMessage_V2.getRoutingType() |
RoutingType |
SessionQueueQueryResponseMessage_V3.getRoutingType() |
| Modifier and Type | Method and Description |
|---|---|
EnumSet<RoutingType> |
CreateAddressMessage.getRoutingTypes() |
| Modifier and Type | Method and Description |
|---|---|
static SimpleString |
QueueAbstractPacket.getOldPrefixedAddress(SimpleString address,
RoutingType routingType) |
void |
CreateQueueMessage_V2.setRoutingType(RoutingType routingType) |
void |
CreateSharedQueueMessage_V2.setRoutingType(RoutingType routingType) |
void |
SessionQueueQueryResponseMessage_V3.setRoutingType(RoutingType routingType) |
| Modifier and Type | Method and Description |
|---|---|
void |
CreateAddressMessage.setRoutingTypes(EnumSet<RoutingType> routingTypes) |
| Constructor and Description |
|---|
CreateQueueMessage_V2(SimpleString address,
SimpleString queueName,
RoutingType routingType,
SimpleString filterString,
boolean durable,
boolean temporary,
int maxConsumers,
boolean purgeOnNoConsumers,
boolean autoCreated,
boolean requiresResponse,
Boolean exclusive,
Boolean groupRebalance,
Boolean groupRebalancePauseDispatch,
Integer groupBuckets,
SimpleString groupFirstKey,
Boolean lastValue,
SimpleString lastValueKey,
Boolean nonDestructive,
Integer consumersBeforeDispatch,
Long delayBeforeDispatch,
Boolean autoDelete,
Long autoDeleteDelay,
Long autoDeleteMessageCount,
Long ringSize,
Boolean enabled) |
CreateSharedQueueMessage_V2(SimpleString address,
SimpleString queueName,
RoutingType routingType,
SimpleString filterString,
boolean durable,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
Boolean exclusive,
Boolean groupRebalance,
Boolean groupRebalancePauseDispatch,
Integer groupBuckets,
SimpleString groupFirstKey,
Boolean lastValue,
SimpleString lastValueKey,
Boolean nonDestructive,
Integer consumersBeforeDispatch,
Long delayBeforeDispatch,
Boolean autoDelete,
Long autoDeleteDelay,
Long autoDeleteMessageCount,
Long ringSize,
Boolean enabled,
boolean requiresResponse) |
| Constructor and Description |
|---|
CreateAddressMessage(SimpleString address,
EnumSet<RoutingType> routingTypes,
boolean autoCreated,
boolean requiresResponse) |
| Modifier and Type | Method and Description |
|---|---|
RoutingType |
QueueConfig.deliveryMode()
Deprecated.
|
RoutingType |
RoutingContext.getPreviousRoutingType() |
RoutingType |
ConsumerInfo.getQueueType() |
RoutingType |
QueueQueryResult.getRoutingType() |
RoutingType |
Queue.getRoutingType() |
RoutingType |
RoutingContext.getRoutingType() |
RoutingType |
ServerSession.getRoutingTypeFromPrefix(SimpleString address,
RoutingType defaultRoutingType) |
| Modifier and Type | Method and Description |
|---|---|
Pair<SimpleString,EnumSet<RoutingType>> |
ServerSession.getAddressAndRoutingTypes(SimpleString address,
EnumSet<RoutingType> defaultRoutingTypes)
Get the canonical (i.e.
|
Set<RoutingType> |
AddressQueryResult.getRoutingTypes() |
| Modifier and Type | Method and Description |
|---|---|
AddressInfo |
ServerSession.createAddress(SimpleString address,
RoutingType routingType,
boolean autoCreated) |
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.
|
void |
ActiveMQServer.createSharedQueue(SimpleString address,
RoutingType routingType,
SimpleString name,
SimpleString filterString,
SimpleString user,
boolean durable)
Deprecated.
|
void |
ActiveMQServer.createSharedQueue(SimpleString address,
RoutingType routingType,
SimpleString name,
SimpleString filterString,
SimpleString user,
boolean durable,
int maxConsumers,
boolean purgeOnNoConsumers,
boolean exclusive,
boolean lastValue)
Deprecated.
|
void |
ActiveMQServer.createSharedQueue(SimpleString address,
RoutingType routingType,
SimpleString name,
SimpleString filterString,
SimpleString user,
boolean durable,
int maxConsumers,
boolean purgeOnNoConsumers,
boolean exclusive,
boolean groupRebalance,
int groupBuckets,
boolean lastValue,
SimpleString lastValueKey,
boolean nonDestructive,
int consumersBeforeDispatch,
long delayBeforeDispatch,
boolean autoDelete,
long autoDeleteTimeout,
long autoDeleteMessageCount)
Deprecated.
|
void |
ActiveMQServer.createSharedQueue(SimpleString address,
RoutingType routingType,
SimpleString name,
SimpleString filterString,
SimpleString user,
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)
Deprecated.
|
void |
ServerSession.createSharedQueue(SimpleString address,
SimpleString name,
RoutingType routingType,
boolean durable,
SimpleString filterString)
Deprecated.
|
void |
ServerSession.createSharedQueue(SimpleString address,
SimpleString name,
RoutingType routingType,
SimpleString filterString,
boolean durable,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
Boolean exclusive,
Boolean lastValue)
Deprecated.
|
void |
ServerSession.createSharedQueue(SimpleString address,
SimpleString name,
RoutingType routingType,
SimpleString filterString,
boolean durable,
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)
Deprecated.
|
void |
ServerSession.createSharedQueue(SimpleString address,
SimpleString name,
RoutingType routingType,
SimpleString filterString,
boolean durable,
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)
Deprecated.
|
SimpleString |
ServerSession.getMatchingQueue(SimpleString address,
RoutingType routingType) |
SimpleString |
ServerSession.getMatchingQueue(SimpleString address,
SimpleString queueName,
RoutingType routingType) |
RoutingType |
ServerSession.getRoutingTypeFromPrefix(SimpleString address,
RoutingType defaultRoutingType) |
IllegalStateException |
ActiveMQMessageBundle.invalidRoutingTypeDelete(RoutingType routingType,
String address) |
IllegalStateException |
ActiveMQMessageBundle_$bundle.invalidRoutingTypeDelete(RoutingType routingType,
String address) |
IllegalArgumentException |
ActiveMQMessageBundle.invalidRoutingTypeForAddress(RoutingType routingType,
String address,
Set<RoutingType> supportedRoutingTypes) |
IllegalArgumentException |
ActiveMQMessageBundle_$bundle.invalidRoutingTypeForAddress(RoutingType routingType,
String address,
Set<RoutingType> supportedRoutingTypes) |
IllegalStateException |
ActiveMQMessageBundle.invalidRoutingTypeUpdate(String queueName,
RoutingType routingType,
String address,
Set<RoutingType> supportedRoutingTypes) |
IllegalStateException |
ActiveMQMessageBundle_$bundle.invalidRoutingTypeUpdate(String queueName,
RoutingType routingType,
String address,
Set<RoutingType> supportedRoutingTypes) |
QueueConfig.Builder |
QueueConfig.Builder.routingType(RoutingType routingType)
Deprecated.
|
void |
Queue.setRoutingType(RoutingType routingType) |
RoutingContext |
RoutingContext.setRoutingType(RoutingType routingType) |
ActiveMQUnexpectedRoutingTypeForAddress |
ActiveMQMessageBundle.unexpectedRoutingTypeForAddress(SimpleString address,
RoutingType expectedRoutingType,
Set<RoutingType> supportedRoutingTypes) |
ActiveMQUnexpectedRoutingTypeForAddress |
ActiveMQMessageBundle_$bundle.unexpectedRoutingTypeForAddress(SimpleString address,
RoutingType expectedRoutingType,
Set<RoutingType> supportedRoutingTypes) |
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 |
|---|---|
AddressInfo |
ServerSession.createAddress(SimpleString address,
EnumSet<RoutingType> routingTypes,
boolean autoCreated) |
ServerSession |
ActiveMQServer.createInternalSession(String name,
int minLargeMessageSize,
RemotingConnection remotingConnection,
boolean autoCommitSends,
boolean autoCommitAcks,
boolean preAcknowledge,
boolean xa,
String defaultAddress,
SessionCallback callback,
boolean autoCreateQueues,
OperationContext context,
Map<SimpleString,RoutingType> prefixes,
String securityDomain)
This is to be used in places where security is bypassed, like internal sessions, broker connections, etc...
|
ServerSession |
ActiveMQServer.createSession(String name,
String username,
String password,
int minLargeMessageSize,
RemotingConnection remotingConnection,
boolean autoCommitSends,
boolean autoCommitAcks,
boolean preAcknowledge,
boolean xa,
String defaultAddress,
SessionCallback callback,
boolean autoCreateQueues,
OperationContext context,
Map<SimpleString,RoutingType> prefixes,
String securityDomain) |
Pair<SimpleString,EnumSet<RoutingType>> |
ServerSession.getAddressAndRoutingTypes(SimpleString address,
EnumSet<RoutingType> defaultRoutingTypes)
Get the canonical (i.e.
|
IllegalArgumentException |
ActiveMQMessageBundle.invalidRoutingTypeForAddress(RoutingType routingType,
String address,
Set<RoutingType> supportedRoutingTypes) |
IllegalArgumentException |
ActiveMQMessageBundle_$bundle.invalidRoutingTypeForAddress(RoutingType routingType,
String address,
Set<RoutingType> supportedRoutingTypes) |
IllegalStateException |
ActiveMQMessageBundle.invalidRoutingTypeUpdate(String queueName,
RoutingType routingType,
String address,
Set<RoutingType> supportedRoutingTypes) |
IllegalStateException |
ActiveMQMessageBundle_$bundle.invalidRoutingTypeUpdate(String queueName,
RoutingType routingType,
String address,
Set<RoutingType> supportedRoutingTypes) |
ActiveMQUnexpectedRoutingTypeForAddress |
ActiveMQMessageBundle.unexpectedRoutingTypeForAddress(SimpleString address,
RoutingType expectedRoutingType,
Set<RoutingType> supportedRoutingTypes) |
ActiveMQUnexpectedRoutingTypeForAddress |
ActiveMQMessageBundle_$bundle.unexpectedRoutingTypeForAddress(SimpleString address,
RoutingType expectedRoutingType,
Set<RoutingType> supportedRoutingTypes) |
boolean |
ActiveMQServer.updateAddressInfo(SimpleString address,
Collection<RoutingType> routingTypes)
Deprecated.
|
boolean |
ActiveMQServer.updateAddressInfo(SimpleString address,
EnumSet<RoutingType> routingTypes)
Updates an
AddressInfo on the broker with the specified routing types. |
| Constructor and Description |
|---|
QueueQueryResult(SimpleString name,
SimpleString address,
boolean durable,
boolean temporary,
SimpleString filterString,
int consumerCount,
long messageCount,
boolean autoCreateQueues,
boolean exists,
boolean autoCreated,
boolean purgeOnNoConsumers,
RoutingType routingType,
int maxConsumers,
Boolean exclusive,
Boolean groupRebalance,
Boolean groupRebalancePauseDispatch,
Integer groupBuckets,
SimpleString groupFirstKey,
Boolean lastValue,
SimpleString lastValueKey,
Boolean nonDestructive,
Integer consumersBeforeDispatch,
Long delayBeforeDispatch,
Boolean autoDelete,
Long autoDeleteDelay,
Long autoDeleteMessageCount,
Integer defaultConsumerWindowSize,
Long ringSize,
Boolean enabled,
Boolean configurationManaged) |
| Constructor and Description |
|---|
AddressQueryResult(SimpleString name,
Set<RoutingType> routingTypes,
long id,
boolean autoCreated,
boolean exists,
boolean autoCreateAddresses,
boolean defaultPurgeOnNoConsumers,
int defaultMaxConsumers) |
| Modifier and Type | Method and Description |
|---|---|
RoutingType |
FederatedConsumerKey.getRoutingType() |
| Modifier and Type | Method and Description |
|---|---|
RoutingType |
FederatedAddressConsumerKey.getRoutingType() |
| Modifier and Type | Method and Description |
|---|---|
RoutingType |
FederatedQueueConsumerKey.getRoutingType() |
| Modifier and Type | Method and Description |
|---|---|
RoutingType |
RoutingContextImpl.getPreviousRoutingType() |
RoutingType |
ServerConsumerImpl.getQueueType() |
RoutingType |
AddressInfo.getRoutingType() |
RoutingType |
QueueImpl.getRoutingType() |
RoutingType |
RoutingContextImpl.getRoutingType() |
RoutingType |
ServerSessionImpl.getRoutingTypeFromPrefix(SimpleString address,
RoutingType defaultRoutingType) |
| Modifier and Type | Method and Description |
|---|---|
Pair<SimpleString,EnumSet<RoutingType>> |
ServerSessionImpl.getAddressAndRoutingTypes(SimpleString address,
EnumSet<RoutingType> defaultRoutingTypes) |
EnumSet<RoutingType> |
AddressInfo.getRoutingTypes() |
| Modifier and Type | Method and Description |
|---|---|
AddressInfo |
AddressInfo.addRoutingType(RoutingType routingType) |
AddressInfo |
AddressInfo.create(SimpleString name,
RoutingType routingType) |
AddressInfo |
ServerSessionImpl.createAddress(SimpleString address,
RoutingType routingType,
boolean autoCreated) |
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.
|
void |
ActiveMQServerImpl.createSharedQueue(SimpleString address,
RoutingType routingType,
SimpleString name,
SimpleString filterString,
SimpleString user,
boolean durable)
Deprecated.
|
void |
ActiveMQServerImpl.createSharedQueue(SimpleString address,
RoutingType routingType,
SimpleString name,
SimpleString filterString,
SimpleString user,
boolean durable,
int maxConsumers,
boolean purgeOnNoConsumers,
boolean exclusive,
boolean lastValue)
Deprecated.
|
void |
ActiveMQServerImpl.createSharedQueue(SimpleString address,
RoutingType routingType,
SimpleString name,
SimpleString filterString,
SimpleString user,
boolean durable,
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)
Deprecated.
|
void |
ActiveMQServerImpl.createSharedQueue(SimpleString address,
RoutingType routingType,
SimpleString name,
SimpleString filterString,
SimpleString user,
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)
Deprecated.
|
void |
ServerSessionImpl.createSharedQueue(SimpleString address,
SimpleString name,
RoutingType routingType,
boolean durable,
SimpleString filterString)
Deprecated.
|
void |
ServerSessionImpl.createSharedQueue(SimpleString address,
SimpleString name,
RoutingType routingType,
SimpleString filterString,
boolean durable,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
Boolean exclusive,
Boolean lastValue)
Deprecated.
|
void |
ServerSessionImpl.createSharedQueue(SimpleString address,
SimpleString name,
RoutingType routingType,
SimpleString filterString,
boolean durable,
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)
Deprecated.
|
void |
ServerSessionImpl.createSharedQueue(SimpleString address,
SimpleString name,
RoutingType routingType,
SimpleString filterString,
boolean durable,
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)
Deprecated.
|
SimpleString |
ServerSessionImpl.getMatchingQueue(SimpleString address,
RoutingType routingType) |
SimpleString |
ServerSessionImpl.getMatchingQueue(SimpleString address,
SimpleString queueName,
RoutingType routingType) |
RoutingType |
ServerSessionImpl.getRoutingTypeFromPrefix(SimpleString address,
RoutingType defaultRoutingType) |
void |
QueueImpl.setRoutingType(RoutingType routingType) |
RoutingContext |
RoutingContextImpl.setRoutingType(RoutingType routingType) |
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 |
|---|---|
AddressInfo |
ServerSessionImpl.createAddress(SimpleString address,
EnumSet<RoutingType> routingTypes,
boolean autoCreated) |
ServerSession |
ActiveMQServerImpl.createInternalSession(String name,
int minLargeMessageSize,
RemotingConnection connection,
boolean autoCommitSends,
boolean autoCommitAcks,
boolean preAcknowledge,
boolean xa,
String defaultAddress,
SessionCallback callback,
boolean autoCreateQueues,
OperationContext context,
Map<SimpleString,RoutingType> prefixes,
String securityDomain) |
ServerSession |
ActiveMQServerImpl.createSession(String name,
String username,
String password,
int minLargeMessageSize,
RemotingConnection connection,
boolean autoCommitSends,
boolean autoCommitAcks,
boolean preAcknowledge,
boolean xa,
String defaultAddress,
SessionCallback callback,
boolean autoCreateQueues,
OperationContext context,
Map<SimpleString,RoutingType> prefixes,
String securityDomain) |
AddressInfo |
AddressInfo.getAddressAndRoutingType(Map<SimpleString,RoutingType> prefixes) |
Pair<SimpleString,EnumSet<RoutingType>> |
ServerSessionImpl.getAddressAndRoutingTypes(SimpleString address,
EnumSet<RoutingType> defaultRoutingTypes) |
protected ServerSessionImpl |
ActiveMQServerImpl.internalCreateSession(String name,
String username,
String password,
String validatedUser,
int minLargeMessageSize,
RemotingConnection connection,
boolean autoCommitSends,
boolean autoCommitAcks,
boolean preAcknowledge,
boolean xa,
String defaultAddress,
SessionCallback callback,
OperationContext context,
boolean autoCreateQueues,
Map<SimpleString,RoutingType> prefixes,
String securityDomain) |
AddressInfo |
AddressInfo.setRoutingTypes(EnumSet<RoutingType> routingTypes) |
boolean |
ActiveMQServerImpl.updateAddressInfo(SimpleString address,
Collection<RoutingType> routingTypes) |
boolean |
ActiveMQServerImpl.updateAddressInfo(SimpleString address,
EnumSet<RoutingType> routingTypes) |
| Constructor and Description |
|---|
AddressInfo(SimpleString name,
RoutingType routingType)
Creates an AddressInfo object with a single RoutingType associated with it.
|
LastValueQueue(long persistenceID,
SimpleString address,
SimpleString name,
Filter filter,
PagingStore pagingStore,
PageSubscription pageSubscription,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated,
RoutingType routingType,
Integer maxConsumers,
Boolean exclusive,
Boolean groupRebalance,
Integer groupBuckets,
SimpleString groupFirstKey,
Integer consumersBeforeDispatch,
Long delayBeforeDispatch,
Boolean purgeOnNoConsumers,
SimpleString lastValueKey,
Boolean nonDestructive,
Boolean autoDelete,
Long autoDeleteDelay,
Long autoDeleteMessageCount,
boolean configurationManaged,
ScheduledExecutorService scheduledExecutor,
PostOffice postOffice,
StorageManager storageManager,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
ArtemisExecutor executor,
ActiveMQServer server,
QueueFactory factory)
Deprecated.
|
QueueImpl(long id,
SimpleString address,
SimpleString name,
Filter filter,
PagingStore pagingStore,
PageSubscription pageSubscription,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated,
RoutingType routingType,
Integer maxConsumers,
Boolean exclusive,
Boolean groupRebalance,
Integer groupBuckets,
Boolean nonDestructive,
Integer consumersBeforeDispatch,
Long delayBeforeDispatch,
Boolean purgeOnNoConsumers,
Boolean autoDelete,
Long autoDeleteDelay,
Long autoDeleteMessageCount,
boolean configurationManaged,
ScheduledExecutorService scheduledExecutor,
PostOffice postOffice,
StorageManager storageManager,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
ArtemisExecutor executor,
ActiveMQServer server,
QueueFactory factory)
Deprecated.
|
QueueImpl(long id,
SimpleString address,
SimpleString name,
Filter filter,
PagingStore pagingStore,
PageSubscription pageSubscription,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated,
RoutingType routingType,
Integer maxConsumers,
Boolean exclusive,
Boolean groupRebalance,
Integer groupBuckets,
SimpleString groupFirstKey,
Boolean nonDestructive,
Integer consumersBeforeDispatch,
Long delayBeforeDispatch,
Boolean purgeOnNoConsumers,
Boolean autoDelete,
Long autoDeleteDelay,
Long autoDeleteMessageCount,
boolean configurationManaged,
Long ringSize,
ScheduledExecutorService scheduledExecutor,
PostOffice postOffice,
StorageManager storageManager,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
ArtemisExecutor executor,
ActiveMQServer server,
QueueFactory factory)
Deprecated.
|
QueueImpl(long id,
SimpleString address,
SimpleString name,
Filter filter,
PagingStore pagingStore,
PageSubscription pageSubscription,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated,
RoutingType routingType,
Integer maxConsumers,
Boolean exclusive,
Boolean groupRebalance,
Integer groupBuckets,
SimpleString groupFirstKey,
Boolean nonDestructive,
Integer consumersBeforeDispatch,
Long delayBeforeDispatch,
Boolean purgeOnNoConsumers,
Boolean autoDelete,
Long autoDeleteDelay,
Long autoDeleteMessageCount,
boolean configurationManaged,
ScheduledExecutorService scheduledExecutor,
PostOffice postOffice,
StorageManager storageManager,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
ArtemisExecutor executor,
ActiveMQServer server,
QueueFactory factory)
Deprecated.
|
QueueImpl(long id,
SimpleString address,
SimpleString name,
Filter filter,
PagingStore pagingStore,
PageSubscription pageSubscription,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated,
RoutingType routingType,
Integer maxConsumers,
Boolean exclusive,
Boolean purgeOnNoConsumers,
ScheduledExecutorService scheduledExecutor,
PostOffice postOffice,
StorageManager storageManager,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
ArtemisExecutor executor,
ActiveMQServer server,
QueueFactory factory)
Deprecated.
|
QueueImpl(long id,
SimpleString address,
SimpleString name,
Filter filter,
PagingStore pagingStore,
PageSubscription pageSubscription,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated,
RoutingType routingType,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
ScheduledExecutorService scheduledExecutor,
PostOffice postOffice,
StorageManager storageManager,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
ArtemisExecutor executor,
ActiveMQServer server,
QueueFactory factory)
Deprecated.
|
| Constructor and Description |
|---|
AddressInfo(SimpleString name,
EnumSet<RoutingType> routingTypes)
Creates an AddressInfo object with a Set of routing types
|
ServerSessionImpl(String name,
String username,
String password,
String validatedUser,
int minLargeMessageSize,
boolean autoCommitSends,
boolean autoCommitAcks,
boolean preAcknowledge,
boolean strictUpdateDeliveryCount,
boolean xa,
RemotingConnection remotingConnection,
StorageManager storageManager,
PostOffice postOffice,
ResourceManager resourceManager,
SecurityStore securityStore,
ManagementService managementService,
ActiveMQServer server,
SimpleString managementAddress,
SimpleString defaultAddress,
SessionCallback callback,
OperationContext context,
PagingManager pagingManager,
Map<SimpleString,RoutingType> prefixes,
String securityDomain) |
| Modifier and Type | Method and Description |
|---|---|
void |
ManagementService.unregisterQueue(SimpleString name,
SimpleString address,
RoutingType routingType) |
| Modifier and Type | Method and Description |
|---|---|
void |
ManagementServiceImpl.unregisterQueue(SimpleString name,
SimpleString address,
RoutingType routingType) |
| Modifier and Type | Method and Description |
|---|---|
default void |
ActiveMQServerSessionPlugin.beforeCreateSession(String name,
String username,
int minLargeMessageSize,
RemotingConnection connection,
boolean autoCommitSends,
boolean autoCommitAcks,
boolean preAcknowledge,
boolean xa,
String defaultAddress,
SessionCallback callback,
boolean autoCreateQueues,
OperationContext context,
Map<SimpleString,RoutingType> prefixes)
Before a session is created.
|
default void |
ActiveMQServerAddressPlugin.beforeUpdateAddress(SimpleString address,
EnumSet<RoutingType> routingTypes)
Before an address is updated
|
| Modifier and Type | Method and Description |
|---|---|
void |
LoggingActiveMQServerPlugin.beforeCreateSession(String name,
String username,
int minLargeMessageSize,
RemotingConnection connection,
boolean autoCommitSends,
boolean autoCommitAcks,
boolean preAcknowledge,
boolean xa,
String publicAddress,
SessionCallback callback,
boolean autoCreateQueues,
OperationContext context,
Map<SimpleString,RoutingType> prefixes)
Before a session is created.
|
| Modifier and Type | Method and Description |
|---|---|
RoutingType |
AddressSettings.getDefaultAddressRoutingType() |
RoutingType |
AddressSettings.getDefaultQueueRoutingType() |
| Modifier and Type | Method and Description |
|---|---|
AddressSettings |
AddressSettings.setDefaultAddressRoutingType(RoutingType defaultAddressRoutingType) |
AddressSettings |
AddressSettings.setDefaultQueueRoutingType(RoutingType defaultQueueRoutingType) |
| Modifier and Type | Method and Description |
|---|---|
static ActiveMQDestination |
ActiveMQDestination.createDestination(RoutingType routingType,
SimpleString address) |
| Modifier and Type | Method and Description |
|---|---|
Map<SimpleString,RoutingType> |
AbstractProtocolManager.getPrefixes() |
Map<SimpleString,RoutingType> |
ProtocolManager.getPrefixes() |
| Modifier and Type | Method and Description |
|---|---|
abstract void |
SessionContext.createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filterString,
boolean durable,
boolean temp,
int maxConsumers,
boolean purgeOnNoConsumers,
boolean autoCreated)
Deprecated.
|
abstract void |
SessionContext.createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filterString,
boolean durable,
boolean temp,
int maxConsumers,
boolean purgeOnNoConsumers,
boolean autoCreated,
Boolean exclusive,
Boolean lastVale) |
abstract void |
SessionContext.createSharedQueue(SimpleString address,
SimpleString queueName,
RoutingType routingType,
SimpleString filterString,
boolean durable)
Deprecated.
|
abstract void |
SessionContext.createSharedQueue(SimpleString address,
SimpleString queueName,
RoutingType routingType,
SimpleString filterString,
boolean durable,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
Boolean exclusive,
Boolean lastValue)
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
abstract void |
SessionContext.createAddress(SimpleString address,
EnumSet<RoutingType> routingTypes,
boolean autoCreated) |
abstract void |
SessionContext.createAddress(SimpleString address,
Set<RoutingType> routingTypes,
boolean autoCreated)
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
static Pair<SimpleString,EnumSet<RoutingType>> |
PrefixUtil.getAddressAndRoutingTypes(SimpleString address,
EnumSet<RoutingType> defaultRoutingTypes,
Map<SimpleString,RoutingType> prefixes) |
| 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).
|
| Modifier and Type | Method and Description |
|---|---|
static SimpleString |
PrefixUtil.getAddress(SimpleString address,
Map<SimpleString,RoutingType> prefixes) |
static Pair<SimpleString,EnumSet<RoutingType>> |
PrefixUtil.getAddressAndRoutingTypes(SimpleString address,
EnumSet<RoutingType> defaultRoutingTypes,
Map<SimpleString,RoutingType> prefixes) |
static Pair<SimpleString,EnumSet<RoutingType>> |
PrefixUtil.getAddressAndRoutingTypes(SimpleString address,
EnumSet<RoutingType> defaultRoutingTypes,
Map<SimpleString,RoutingType> prefixes) |
static SimpleString |
PrefixUtil.getPrefix(SimpleString address,
Map<SimpleString,RoutingType> prefixes) |
Copyright © 2025 JBoss by Red Hat. All rights reserved.