Constructor and Description |
---|
AddressControlImpl(AddressInfo addressInfo,
ActiveMQServer server,
PagingManager pagingManager,
StorageManager storageManager,
HierarchicalRepository<Set<Role>> securityRepository,
SecurityStore securityStore,
ManagementService managementService) |
Modifier and Type | Method and Description |
---|---|
Object |
AddressView.getField(AddressInfo address,
String fieldName) |
JsonObjectBuilder |
AddressView.toJson(AddressInfo address) |
Modifier and Type | Method and Description |
---|---|
boolean |
AddressFilterPredicate.test(AddressInfo address) |
Modifier and Type | Method and Description |
---|---|
void |
StorageManager.addAddressBinding(long tx,
AddressInfo addressInfo) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractJournalStorageManager.addAddressBinding(long tx,
AddressInfo addressInfo) |
Modifier and Type | Method and Description |
---|---|
void |
NullStorageManager.addAddressBinding(long tx,
AddressInfo addressInfo) |
Modifier and Type | Method and Description |
---|---|
AddressInfo |
AddressManager.getAddressInfo(SimpleString address) |
AddressInfo |
PostOffice.getAddressInfo(SimpleString address) |
AddressInfo |
AddressManager.removeAddressInfo(SimpleString address) |
AddressInfo |
PostOffice.removeAddressInfo(SimpleString address) |
AddressInfo |
PostOffice.removeAddressInfo(SimpleString address,
boolean force) |
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 |
---|---|
boolean |
AddressManager.addAddressInfo(AddressInfo addressInfo) |
boolean |
PostOffice.addAddressInfo(AddressInfo addressInfo) |
boolean |
AddressManager.reloadAddressInfo(AddressInfo addressInfo) |
default void |
PostOffice.reloadAddressInfo(AddressInfo addressInfo) |
Modifier and Type | Method and Description |
---|---|
AddressInfo |
SimpleAddressManager.getAddressInfo(SimpleString addressName) |
AddressInfo |
PostOfficeImpl.getAddressInfo(SimpleString addressName) |
AddressInfo |
SimpleAddressManager.removeAddressInfo(SimpleString address) |
AddressInfo |
WildcardAddressManager.removeAddressInfo(SimpleString address) |
AddressInfo |
PostOfficeImpl.removeAddressInfo(SimpleString address) |
AddressInfo |
PostOfficeImpl.removeAddressInfo(SimpleString address,
boolean force) |
AddressInfo |
SimpleAddressManager.updateAddressInfo(SimpleString addressName,
EnumSet<RoutingType> routingTypes) |
AddressInfo |
PostOfficeImpl.updateAddressInfo(SimpleString addressName,
EnumSet<RoutingType> routingTypes) |
Modifier and Type | Method and Description |
---|---|
boolean |
SimpleAddressManager.addAddressInfo(AddressInfo addressInfo) |
boolean |
PostOfficeImpl.addAddressInfo(AddressInfo addressInfo) |
boolean |
SimpleAddressManager.reloadAddressInfo(AddressInfo addressInfo) |
void |
PostOfficeImpl.reloadAddressInfo(AddressInfo addressInfo) |
Modifier and Type | Method and Description |
---|---|
AddressInfo |
ActiveMQServer.addOrUpdateAddressInfo(AddressInfo addressInfo)
A convenience method to combine the functionality of
addAddressInfo and updateAddressInfo . |
AddressInfo |
ServerSession.createAddress(AddressInfo addressInfo,
boolean autoCreated) |
AddressInfo |
ServerSession.createAddress(SimpleString address,
EnumSet<RoutingType> routingTypes,
boolean autoCreated) |
AddressInfo |
ServerSession.createAddress(SimpleString address,
RoutingType routingType,
boolean autoCreated) |
AddressInfo |
ServerSession.getAddress(SimpleString address) |
AddressInfo |
ServerSession.getAddressAndRoutingType(AddressInfo addressInfo)
Get the canonical (i.e.
|
AddressInfo |
BindingQueryResult.getAddressInfo() |
AddressInfo |
ActiveMQServer.getAddressInfo(SimpleString address) |
Modifier and Type | Method and Description |
---|---|
boolean |
ActiveMQServer.addAddressInfo(AddressInfo addressInfo)
Add the
AddressInfo to the broker |
AddressInfo |
ActiveMQServer.addOrUpdateAddressInfo(AddressInfo addressInfo)
A convenience method to combine the functionality of
addAddressInfo and updateAddressInfo . |
AddressInfo |
ServerSession.createAddress(AddressInfo addressInfo,
boolean autoCreated) |
Queue |
ServerSession.createQueue(AddressInfo address,
SimpleString name,
SimpleString filterString,
boolean temporary,
boolean durable) |
Queue |
ServerSession.createQueue(AddressInfo addressInfo,
SimpleString name,
SimpleString filterString,
boolean temporary,
boolean durable,
boolean autoCreated) |
Queue |
ServerSession.createQueue(AddressInfo addressInfo,
SimpleString name,
SimpleString filterString,
boolean temporary,
boolean durable,
Boolean exclusive,
Boolean lastValue,
boolean autoCreated) |
Queue |
ActiveMQServer.createQueue(AddressInfo addressInfo,
SimpleString queueName,
SimpleString filter,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
boolean autoCreateAddress) |
Queue |
ActiveMQServer.createQueue(AddressInfo addressInfo,
SimpleString queueName,
SimpleString filter,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
Boolean exclusive,
Boolean lastValue,
boolean autoCreateAddress) |
Queue |
ActiveMQServer.createQueue(AddressInfo addressInfo,
SimpleString queueName,
SimpleString filter,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
Boolean exclusive,
Boolean groupRebalance,
Integer groupBuckets,
Boolean lastValue,
SimpleString lastValueKey,
Boolean nonDestructive,
Integer consumersBeforeDispatch,
Long delayBeforeDispatch,
Boolean autoDelete,
Long autoDeleteDelay,
Long autoDeleteMessageCount,
boolean autoCreateAddress) |
Queue |
ActiveMQServer.createQueue(AddressInfo addressInfo,
SimpleString queueName,
SimpleString filter,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
Boolean exclusive,
Boolean groupRebalance,
Integer groupBuckets,
SimpleString groupFirstKey,
Boolean lastValue,
SimpleString lastValueKey,
Boolean nonDestructive,
Integer consumersBeforeDispatch,
Long delayBeforeDispatch,
Boolean autoDelete,
Long autoDeleteDelay,
Long autoDeleteMessageCount,
boolean autoCreateAddress) |
AddressInfo |
ServerSession.getAddressAndRoutingType(AddressInfo addressInfo)
Get the canonical (i.e.
|
Constructor and Description |
---|
BindingQueryResult(boolean exists,
AddressInfo addressInfo,
List<SimpleString> queueNames,
boolean autoCreateQueues,
boolean autoCreateAddresses,
boolean defaultPurgeOnNoConsumers,
int defaultMaxConsumers,
boolean defaultExclusive,
boolean defaultLastValue,
SimpleString defaultLastValueKey,
Boolean defaultNonDestructive,
Integer defaultConsumersBeforeDispatch,
Long defaultDelayBeforeDispatch) |
Modifier and Type | Method and Description |
---|---|
boolean |
ActiveMQServerImpl.addAddressInfo(AddressInfo addressInfo) |
AddressInfo |
ActiveMQServerImpl.addOrUpdateAddressInfo(AddressInfo addressInfo) |
AddressInfo |
ServerSessionImpl.createAddress(AddressInfo addressInfo,
boolean autoCreated) |
Queue |
ServerSessionImpl.createQueue(AddressInfo addressInfo,
SimpleString name,
SimpleString filterString,
boolean temporary,
boolean durable) |
Queue |
ServerSessionImpl.createQueue(AddressInfo addressInfo,
SimpleString name,
SimpleString filterString,
boolean temporary,
boolean durable,
boolean autoCreated) |
Queue |
ServerSessionImpl.createQueue(AddressInfo addressInfo,
SimpleString name,
SimpleString filterString,
boolean temporary,
boolean durable,
Boolean exclusive,
Boolean lastValue,
boolean autoCreated) |
Queue |
ServerSessionImpl.createQueue(AddressInfo addressInfo,
SimpleString name,
SimpleString filterString,
boolean temporary,
boolean durable,
int maxConsumers,
boolean purgeOnNoConsumers,
boolean exclusive,
boolean groupRebalance,
int groupBuckets,
SimpleString groupFirstKey,
boolean lastValue,
SimpleString lastValueKey,
boolean nonDestructive,
int consumersBeforeDispatch,
long delayBeforeDispatch,
boolean autoDelete,
long autoDeleteDelay,
long autoDeleteMessageCount,
boolean autoCreated) |
Queue |
ActiveMQServerImpl.createQueue(AddressInfo addrInfo,
SimpleString queueName,
SimpleString filterString,
SimpleString user,
boolean durable,
boolean temporary,
boolean ignoreIfExists,
boolean transientQueue,
boolean autoCreated,
int maxConsumers,
boolean purgeOnNoConsumers,
boolean exclusive,
boolean groupRebalance,
int groupBuckets,
SimpleString groupFirstKey,
boolean lastValue,
SimpleString lastValueKey,
boolean nonDestructive,
int consumersBeforeDispatch,
long delayBeforeDispatch,
boolean autoDelete,
long autoDeleteDelay,
long autoDeleteMessageCount,
boolean autoCreateAddress,
boolean configurationManaged) |
Queue |
ActiveMQServerImpl.createQueue(AddressInfo addressInfo,
SimpleString queueName,
SimpleString filter,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
boolean autoCreateAddress) |
Queue |
ActiveMQServerImpl.createQueue(AddressInfo addressInfo,
SimpleString queueName,
SimpleString filter,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
Boolean exclusive,
Boolean lastValue,
boolean autoCreateAddress) |
Queue |
ActiveMQServerImpl.createQueue(AddressInfo addressInfo,
SimpleString queueName,
SimpleString filter,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
Boolean exclusive,
Boolean groupRebalance,
Integer groupBuckets,
Boolean lastValue,
SimpleString lastValueKey,
Boolean nonDestructive,
Integer consumersBeforeDispatch,
Long delayBeforeDispatch,
Boolean autoDelete,
Long autoDeleteDelay,
Long autoDeleteMessageCount,
boolean autoCreateAddress) |
Queue |
ActiveMQServerImpl.createQueue(AddressInfo addressInfo,
SimpleString queueName,
SimpleString filter,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
Boolean exclusive,
Boolean groupRebalance,
Integer groupBuckets,
SimpleString groupFirstKey,
Boolean lastValue,
SimpleString lastValueKey,
Boolean nonDestructive,
Integer consumersBeforeDispatch,
Long delayBeforeDispatch,
Boolean autoDelete,
Long autoDeleteDelay,
Long autoDeleteMessageCount,
boolean autoCreateAddress) |
AddressInfo |
ServerSessionImpl.getAddressAndRoutingType(AddressInfo addressInfo) |
Modifier and Type | Method and Description |
---|---|
void |
ManagementService.registerAddress(AddressInfo addressInfo) |
Modifier and Type | Method and Description |
---|---|
void |
ManagementServiceImpl.registerAddress(AddressInfo addressInfo) |
void |
ManagementServiceImpl.registerQueue(Queue queue,
AddressInfo addressInfo,
StorageManager storageManager) |
Modifier and Type | Method and Description |
---|---|
default void |
ActiveMQServerAddressPlugin.afterAddAddress(AddressInfo addressInfo,
boolean reload)
After an address has been added tot he broker
|
default void |
ActiveMQServerAddressPlugin.afterRemoveAddress(SimpleString address,
AddressInfo addressInfo)
After an address has been removed
|
default void |
ActiveMQServerAddressPlugin.afterUpdateAddress(AddressInfo addressInfo)
After an address has been updated
|
default void |
ActiveMQServerAddressPlugin.beforeAddAddress(AddressInfo addressInfo,
boolean reload)
Before an address is added tot he broker
|
Modifier and Type | Method and Description |
---|---|
void |
NotificationActiveMQServerPlugin.afterAddAddress(AddressInfo addressInfo,
boolean reload) |
void |
NotificationActiveMQServerPlugin.afterRemoveAddress(SimpleString address,
AddressInfo addressInfo) |
Copyright © 2020 JBoss by Red Hat. All rights reserved.