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,
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(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(SimpleString address,
AddressSettings settings) |
Modifier and Type | Method and Description |
---|---|
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,
Executor executor,
boolean syncNonTransactional) |
Constructor and Description |
---|
PagingManagerImpl(PagingStoreFactory pagingSPI,
HierarchicalRepository<AddressSettings> addressSettingsRepository) |
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 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,
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,
Executor executor) |
QueueFactoryImpl(ExecutorFactory executorFactory,
ScheduledExecutorService scheduledExecutor,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
StorageManager storageManager) |
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,
Executor executor) |
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,
Executor executor) |
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.setAutoCreateJmsQueues(boolean autoCreateJmsQueues) |
AddressSettings |
AddressSettings.setAutoCreateJmsTopics(boolean autoCreateJmsTopics) |
AddressSettings |
AddressSettings.setAutoDeleteJmsQueues(boolean autoDeleteJmsQueues) |
AddressSettings |
AddressSettings.setAutoDeleteJmsTopics(boolean autoDeleteJmsTopics) |
AddressSettings |
AddressSettings.setDeadLetterAddress(SimpleString deadLetterAddress) |
AddressSettings |
AddressSettings.setExpiryAddress(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) |
Modifier and Type | Method and Description |
---|---|
AddressSettings |
JMSServerManager.getAddressSettings(String address) |
Modifier and Type | Method and Description |
---|---|
void |
JMSServerManager.addAddressSettings(String address,
AddressSettings addressSettings) |
Modifier and Type | Method and Description |
---|---|
AddressSettings |
JMSServerManagerImpl.getAddressSettings(String address) |
Modifier and Type | Method and Description |
---|---|
void |
JMSServerManagerImpl.addAddressSettings(String address,
AddressSettings addressSettings) |
Copyright © 2016 The Apache Software Foundation. All rights reserved.