Modifier and Type | Method and Description |
---|---|
Map<String,AddressSettings> |
Configuration.getAddressesSettings() |
Modifier and Type | Method and Description |
---|---|
Configuration |
Configuration.addAddressesSetting(String key,
AddressSettings addressesSetting) |
Modifier and Type | Method and Description |
---|---|
Configuration |
Configuration.setAddressesSettings(Map<String,AddressSettings> addressesSettings) |
Modifier and Type | Method and Description |
---|---|
Map<String,AddressSettings> |
ConfigurationImpl.getAddressesSettings() |
Modifier and Type | Method and Description |
---|---|
ConfigurationImpl |
ConfigurationImpl.addAddressesSetting(String key,
AddressSettings addressesSetting) |
Modifier and Type | Method and Description |
---|---|
ConfigurationImpl |
ConfigurationImpl.setAddressesSettings(Map<String,AddressSettings> addressesSettings) |
Modifier and Type | Method and Description |
---|---|
protected Pair<String,AddressSettings> |
FileConfigurationParser.parseAddressSettings(Node node) |
Constructor and Description |
---|
QueueControlImpl(Queue queue,
String address,
ActiveMQServer server,
StorageManager storageManager,
SecurityStore securityStore,
HierarchicalRepository<AddressSettings> addressSettingsRepository) |
Modifier and Type | Method and Description |
---|---|
void |
PagingStore.applySetting(AddressSettings addressSettings) |
PageCursorProvider |
PagingStoreFactory.newCursorProvider(PagingStore store,
StorageManager storageManager,
AddressSettings addressSettings,
ArtemisExecutor executor) |
PagingStore |
PagingStoreFactory.newStore(SimpleString address,
AddressSettings addressSettings) |
Modifier and Type | Method and Description |
---|---|
List<PagingStore> |
PagingStoreFactory.reloadStores(HierarchicalRepository<AddressSettings> addressSettingsRepository) |
Modifier and Type | Method and Description |
---|---|
void |
PagingStoreImpl.applySetting(AddressSettings addressSettings) |
PageCursorProvider |
PagingStoreFactoryDatabase.newCursorProvider(PagingStore store,
StorageManager storageManager,
AddressSettings addressSettings,
ArtemisExecutor executor) |
PageCursorProvider |
PagingStoreFactoryNIO.newCursorProvider(PagingStore store,
StorageManager storageManager,
AddressSettings addressSettings,
ArtemisExecutor executor) |
PagingStore |
PagingStoreFactoryDatabase.newStore(SimpleString address,
AddressSettings settings) |
PagingStore |
PagingStoreFactoryNIO.newStore(SimpleString address,
AddressSettings settings) |
Modifier and Type | Method and Description |
---|---|
List<PagingStore> |
PagingStoreFactoryDatabase.reloadStores(HierarchicalRepository<AddressSettings> addressSettingsRepository) |
List<PagingStore> |
PagingStoreFactoryNIO.reloadStores(HierarchicalRepository<AddressSettings> addressSettingsRepository) |
Constructor and Description |
---|
PagingStoreImpl(SimpleString address,
ScheduledExecutorService scheduledExecutor,
long syncTimeout,
PagingManager pagingManager,
StorageManager storageManager,
SequentialFileFactory fileFactory,
PagingStoreFactory storeFactory,
SimpleString storeName,
AddressSettings addressSettings,
ArtemisExecutor executor,
ArtemisExecutor ioExecutor,
boolean syncNonTransactional) |
PagingStoreImpl(SimpleString address,
ScheduledExecutorService scheduledExecutor,
long syncTimeout,
PagingManager pagingManager,
StorageManager storageManager,
SequentialFileFactory fileFactory,
PagingStoreFactory storeFactory,
SimpleString storeName,
AddressSettings addressSettings,
ArtemisExecutor executor,
boolean syncNonTransactional) |
Constructor and Description |
---|
PagingManagerImpl(PagingStoreFactory pagingSPI,
HierarchicalRepository<AddressSettings> addressSettingsRepository) |
PagingManagerImpl(PagingStoreFactory pagingSPI,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
long maxSize,
SimpleString managementAddress) |
PagingManagerImpl(PagingStoreFactory pagingSPI,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
SimpleString managementAddress) |
Modifier and Type | Method and Description |
---|---|
AddressSettings |
PersistedAddressSetting.getSetting() |
Constructor and Description |
---|
PersistedAddressSetting(SimpleString addressMatch,
AddressSettings setting) |
Constructor and Description |
---|
PostOfficeImpl(ActiveMQServer server,
StorageManager storageManager,
PagingManager pagingManager,
QueueFactory bindableFactory,
ManagementService managementService,
long expiryReaperPeriod,
long addressQueueReaperPeriod,
WildcardConfiguration wildcardConfiguration,
int idCacheSize,
boolean persistIDCache,
HierarchicalRepository<AddressSettings> addressSettingsRepository) |
Modifier and Type | Method and Description |
---|---|
HierarchicalRepository<AddressSettings> |
ActiveMQServer.getAddressSettingsRepository() |
Modifier and Type | Field and Description |
---|---|
protected HierarchicalRepository<AddressSettings> |
QueueFactoryImpl.addressSettingsRepository |
Modifier and Type | Method and Description |
---|---|
HierarchicalRepository<AddressSettings> |
ActiveMQServerImpl.getAddressSettingsRepository() |
Constructor and Description |
---|
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 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) |
QueueFactoryImpl(ExecutorFactory executorFactory,
ScheduledExecutorService scheduledExecutor,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
StorageManager storageManager,
ActiveMQServer server) |
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 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) |
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 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) |
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) |
QueueImpl(long id,
SimpleString address,
SimpleString name,
Filter filter,
PageSubscription pageSubscription,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated,
ScheduledExecutorService scheduledExecutor,
PostOffice postOffice,
StorageManager storageManager,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
ArtemisExecutor executor,
ActiveMQServer server,
QueueFactory factory) |
QueueImpl(long id,
SimpleString address,
SimpleString name,
Filter filter,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated,
ScheduledExecutorService scheduledExecutor,
PostOffice postOffice,
StorageManager storageManager,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
ArtemisExecutor executor,
ActiveMQServer server,
QueueFactory factory) |
Modifier and Type | Method and Description |
---|---|
ActiveMQServerControlImpl |
ManagementService.registerServer(PostOffice postOffice,
SecurityStore securityStore,
StorageManager storageManager,
Configuration configuration,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
HierarchicalRepository<Set<Role>> securityRepository,
ResourceManager resourceManager,
RemotingService remotingService,
ActiveMQServer messagingServer,
QueueFactory queueFactory,
ScheduledExecutorService scheduledThreadPool,
PagingManager pagingManager,
boolean backup) |
Modifier and Type | Method and Description |
---|---|
ActiveMQServerControlImpl |
ManagementServiceImpl.registerServer(PostOffice postOffice,
SecurityStore securityStore,
StorageManager storageManager1,
Configuration configuration,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
HierarchicalRepository<Set<Role>> securityRepository,
ResourceManager resourceManager,
RemotingService remotingService,
ActiveMQServer messagingServer,
QueueFactory queueFactory,
ScheduledExecutorService scheduledThreadPool,
PagingManager pagingManager,
boolean backup) |
Modifier and Type | Method and Description |
---|---|
AddressSettings |
AddressSettings.setAddressFullMessagePolicy(AddressFullMessagePolicy addressFullMessagePolicy) |
AddressSettings |
AddressSettings.setAutoCreateAddresses(Boolean autoCreateAddresses) |
AddressSettings |
AddressSettings.setAutoCreateJmsQueues(boolean autoCreateJmsQueues)
Deprecated.
|
AddressSettings |
AddressSettings.setAutoCreateJmsTopics(boolean autoCreateJmsTopics)
Deprecated.
|
AddressSettings |
AddressSettings.setAutoCreateQueues(Boolean autoCreateQueues) |
AddressSettings |
AddressSettings.setAutoDeleteAddresses(Boolean autoDeleteAddresses) |
AddressSettings |
AddressSettings.setAutoDeleteAddressesDelay(long autoDeleteAddressesDelay) |
AddressSettings |
AddressSettings.setAutoDeleteCreatedQueues(Boolean autoDeleteCreatedQueues) |
AddressSettings |
AddressSettings.setAutoDeleteJmsQueues(boolean autoDeleteJmsQueues)
Deprecated.
|
AddressSettings |
AddressSettings.setAutoDeleteJmsTopics(boolean autoDeleteJmsTopics)
Deprecated.
|
AddressSettings |
AddressSettings.setAutoDeleteQueues(Boolean autoDeleteQueues) |
AddressSettings |
AddressSettings.setAutoDeleteQueuesDelay(long autoDeleteQueuesDelay) |
AddressSettings |
AddressSettings.setAutoDeleteQueuesMessageCount(long autoDeleteQueuesMessageCount) |
AddressSettings |
AddressSettings.setConfigDeleteAddresses(DeletionPolicy configDeleteAddresses) |
AddressSettings |
AddressSettings.setConfigDeleteQueues(DeletionPolicy configDeleteQueues) |
AddressSettings |
AddressSettings.setDeadLetterAddress(SimpleString deadLetterAddress) |
AddressSettings |
AddressSettings.setDefaultAddressRoutingType(RoutingType defaultAddressRoutingType) |
AddressSettings |
AddressSettings.setDefaultConsumersBeforeDispatch(Integer defaultConsumersBeforeDispatch) |
AddressSettings |
AddressSettings.setDefaultConsumerWindowSize(int defaultConsumerWindowSize) |
AddressSettings |
AddressSettings.setDefaultDelayBeforeDispatch(Long defaultDelayBeforeDispatch) |
AddressSettings |
AddressSettings.setDefaultExclusiveQueue(Boolean defaultExclusiveQueue) |
AddressSettings |
AddressSettings.setDefaultGroupBuckets(int defaultGroupBuckets) |
AddressSettings |
AddressSettings.setDefaultGroupFirstKey(SimpleString defaultGroupFirstKey) |
AddressSettings |
AddressSettings.setDefaultGroupRebalance(boolean defaultGroupRebalance) |
AddressSettings |
AddressSettings.setDefaultLastValueKey(SimpleString defaultLastValueKey) |
AddressSettings |
AddressSettings.setDefaultLastValueQueue(boolean defaultLastValueQueue) |
AddressSettings |
AddressSettings.setDefaultMaxConsumers(Integer defaultMaxConsumers) |
AddressSettings |
AddressSettings.setDefaultNonDestructive(boolean defaultNonDestructive) |
AddressSettings |
AddressSettings.setDefaultPurgeOnNoConsumers(Boolean defaultPurgeOnNoConsumers) |
AddressSettings |
AddressSettings.setDefaultQueueRoutingType(RoutingType defaultQueueRoutingType) |
AddressSettings |
AddressSettings.setExpiryAddress(SimpleString expiryAddress) |
AddressSettings |
AddressSettings.setExpiryDelay(Long expiryDelay) |
AddressSettings |
AddressSettings.setManagementBrowsePageSize(int managementBrowsePageSize) |
AddressSettings |
AddressSettings.setMaxDeliveryAttempts(int maxDeliveryAttempts) |
AddressSettings |
AddressSettings.setMaxRedeliveryDelay(long maxRedeliveryDelay) |
AddressSettings |
AddressSettings.setMaxSizeBytes(long maxSizeBytes) |
AddressSettings |
AddressSettings.setMaxSizeBytesRejectThreshold(long maxSizeBytesRejectThreshold) |
AddressSettings |
AddressSettings.setMessageCounterHistoryDayLimit(int messageCounterHistoryDayLimit) |
AddressSettings |
AddressSettings.setPageCacheMaxSize(int pageMaxCache) |
AddressSettings |
AddressSettings.setPageSizeBytes(long pageSize) |
AddressSettings |
AddressSettings.setQueuePrefetch(int queuePrefetch) |
AddressSettings |
AddressSettings.setRedeliveryDelay(long redeliveryDelay) |
AddressSettings |
AddressSettings.setRedeliveryMultiplier(double redeliveryMultiplier) |
AddressSettings |
AddressSettings.setRedistributionDelay(long redistributionDelay) |
AddressSettings |
AddressSettings.setSendToDLAOnNoRoute(boolean value) |
AddressSettings |
AddressSettings.setSlowConsumerCheckPeriod(long slowConsumerCheckPeriod) |
AddressSettings |
AddressSettings.setSlowConsumerPolicy(SlowConsumerPolicy slowConsumerPolicy) |
AddressSettings |
AddressSettings.setSlowConsumerThreshold(long slowConsumerThreshold) |
Modifier and Type | Method and Description |
---|---|
void |
AddressSettings.merge(AddressSettings merged)
merge 2 objects in to 1
|
Constructor and Description |
---|
AddressSettings(AddressSettings other) |
Modifier and Type | Method and Description |
---|---|
AddressSettings |
JMSServerManager.getAddressSettings(String address)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
JMSServerManager.addAddressSettings(String address,
AddressSettings addressSettings)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
AddressSettings |
JMSServerManagerImpl.getAddressSettings(String address)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
JMSServerManagerImpl.addAddressSettings(String address,
AddressSettings addressSettings)
Deprecated.
|
Copyright © 2019 JBoss by Red Hat. All rights reserved.