| 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 org.apache.activemq.artemis.api.core.Pair<String,AddressSettings> |
FileConfigurationParser.parseAddressSettings(Node node) |
| Constructor and Description |
|---|
QueueControlImpl(Queue queue,
String address,
PostOffice postOffice,
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,
Executor executor) |
PagingStore |
PagingStoreFactory.newStore(org.apache.activemq.artemis.api.core.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 |
PagingStoreFactoryNIO.newCursorProvider(PagingStore store,
StorageManager storageManager,
AddressSettings addressSettings,
Executor executor) |
PagingStore |
PagingStoreFactoryNIO.newStore(org.apache.activemq.artemis.api.core.SimpleString address,
AddressSettings settings) |
| Modifier and Type | Method and Description |
|---|---|
List<PagingStore> |
PagingStoreFactoryNIO.reloadStores(HierarchicalRepository<AddressSettings> addressSettingsRepository) |
| Constructor and Description |
|---|
PagingStoreImpl(org.apache.activemq.artemis.api.core.SimpleString address,
ScheduledExecutorService scheduledExecutor,
long syncTimeout,
PagingManager pagingManager,
StorageManager storageManager,
org.apache.activemq.artemis.core.io.SequentialFileFactory fileFactory,
PagingStoreFactory storeFactory,
org.apache.activemq.artemis.api.core.SimpleString storeName,
AddressSettings addressSettings,
Executor executor,
boolean syncNonTransactional) |
| Constructor and Description |
|---|
PagingManagerImpl(PagingStoreFactory pagingSPI,
HierarchicalRepository<AddressSettings> addressSettingsRepository) |
PagingManagerImpl(PagingStoreFactory pagingSPI,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
long maxSize) |
| Modifier and Type | Method and Description |
|---|---|
AddressSettings |
PersistedAddressSetting.getSetting() |
| Constructor and Description |
|---|
PersistedAddressSetting(org.apache.activemq.artemis.api.core.SimpleString addressMatch,
AddressSettings setting) |
| Constructor and Description |
|---|
PostOfficeImpl(ActiveMQServer server,
StorageManager storageManager,
PagingManager pagingManager,
QueueFactory bindableFactory,
ManagementService managementService,
long reaperPeriod,
int reaperPriority,
boolean enableWildCardRouting,
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,
org.apache.activemq.artemis.api.core.SimpleString address,
org.apache.activemq.artemis.api.core.SimpleString name,
Filter filter,
PageSubscription pageSubscription,
org.apache.activemq.artemis.api.core.SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated,
ScheduledExecutorService scheduledExecutor,
PostOffice postOffice,
StorageManager storageManager,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
Executor executor) |
QueueFactoryImpl(org.apache.activemq.artemis.utils.ExecutorFactory executorFactory,
ScheduledExecutorService scheduledExecutor,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
StorageManager storageManager) |
QueueImpl(long id,
org.apache.activemq.artemis.api.core.SimpleString address,
org.apache.activemq.artemis.api.core.SimpleString name,
Filter filter,
PageSubscription pageSubscription,
org.apache.activemq.artemis.api.core.SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated,
ScheduledExecutorService scheduledExecutor,
PostOffice postOffice,
StorageManager storageManager,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
Executor executor) |
QueueImpl(long id,
org.apache.activemq.artemis.api.core.SimpleString address,
org.apache.activemq.artemis.api.core.SimpleString name,
Filter filter,
org.apache.activemq.artemis.api.core.SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated,
ScheduledExecutorService scheduledExecutor,
PostOffice postOffice,
StorageManager storageManager,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
Executor executor) |
| Modifier and Type | Method and Description |
|---|---|
ActiveMQServerControlImpl |
ManagementService.registerServer(PostOffice postOffice,
SecurityStore securityStore,
StorageManager storageManager,
Configuration configuration,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
HierarchicalRepository<Set<org.apache.activemq.artemis.core.security.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<org.apache.activemq.artemis.core.security.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(org.apache.activemq.artemis.core.settings.impl.AddressFullMessagePolicy addressFullMessagePolicy) |
AddressSettings |
AddressSettings.setAutoCreateJmsQueues(boolean autoCreateJmsQueues) |
AddressSettings |
AddressSettings.setAutoCreateJmsTopics(boolean autoCreateJmsTopics) |
AddressSettings |
AddressSettings.setAutoDeleteJmsQueues(boolean autoDeleteJmsQueues) |
AddressSettings |
AddressSettings.setAutoDeleteJmsTopics(boolean autoDeleteJmsTopics) |
AddressSettings |
AddressSettings.setDeadLetterAddress(org.apache.activemq.artemis.api.core.SimpleString deadLetterAddress) |
AddressSettings |
AddressSettings.setExpiryAddress(org.apache.activemq.artemis.api.core.SimpleString expiryAddress) |
AddressSettings |
AddressSettings.setExpiryDelay(Long expiryDelay) |
AddressSettings |
AddressSettings.setLastValueQueue(boolean lastValueQueue) |
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) |
Copyright © 2023 The Apache Software Foundation. All rights reserved.