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 |
---|---|
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 |
---|---|
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)
Creates a non-temporary queue non-durable queue.
|
void |
ClientSession.createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
boolean durable)
Creates a non-temporary queue.
|
void |
ClientSession.createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filter,
boolean durable)
Creates a non-temporary queue.
|
void |
ClientSession.createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filter,
boolean durable,
boolean autoCreated)
Creates a non-temporary queue.
|
void |
ClientSession.createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filter,
boolean durable,
boolean autoCreated,
int maxConsumers,
boolean purgeOnNoConsumers)
Creates a non-temporary queue.
|
void |
ClientSession.createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filter,
boolean durable,
boolean autoCreated,
int maxConsumers,
boolean purgeOnNoConsumers,
Boolean exclusive,
Boolean lastValue)
Creates a non-temporary queue.
|
void |
ClientSession.createQueue(String address,
RoutingType routingType,
String queueName)
Creates a non-temporary queue non-durable queue.
|
void |
ClientSession.createQueue(String address,
RoutingType routingType,
String queueName,
boolean durable)
Creates a non-temporary queue.
|
void |
ClientSession.createQueue(String address,
RoutingType routingType,
String queueName,
String filter,
boolean durable)
Creates a non-temporaryqueue.
|
void |
ClientSession.createQueue(String address,
RoutingType routingType,
String queueName,
String filter,
boolean durable,
boolean autoCreated)
Creates a non-temporaryqueue.
|
void |
ClientSession.createQueue(String address,
RoutingType routingType,
String queueName,
String filter,
boolean durable,
boolean autoCreated,
int maxConsumers,
boolean purgeOnNoConsumers)
Creates a non-temporaryqueue.
|
void |
ClientSession.createQueue(String address,
RoutingType routingType,
String queueName,
String filter,
boolean durable,
boolean autoCreated,
int maxConsumers,
boolean purgeOnNoConsumers,
Boolean exclusive,
Boolean lastValue)
Creates a non-temporaryqueue.
|
void |
ClientSession.createSharedQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
boolean durable)
Creates a transient queue.
|
void |
ClientSession.createSharedQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filter,
boolean durable)
Creates a transient queue.
|
void |
ClientSession.createSharedQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filter,
boolean durable,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
Boolean exclusive,
Boolean lastValue)
Creates Shared queue.
|
void |
ClientSession.createTemporaryQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName)
Creates a temporary queue.
|
void |
ClientSession.createTemporaryQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filter)
Creates a temporary queue with a filter.
|
void |
ClientSession.createTemporaryQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filter,
int maxConsumers,
boolean purgeOnNoConsumers,
Boolean exclusive,
Boolean lastValue)
Creates a temporary queue with a filter.
|
void |
ClientSession.createTemporaryQueue(String address,
RoutingType routingType,
String queueName)
Creates a temporary queue.
|
void |
ClientSession.createTemporaryQueue(String address,
RoutingType routingType,
String queueName,
String filter)
Creates a temporary queue with a filter.
|
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.
|
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)
Creates a non-temporary queue non-durable queue.
|
void |
ClientSessionImpl.createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
boolean durable)
Creates a non-temporary queue.
|
void |
ClientSessionImpl.createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filter,
boolean durable)
Creates a non-temporary queue.
|
void |
ClientSessionImpl.createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filterString,
boolean durable,
boolean autoCreated)
New Queue API
|
void |
ClientSessionImpl.createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filterString,
boolean durable,
boolean autoCreated,
int maxConsumers,
boolean purgeOnNoConsumers) |
void |
ClientSessionImpl.createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filterString,
boolean durable,
boolean autoCreated,
int maxConsumers,
boolean purgeOnNoConsumers,
Boolean exclusive,
Boolean lastValue) |
void |
ClientSessionImpl.createQueue(String address,
RoutingType routingType,
String queueName)
Creates a non-temporary queue non-durable queue.
|
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) |
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)
Creates Shared queue.
|
void |
ClientSessionImpl.createTemporaryQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName) |
void |
ClientSessionImpl.createTemporaryQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filter) |
void |
ClientSessionImpl.createTemporaryQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filter,
int maxConsumers,
boolean purgeOnNoConsumers,
Boolean exclusive,
Boolean lastValue) |
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 lastValue) |
Modifier and Type | Method and Description |
---|---|
RoutingType |
CoreQueueConfiguration.getRoutingType() |
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) |
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 |
PostOffice.getMatchingQueue(SimpleString address,
RoutingType routingType) |
SimpleString |
AddressManager.getMatchingQueue(SimpleString address,
RoutingType routingType) |
SimpleString |
PostOffice.getMatchingQueue(SimpleString address,
SimpleString queueName,
RoutingType routingType) |
SimpleString |
AddressManager.getMatchingQueue(SimpleString address,
SimpleString queueName,
RoutingType routingType) |
QueueBinding |
PostOffice.updateQueue(SimpleString name,
RoutingType routingType,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
Boolean exclusive) |
Modifier and Type | Method and Description |
---|---|
AddressInfo |
PostOffice.updateAddressInfo(SimpleString addressName,
EnumSet<RoutingType> routingTypes) |
AddressInfo |
AddressManager.updateAddressInfo(SimpleString addressName,
EnumSet<RoutingType> routingTypes)
it will return null if there are no updates.
|
Modifier and Type | Method and Description |
---|---|
SimpleString |
SimpleAddressManager.getMatchingQueue(SimpleString address,
RoutingType routingType) |
SimpleString |
PostOfficeImpl.getMatchingQueue(SimpleString address,
RoutingType routingType) |
SimpleString |
SimpleAddressManager.getMatchingQueue(SimpleString address,
SimpleString queueName,
RoutingType routingType) |
SimpleString |
PostOfficeImpl.getMatchingQueue(SimpleString address,
SimpleString queueName,
RoutingType routingType) |
QueueBinding |
PostOfficeImpl.updateQueue(SimpleString name,
RoutingType routingType,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
Boolean exclusive) |
Modifier and Type | Method and Description |
---|---|
AddressInfo |
SimpleAddressManager.updateAddressInfo(SimpleString addressName,
EnumSet<RoutingType> routingTypes) |
AddressInfo |
PostOfficeImpl.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) |
void |
ActiveMQSessionContext.createSharedQueue(SimpleString address,
SimpleString queueName,
RoutingType routingType,
SimpleString filterString,
boolean durable) |
void |
ActiveMQSessionContext.createSharedQueue(SimpleString address,
SimpleString queueName,
RoutingType routingType,
SimpleString filterString,
boolean durable,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
Boolean exclusive,
Boolean lastValue) |
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 |
SessionQueueQueryResponseMessage_V3.getRoutingType() |
RoutingType |
CreateSharedQueueMessage_V2.getRoutingType() |
RoutingType |
CreateQueueMessage_V2.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 |
SessionQueueQueryResponseMessage_V3.setRoutingType(RoutingType routingType) |
void |
CreateSharedQueueMessage_V2.setRoutingType(RoutingType routingType) |
void |
CreateQueueMessage_V2.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 lastValue) |
CreateSharedQueueMessage_V2(SimpleString address,
SimpleString queueName,
RoutingType routingType,
SimpleString filterString,
boolean durable,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
Boolean exclusive,
Boolean lastValue,
boolean requiresResponse) |
Constructor and Description |
---|
CreateAddressMessage(SimpleString address,
EnumSet<RoutingType> routingTypes,
boolean autoCreated,
boolean requiresResponse) |
Modifier and Type | Method and Description |
---|---|
RoutingType |
QueueConfig.deliveryMode() |
RoutingType |
ConsumerInfo.getQueueType() |
RoutingType |
RoutingContext.getRoutingType() |
RoutingType |
Queue.getRoutingType() |
RoutingType |
QueueQueryResult.getRoutingType() |
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) |
Queue |
ActiveMQServer.createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filter,
boolean durable,
boolean temporary,
int maxConsumers,
boolean purgeOnNoConsumers,
boolean autoCreateAddress) |
Queue |
ActiveMQServer.createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString user,
SimpleString filterString,
boolean durable,
boolean temporary) |
Queue |
ActiveMQServer.createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filter,
SimpleString user,
boolean durable,
boolean temporary,
boolean ignoreIfExists,
boolean transientQueue,
boolean autoCreated,
int maxConsumers,
boolean purgeOnNoConsumers,
boolean autoCreateAddress) |
Queue |
ActiveMQServer.createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filter,
SimpleString user,
boolean durable,
boolean temporary,
boolean ignoreIfExists,
boolean transientQueue,
boolean autoCreated,
int maxConsumers,
boolean purgeOnNoConsumers,
boolean exclusive,
boolean lastValue,
boolean autoCreateAddress) |
Queue |
ActiveMQServer.createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filter,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
boolean autoCreateAddress) |
Queue |
ServerSession.createQueue(SimpleString address,
SimpleString name,
RoutingType routingType,
SimpleString filterString,
boolean temporary,
boolean durable) |
Queue |
ServerSession.createQueue(SimpleString address,
SimpleString name,
RoutingType routingType,
SimpleString filterString,
boolean temporary,
boolean durable,
boolean autoCreated) |
Queue |
ServerSession.createQueue(SimpleString address,
SimpleString name,
RoutingType routingType,
SimpleString filterString,
boolean temporary,
boolean durable,
int maxConsumers,
boolean purgeOnNoConsumers,
boolean autoCreated) |
Queue |
ServerSession.createQueue(SimpleString address,
SimpleString name,
RoutingType routingType,
SimpleString filterString,
boolean temporary,
boolean durable,
int maxConsumers,
boolean purgeOnNoConsumers,
Boolean exclusive,
Boolean lastValue,
boolean autoCreated) |
void |
ActiveMQServer.createSharedQueue(SimpleString address,
RoutingType routingType,
SimpleString name,
SimpleString filterString,
SimpleString user,
boolean durable)
Creates a transient queue.
|
void |
ActiveMQServer.createSharedQueue(SimpleString address,
RoutingType routingType,
SimpleString name,
SimpleString filterString,
SimpleString user,
boolean durable,
int maxConsumers,
boolean purgeOnNoConsumers,
boolean exclusive,
boolean lastValue) |
void |
ServerSession.createSharedQueue(SimpleString address,
SimpleString name,
RoutingType routingType,
boolean durable,
SimpleString filterString) |
void |
ServerSession.createSharedQueue(SimpleString address,
SimpleString name,
RoutingType routingType,
SimpleString filterString,
boolean durable,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
Boolean exclusive,
Boolean lastValue) |
SimpleString |
ServerSession.getMatchingQueue(SimpleString address,
RoutingType routingType) |
SimpleString |
ServerSession.getMatchingQueue(SimpleString address,
SimpleString queueName,
RoutingType routingType) |
IllegalStateException |
ActiveMQMessageBundle.invalidRoutingTypeDelete(RoutingType routingType,
String address) |
IllegalArgumentException |
ActiveMQMessageBundle.invalidRoutingTypeForAddress(RoutingType routingType,
String address,
Set<RoutingType> supportedRoutingTypes) |
IllegalStateException |
ActiveMQMessageBundle.invalidRoutingTypeUpdate(String queueName,
RoutingType routingType,
String address,
Set<RoutingType> supportedRoutingTypes) |
QueueConfig.Builder |
QueueConfig.Builder.routingType(RoutingType routingType) |
void |
RoutingContext.setRoutingType(RoutingType routingType) |
void |
Queue.setRoutingType(RoutingType routingType) |
void |
ActiveMQServerLogger.undeployQueue(RoutingType routingType,
SimpleString queueName) |
ActiveMQUnexpectedRoutingTypeForAddress |
ActiveMQMessageBundle.unexpectedRoutingTypeForAddress(SimpleString address,
RoutingType expectedRoutingType,
Set<RoutingType> supportedRoutingTypes) |
Queue |
ActiveMQServer.updateQueue(String name,
RoutingType routingType,
Integer maxConsumers,
Boolean purgeOnNoConsumers) |
Queue |
ActiveMQServer.updateQueue(String name,
RoutingType routingType,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
Boolean exclusive) |
Modifier and Type | Method and Description |
---|---|
AddressInfo |
ServerSession.createAddress(SimpleString address,
EnumSet<RoutingType> routingTypes,
boolean autoCreated) |
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) |
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) |
IllegalStateException |
ActiveMQMessageBundle.invalidRoutingTypeUpdate(String queueName,
RoutingType routingType,
String address,
Set<RoutingType> supportedRoutingTypes) |
ActiveMQUnexpectedRoutingTypeForAddress |
ActiveMQMessageBundle.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 lastValue) |
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 |
ServerConsumerImpl.getQueueType() |
RoutingType |
RoutingContextImpl.getRoutingType() |
RoutingType |
QueueImpl.getRoutingType() |
RoutingType |
AddressInfo.getRoutingType() |
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) |
Queue |
ActiveMQServerImpl.createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filter,
boolean durable,
boolean temporary,
int maxConsumers,
boolean purgeOnNoConsumers,
boolean autoCreateAddress) |
Queue |
ActiveMQServerImpl.createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString user,
SimpleString filterString,
boolean durable,
boolean temporary) |
Queue |
ActiveMQServerImpl.createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filter,
SimpleString user,
boolean durable,
boolean temporary,
boolean ignoreIfExists,
boolean transientQueue,
boolean autoCreated,
int maxConsumers,
boolean purgeOnNoConsumers,
boolean autoCreateAddress) |
Queue |
ActiveMQServerImpl.createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filterString,
SimpleString user,
boolean durable,
boolean temporary,
boolean ignoreIfExists,
boolean transientQueue,
boolean autoCreated,
int maxConsumers,
boolean purgeOnNoConsumers,
boolean exclusive,
boolean lastValue,
boolean autoCreateAddress) |
Queue |
ActiveMQServerImpl.createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filter,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
boolean autoCreateAddress)
Deprecated.
|
Queue |
ServerSessionImpl.createQueue(SimpleString address,
SimpleString name,
RoutingType routingType,
SimpleString filterString,
boolean temporary,
boolean durable) |
Queue |
ServerSessionImpl.createQueue(SimpleString address,
SimpleString name,
RoutingType routingType,
SimpleString filterString,
boolean temporary,
boolean durable,
boolean autoCreated) |
Queue |
ServerSessionImpl.createQueue(SimpleString address,
SimpleString name,
RoutingType routingType,
SimpleString filterString,
boolean temporary,
boolean durable,
int maxConsumers,
boolean purgeOnNoConsumers,
boolean autoCreated) |
Queue |
ServerSessionImpl.createQueue(SimpleString address,
SimpleString name,
RoutingType routingType,
SimpleString filterString,
boolean temporary,
boolean durable,
int maxConsumers,
boolean purgeOnNoConsumers,
Boolean exclusive,
Boolean lastValue,
boolean autoCreated) |
void |
ActiveMQServerImpl.createSharedQueue(SimpleString address,
RoutingType routingType,
SimpleString name,
SimpleString filterString,
SimpleString user,
boolean durable) |
void |
ActiveMQServerImpl.createSharedQueue(SimpleString address,
RoutingType routingType,
SimpleString name,
SimpleString filterString,
SimpleString user,
boolean durable,
int maxConsumers,
boolean purgeOnNoConsumers,
boolean exclusive,
boolean lastValue) |
void |
ServerSessionImpl.createSharedQueue(SimpleString address,
SimpleString name,
RoutingType routingType,
boolean durable,
SimpleString filterString) |
void |
ServerSessionImpl.createSharedQueue(SimpleString address,
SimpleString name,
RoutingType routingType,
SimpleString filterString,
boolean durable,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
Boolean exclusive,
Boolean lastValue) |
SimpleString |
ServerSessionImpl.getMatchingQueue(SimpleString address,
RoutingType routingType) |
SimpleString |
ServerSessionImpl.getMatchingQueue(SimpleString address,
SimpleString queueName,
RoutingType routingType) |
void |
RoutingContextImpl.setRoutingType(RoutingType routingType) |
void |
QueueImpl.setRoutingType(RoutingType routingType) |
Queue |
ActiveMQServerImpl.updateQueue(String name,
RoutingType routingType,
Integer maxConsumers,
Boolean purgeOnNoConsumers) |
Queue |
ActiveMQServerImpl.updateQueue(String name,
RoutingType routingType,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
Boolean exclusive) |
Modifier and Type | Method and Description |
---|---|
AddressInfo |
ServerSessionImpl.createAddress(SimpleString address,
EnumSet<RoutingType> routingTypes,
boolean autoCreated) |
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) |
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 autoCreateJMSQueues,
Map<SimpleString,RoutingType> prefixes) |
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,
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) |
QueueImpl(long id,
SimpleString address,
SimpleString name,
Filter filter,
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) |
QueueImpl(long id,
SimpleString address,
SimpleString name,
Filter filter,
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) |
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) |
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 |
ActiveMQServerPlugin.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 |
ActiveMQServerPlugin.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 |
---|---|
Map<SimpleString,RoutingType> |
ProtocolManager.getPrefixes() |
Map<SimpleString,RoutingType> |
AbstractProtocolManager.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) |
abstract void |
SessionContext.createSharedQueue(SimpleString address,
SimpleString queueName,
RoutingType routingType,
SimpleString filterString,
boolean durable,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
Boolean exclusive,
Boolean lastValue)
Creates a shared queue using the routing type set by the Address.
|
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 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 © 2018 JBoss by Red Hat. All rights reserved.