public class ConfigurationImpl extends Object implements Configuration, Serializable
Constructor and Description |
---|
ConfigurationImpl() |
Modifier and Type | Method and Description |
---|---|
ConfigurationImpl |
addAcceptorConfiguration(String name,
String uri)
Add an acceptor to the config
|
ConfigurationImpl |
addAcceptorConfiguration(TransportConfiguration infos) |
Configuration |
addAddressConfiguration(CoreAddressConfiguration config)
Adds an addresses configuration
|
ConfigurationImpl |
addAddressesSetting(String key,
AddressSettings addressesSetting) |
ConfigurationImpl |
addBridgeConfiguration(BridgeConfiguration config) |
ConfigurationImpl |
addBroadcastGroupConfiguration(BroadcastGroupConfiguration config) |
ConfigurationImpl |
addClusterConfiguration(ClusterConnectionConfiguration config) |
ClusterConnectionConfiguration |
addClusterConfiguration(String name,
String uri) |
ConfigurationImpl |
addConnectorConfiguration(String name,
String uri) |
ConfigurationImpl |
addConnectorConfiguration(String key,
TransportConfiguration info) |
ConfigurationImpl |
addConnectorServiceConfiguration(ConnectorServiceConfiguration config) |
ConfigurationImpl |
addDiscoveryGroupConfiguration(String key,
DiscoveryGroupConfiguration discoveryGroupConfiguration) |
ConfigurationImpl |
addDivertConfiguration(DivertConfiguration config) |
ConfigurationImpl |
addQueueConfiguration(CoreQueueConfiguration config) |
ConfigurationImpl |
addResourceLimitSettings(ResourceLimitSettings resourceLimitSettings) |
Configuration |
addSecurityRoleNameMapping(String internalRole,
Set<String> externalRoles) |
ConfigurationImpl |
addSecuritySettingPlugin(SecuritySettingPlugin plugin) |
static boolean |
checkoutDupCacheSize(int windowSize,
int idCacheSize) |
ConfigurationImpl |
clearAcceptorConfigurations() |
ConfigurationImpl |
clearAddressesSettings() |
ConfigurationImpl |
clearClusterConfigurations() |
ConfigurationImpl |
clearConnectorConfigurations() |
Configuration |
copy() |
String |
debugConnectors()
It will return all the connectors in a toString manner for debug purposes.
|
boolean |
equals(Object obj) |
Set<TransportConfiguration> |
getAcceptorConfigurations()
Returns the acceptors configured for this server.
|
List<CoreAddressConfiguration> |
getAddressConfigurations()
Returns the addresses configured for this server.
|
Map<String,AddressSettings> |
getAddressesSettings() |
String |
getBindingsDirectory()
Returns the file system directory used to store bindings.
|
File |
getBindingsLocation()
The binding location related to artemis.instance.
|
List<BridgeConfiguration> |
getBridgeConfigurations()
Returns the bridges configured for this server.
|
List<BroadcastGroupConfiguration> |
getBroadcastGroupConfigurations()
Returns the broadcast groups configured for this server.
|
File |
getBrokerInstance()
Set the Artemis instance relative folder for data and stuff.
|
List<ActiveMQServerPlugin> |
getBrokerPlugins() |
List<ClusterConnectionConfiguration> |
getClusterConfigurations()
Returns the cluster connections configured for this server.
|
String |
getClusterPassword()
Returns the cluster password for this server.
|
String |
getClusterUser()
Returns the cluster user for this server.
|
long |
getConfigurationFileRefreshPeriod() |
URL |
getConfigurationUrl() |
long |
getConnectionTtlCheckInterval() |
long |
getConnectionTTLOverride()
Returns the connection time to live.
|
Map<String,TransportConfiguration> |
getConnectorConfigurations()
Returns the connectors configured for this server.
|
List<ConnectorServiceConfiguration> |
getConnectorServiceConfigurations() |
long |
getCriticalAnalyzerCheckPeriod() |
CriticalAnalyzerPolicy |
getCriticalAnalyzerPolicy() |
long |
getCriticalAnalyzerTimeout() |
Map<String,DiscoveryGroupConfiguration> |
getDiscoveryGroupConfigurations()
Returns the discovery groups configured for this server.
|
int |
getDiskScanPeriod() |
List<DivertConfiguration> |
getDivertConfigurations()
Returns the diverts configured for this server.
|
long |
getFileDeployerScanPeriod()
Returns the period (in milliseconds) to scan configuration files used by deployment.
|
long |
getGlobalMaxSize() |
long |
getGracefulShutdownTimeout()
Returns the graceful shutdown timeout for this server.
|
GroupingHandlerConfiguration |
getGroupingHandlerConfiguration()
Returns the grouping handler configured for this server.
|
HAPolicyConfiguration |
getHAPolicyConfiguration() |
int |
getIDCacheSize()
Returns the size of the cache for pre-creating message IDs.
|
List<String> |
getIncomingInterceptorClassNames()
Returns the list of interceptors classes used by this server for incoming messages (i.e.
|
String |
getInternalNamingPrefix() |
String |
getJMXDomain()
Returns the domain used by JMX MBeans (provided JMX management is enabled).
|
int |
getJournalBufferSize_AIO()
Returns the buffer size (in bytes) for AIO.
|
int |
getJournalBufferSize_NIO()
Returns the buffer size (in bytes) for NIO.
|
int |
getJournalBufferTimeout_AIO()
Returns the timeout (in nanoseconds) used to flush buffers in the AIO queue.
|
int |
getJournalBufferTimeout_NIO()
Returns the timeout (in nanoseconds) used to flush buffers in the NIO.
|
int |
getJournalCompactMinFiles()
Returns the minimal number of journal files before compacting.
|
int |
getJournalCompactPercentage()
Returns the percentage of live data before compacting the journal.
|
String |
getJournalDirectory()
Returns the file system directory used to store journal log.
|
int |
getJournalFileOpenTimeout() |
int |
getJournalFileSize()
Returns the size (in bytes) of each journal files.
|
File |
getJournalLocation()
The location of the journal related to artemis.instance.
|
long |
getJournalLockAcquisitionTimeout() |
int |
getJournalMaxIO_AIO()
Returns the maximum number of write requests that can be in the AIO queue at any given time.
|
int |
getJournalMaxIO_NIO()
Returns the maximum number of write requests for NIO journal.
|
int |
getJournalMinFiles()
Returns the number of journal files to pre-create.
|
int |
getJournalPoolFiles()
Number of files that would be acceptable to keep on a pool.
|
JournalType |
getJournalType()
Returns the type of journal used by this server (
NIO , ASYNCIO or MAPPED ). |
String |
getLargeMessagesDirectory()
Returns the file system directory used to store large messages.
|
File |
getLargeMessagesLocation()
The large message location related to artemis.instance
|
SimpleString |
getManagementAddress()
Returns the management address of this server.
|
SimpleString |
getManagementNotificationAddress()
Returns the management notification address of this server.
|
int |
getMaxDiskUsage() |
long |
getMemoryMeasureInterval() |
int |
getMemoryWarningThreshold() |
int |
getMessageCounterMaxDayHistory()
Returns the maximum number of days kept in memory for message counter.
|
long |
getMessageCounterSamplePeriod()
Returns the sample period (in milliseconds) to take message counter snapshot.
|
long |
getMessageExpiryScanPeriod()
Returns the frequency (in milliseconds) to scan messages to detect which messages have
expired.
|
int |
getMessageExpiryThreadPriority()
Returns the priority of the thread used to scan message expiration.
|
String |
getName()
To be used on dependency management on the application server
|
String |
getNetworkCheckList() |
String |
getNetworkCheckNIC() |
long |
getNetworkCheckPeriod() |
String |
getNetworkCheckPing6Command() |
String |
getNetworkCheckPingCommand() |
int |
getNetworkCheckTimeout() |
String |
getNetworkCheckURLList() |
List<String> |
getOutgoingInterceptorClassNames()
Returns the list of interceptors classes used by this server for outgoing messages (i.e.
|
int |
getPageMaxConcurrentIO()
The max number of concurrent reads allowed on paging.
|
String |
getPagingDirectory()
Returns the file system directory used to store paging files.
|
File |
getPagingLocation()
The paging location related to artemis.instance
|
String |
getPasswordCodec()
Gets the default password decoder
|
List<CoreQueueConfiguration> |
getQueueConfigurations()
Returns the queues configured for this server.
|
Map<String,ResourceLimitSettings> |
getResourceLimitSettings() |
int |
getScheduledThreadPoolMaxSize()
Returns the maximum number of threads in the scheduled thread pool of this server.
|
long |
getSecurityInvalidationInterval()
Returns the interval time (in milliseconds) to invalidate security credentials.
|
Map<String,Set<String>> |
getSecurityRoleNameMappings() |
Map<String,Set<Role>> |
getSecurityRoles() |
List<SecuritySettingPlugin> |
getSecuritySettingPlugins() |
long |
getServerDumpInterval() |
StoreConfiguration |
getStoreConfiguration() |
String |
getSystemPropertyPrefix()
See doc at
Configuration.setSystemPropertyPrefix(String) . |
int |
getThreadPoolMaxSize()
Returns the maximum number of threads in the thread pool of this server.
|
long |
getTransactionTimeout()
Returns the timeout (in milliseconds) after which transactions is removed from the resource
manager after it was created.
|
long |
getTransactionTimeoutScanPeriod()
Returns the frequency (in milliseconds) to scan transactions to detect which transactions have
timed out.
|
TransportConfiguration[] |
getTransportConfigurations(List<String> connectorNames) |
TransportConfiguration[] |
getTransportConfigurations(String... connectorNames) |
WildcardConfiguration |
getWildcardConfiguration() |
int |
hashCode() |
boolean |
isAmqpUseCoreSubscriptionNaming()
Returns if to use Core subscription naming for AMQP.
|
boolean |
isAsyncConnectionExecutionEnabled()
Returns whether code coming from connection is executed asynchronously or not.
|
boolean |
isCheckForLiveServer() |
boolean |
isClustered()
Returns whether this server is clustered.
|
boolean |
isCreateBindingsDir()
Returns whether the bindings directory is created on this server startup.
|
boolean |
isCreateJournalDir()
Returns whether the journal directory is created on this server startup.
|
boolean |
isCriticalAnalyzer() |
boolean |
isFailoverOnServerShutdown() |
boolean |
isGracefulShutdownEnabled()
Returns whether graceful shutdown is enabled for this server.
|
boolean |
isJMXManagementEnabled()
Returns whether this server is manageable using JMX or not.
|
boolean |
isJMXUseBrokerName()
whether or not to use the broker name in the JMX tree
|
boolean |
isJournalDatasync()
Should use fdatasync on journal files.
|
boolean |
isJournalSyncNonTransactional()
Returns whether the journal is synchronized when receiving non-transactional data.
|
boolean |
isJournalSyncTransactional()
Returns whether the journal is synchronized when receiving transactional data.
|
boolean |
isLogJournalWriteRate() |
Boolean |
isMaskPassword()
If passwords are masked.
|
boolean |
isMessageCounterEnabled()
Returns whether message counter is enabled for this server.
|
boolean |
isPersistDeliveryCountBeforeDelivery()
Returns whether delivery count is persisted before messages are delivered to the consumers.
|
boolean |
isPersistenceEnabled()
Returns whether this server is using persistence and store data.
|
boolean |
isPersistIDCache()
Returns whether message ID cache is persisted.
|
boolean |
isPopulateValidatedUser() |
boolean |
isResolveProtocols() |
boolean |
isSecurityEnabled()
Returns whether security is enabled for this server.
|
boolean |
isWildcardRoutingEnabled()
Deprecated.
|
Configuration |
parseSystemProperties() |
Configuration |
parseSystemProperties(Properties properties) |
ConfigurationImpl |
putSecurityRoles(String match,
Set<Role> roles) |
void |
registerBrokerPlugin(ActiveMQServerPlugin plugin) |
void |
registerBrokerPlugins(List<ActiveMQServerPlugin> plugins) |
ConfigurationImpl |
setAcceptorConfigurations(Set<TransportConfiguration> infos)
Sets the acceptors configured for this server.
|
Configuration |
setAddressConfigurations(List<CoreAddressConfiguration> configs)
Sets the addresses configured for this server.
|
ConfigurationImpl |
setAddressesSettings(Map<String,AddressSettings> addressesSettings) |
Configuration |
setAmqpUseCoreSubscriptionNaming(boolean amqpUseCoreSubscriptionNaming)
Sets if to use Core subscription naming for AMQP.
|
ConfigurationImpl |
setBindingsDirectory(String dir)
Sets the file system directory used to store bindings.
|
ConfigurationImpl |
setBridgeConfigurations(List<BridgeConfiguration> configs)
Sets the bridges configured for this server.
|
ConfigurationImpl |
setBroadcastGroupConfigurations(List<BroadcastGroupConfiguration> configs)
Sets the broadcast groups configured for this server.
|
void |
setBrokerInstance(File directory)
Set the Artemis instance relative folder for data and stuff.
|
ConfigurationImpl |
setCheckForLiveServer(boolean checkForLiveServer) |
ConfigurationImpl |
setClusterConfigurations(List<ClusterConnectionConfiguration> configs)
Sets the cluster connections configured for this server.
|
ConfigurationImpl |
setClusterPassword(String theclusterPassword)
Sets the cluster password for this server.
|
ConfigurationImpl |
setClusterUser(String user)
Sets the cluster user for this server.
|
ConfigurationImpl |
setConfigurationFileRefreshPeriod(long configurationFileRefreshPeriod) |
ConfigurationImpl |
setConfigurationUrl(URL configurationUrl) |
ConfigurationImpl |
setConnectionTtlCheckInterval(long connectionTtlCheckInterval) |
ConfigurationImpl |
setConnectionTTLOverride(long ttl)
Sets the connection time to live.
|
ConfigurationImpl |
setConnectorConfigurations(Map<String,TransportConfiguration> infos)
Sets the connectors configured for this server.
|
ConfigurationImpl |
setConnectorServiceConfigurations(List<ConnectorServiceConfiguration> configs) |
ConfigurationImpl |
setCreateBindingsDir(boolean create)
Sets whether the bindings directory is created on this server startup.
|
ConfigurationImpl |
setCreateJournalDir(boolean create)
Sets whether the journal directory is created on this server startup.
|
Configuration |
setCriticalAnalyzer(boolean CriticalAnalyzer) |
Configuration |
setCriticalAnalyzerCheckPeriod(long checkPeriod) |
Configuration |
setCriticalAnalyzerPolicy(CriticalAnalyzerPolicy policy) |
Configuration |
setCriticalAnalyzerTimeout(long timeout) |
ConfigurationImpl |
setDiscoveryGroupConfigurations(Map<String,DiscoveryGroupConfiguration> discoveryGroupConfigurations)
Sets the discovery groups configured for this server.
|
ConfigurationImpl |
setDiskScanPeriod(int diskScanPeriod) |
ConfigurationImpl |
setDivertConfigurations(List<DivertConfiguration> configs)
Sets the diverts configured for this server.
|
ConfigurationImpl |
setEnabledAsyncConnectionExecution(boolean enabled)
Sets whether code coming from connection is executed asynchronously or not.
|
ConfigurationImpl |
setFailoverOnServerShutdown(boolean failoverOnServerShutdown) |
ConfigurationImpl |
setFileDeployerScanPeriod(long period)
Sets the period to scan configuration files used by deployment.
|
ConfigurationImpl |
setGlobalMaxSize(long maxSize) |
ConfigurationImpl |
setGracefulShutdownEnabled(boolean enabled)
Sets whether security is enabled for this server.
|
ConfigurationImpl |
setGracefulShutdownTimeout(long timeout)
Sets the graceful shutdown timeout
|
ConfigurationImpl |
setGroupingHandlerConfiguration(GroupingHandlerConfiguration groupingHandlerConfiguration)
Sets the grouping handler configured for this server.
|
ConfigurationImpl |
setHAPolicyConfiguration(HAPolicyConfiguration haPolicyConfiguration) |
ConfigurationImpl |
setIDCacheSize(int idCacheSize)
Sets the size of the cache for pre-creating message IDs.
|
ConfigurationImpl |
setIncomingInterceptorClassNames(List<String> interceptors)
Sets the list of interceptors classes used by this server for incoming messages (i.e.
|
ConfigurationImpl |
setInternalNamingPrefix(String internalNamingPrefix) |
ConfigurationImpl |
setJMXDomain(String domain)
Sets the domain used by JMX MBeans (provided JMX management is enabled).
|
ConfigurationImpl |
setJMXManagementEnabled(boolean enabled)
Sets whether this server is manageable using JMX or not.
|
ConfigurationImpl |
setJMXUseBrokerName(boolean jmxUseBrokerName)
whether or not to use the broker name in the JMX tree
|
ConfigurationImpl |
setJournalBufferSize_AIO(int journalBufferSize)
Sets the buffer size (in bytes) for AIO.
|
ConfigurationImpl |
setJournalBufferSize_NIO(int journalBufferSize)
Sets the buffer size (in bytes) for NIO.
|
ConfigurationImpl |
setJournalBufferTimeout_AIO(int journalBufferTimeout)
Sets the timeout (in nanoseconds) used to flush buffers in the AIO queue.
|
ConfigurationImpl |
setJournalBufferTimeout_NIO(int journalBufferTimeout)
Sets the timeout (in nanoseconds) used to flush buffers in the NIO.
|
ConfigurationImpl |
setJournalCompactMinFiles(int minFiles)
Sets the minimal number of journal files before compacting.
|
ConfigurationImpl |
setJournalCompactPercentage(int percentage)
Sets the percentage of live data before compacting the journal.
|
ConfigurationImpl |
setJournalDatasync(boolean enable)
documented at
Configuration.isJournalDatasync() ()} |
ConfigurationImpl |
setJournalDirectory(String dir)
Sets the file system directory used to store journal log.
|
Configuration |
setJournalFileOpenTimeout(int journalFileOpenTimeout)
Sets the journal file open timeout
|
ConfigurationImpl |
setJournalFileSize(int size)
Sets the size (in bytes) of each journal files.
|
ConfigurationImpl |
setJournalLockAcquisitionTimeout(long journalLockAcquisitionTimeout) |
ConfigurationImpl |
setJournalMaxIO_AIO(int journalMaxIO)
Sets the maximum number of write requests that can be in the AIO queue at any given time.
|
ConfigurationImpl |
setJournalMaxIO_NIO(int journalMaxIO)
Sets the maximum number of write requests for NIO journal.
|
ConfigurationImpl |
setJournalMinFiles(int files)
Sets the number of journal files to pre-create.
|
Configuration |
setJournalPoolFiles(int poolSize)
Number of files that would be acceptable to keep on a pool.
|
ConfigurationImpl |
setJournalSyncNonTransactional(boolean sync)
Sets whether the journal is synchronized when receiving non-transactional data.
|
ConfigurationImpl |
setJournalSyncTransactional(boolean sync)
Sets whether the journal is synchronized when receiving transactional data.
|
ConfigurationImpl |
setJournalType(JournalType type)
Sets the type of journal used by this server (either
NIO or ASYNCIO ). |
ConfigurationImpl |
setLargeMessagesDirectory(String directory)
Sets the file system directory used to store large messages.
|
ConfigurationImpl |
setLogJournalWriteRate(boolean logJournalWriteRate) |
ConfigurationImpl |
setManagementAddress(SimpleString address)
Sets the management address of this server.
|
ConfigurationImpl |
setManagementNotificationAddress(SimpleString address)
Sets the management notification address of this server.
|
ConfigurationImpl |
setMaskPassword(Boolean maskPassword)
Sets if passwords should be masked or not.
|
ConfigurationImpl |
setMaxDiskUsage(int maxDiskUsage) |
ConfigurationImpl |
setMemoryMeasureInterval(long memoryMeasureInterval) |
ConfigurationImpl |
setMemoryWarningThreshold(int memoryWarningThreshold) |
ConfigurationImpl |
setMessageCounterEnabled(boolean enabled)
Sets whether message counter is enabled for this server.
|
ConfigurationImpl |
setMessageCounterMaxDayHistory(int maxDayHistory)
Sets the maximum number of days kept in memory for message counter.
|
ConfigurationImpl |
setMessageCounterSamplePeriod(long period)
Sets the sample period to take message counter snapshot.
|
ConfigurationImpl |
setMessageExpiryScanPeriod(long messageExpiryScanPeriod)
Sets the frequency (in milliseconds) to scan messages to detect which messages
have expired.
|
ConfigurationImpl |
setMessageExpiryThreadPriority(int messageExpiryThreadPriority)
Sets the priority of the thread used to scan message expiration.
|
ConfigurationImpl |
setName(String name)
To be used on dependency management on the application server
|
Configuration |
setNetworCheckNIC(String nic)
The NIC name to be used on network checks
|
ConfigurationImpl |
setNetworkCheckList(String list)
A comma separated list of IPs we could use to validate if the network is UP.
|
ConfigurationImpl |
setNetworkCheckPeriod(long period)
The interval on which we will perform network checks.
|
Configuration |
setNetworkCheckPing6Command(String command) |
ConfigurationImpl |
setNetworkCheckPingCommand(String command) |
ConfigurationImpl |
setNetworkCheckTimeout(int timeout)
Time in ms for how long we should wait for a ping to finish.
|
ConfigurationImpl |
setNetworkCheckURLList(String urls)
A comma separated list of URIs we could use to validate if the network is UP.
|
ConfigurationImpl |
setOutgoingInterceptorClassNames(List<String> interceptors)
Sets the list of interceptors classes used by this server for outgoing messages (i.e.
|
ConfigurationImpl |
setPageMaxConcurrentIO(int maxIO)
The max number of concurrent reads allowed on paging.
|
ConfigurationImpl |
setPagingDirectory(String dir)
Sets the file system directory used to store paging files.
|
ConfigurationImpl |
setPasswordCodec(String codec)
The default password decoder
|
ConfigurationImpl |
setPersistDeliveryCountBeforeDelivery(boolean persistDeliveryCountBeforeDelivery)
Sets whether delivery count is persisted before messages are delivered to consumers.
|
ConfigurationImpl |
setPersistenceEnabled(boolean enable)
Sets whether this server is using persistence and store data.
|
ConfigurationImpl |
setPersistIDCache(boolean persist)
Sets whether message ID cache is persisted.
|
ConfigurationImpl |
setPopulateValidatedUser(boolean populateValidatedUser) |
ConfigurationImpl |
setQueueConfigurations(List<CoreQueueConfiguration> configs)
Sets the queues configured for this server.
|
ConfigurationImpl |
setResolveProtocols(boolean resolveProtocols) |
ConfigurationImpl |
setResourceLimitSettings(Map<String,ResourceLimitSettings> resourceLimitSettings) |
ConfigurationImpl |
setScheduledThreadPoolMaxSize(int maxSize)
Sets the maximum number of threads in the scheduled thread pool of this server.
|
ConfigurationImpl |
setSecurityEnabled(boolean enabled)
Sets whether security is enabled for this server.
|
ConfigurationImpl |
setSecurityInvalidationInterval(long interval)
Sets the interval time (in milliseconds) to invalidate security credentials.
|
ConfigurationImpl |
setSecurityRoles(Map<String,Set<Role>> securitySettings) |
ConfigurationImpl |
setSecuritySettingPlugins(List<SecuritySettingPlugin> plugins) |
ConfigurationImpl |
setServerDumpInterval(long intervalInMilliseconds) |
ConfigurationImpl |
setStoreConfiguration(StoreConfiguration storeConfiguration) |
Configuration |
setSystemPropertyPrefix(String systemPropertyPrefix)
We use Bean-utils to pass in System.properties that start with
Configuration.setSystemPropertyPrefix(String) . |
ConfigurationImpl |
setThreadPoolMaxSize(int maxSize)
Sets the maximum number of threads in the thread pool of this server.
|
ConfigurationImpl |
setTransactionTimeout(long timeout)
Sets the timeout (in milliseconds) after which transactions is removed
from the resource manager after it was created.
|
ConfigurationImpl |
setTransactionTimeoutScanPeriod(long period)
Sets the frequency (in milliseconds) to scan transactions to detect which transactions
have timed out.
|
Configuration |
setWildCardConfiguration(WildcardConfiguration wildcardConfiguration) |
ConfigurationImpl |
setWildcardRoutingEnabled(boolean enabled)
Deprecated.
|
String |
toString() |
void |
unRegisterBrokerPlugin(ActiveMQServerPlugin plugin) |
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
isJDBC
public static final JournalType DEFAULT_JOURNAL_TYPE
protected long fileDeploymentScanPeriod
protected boolean jmxManagementEnabled
protected String jmxDomain
protected boolean jmxUseBrokerName
protected long connectionTTLOverride
protected boolean asyncConnectionExecutionEnabled
protected int idCacheSize
protected Map<String,TransportConfiguration> connectorConfigs
protected List<BridgeConfiguration> bridgeConfigurations
protected List<DivertConfiguration> divertConfigurations
protected List<ClusterConnectionConfiguration> clusterConfigurations
protected transient List<BroadcastGroupConfiguration> broadcastGroupConfigurations
protected transient Map<String,DiscoveryGroupConfiguration> discoveryGroupConfigurations
protected String largeMessagesDirectory
protected String bindingsDirectory
protected boolean createBindingsDir
protected String journalDirectory
protected boolean createJournalDir
public JournalType journalType
protected boolean journalSyncTransactional
protected boolean journalSyncNonTransactional
protected int journalCompactMinFiles
protected int journalCompactPercentage
protected int journalFileOpenTimeout
protected int journalFileSize
protected int journalPoolFiles
protected int journalMinFiles
protected int journalMaxIO_AIO
protected int journalBufferTimeout_AIO
protected int journalBufferSize_AIO
protected int journalMaxIO_NIO
protected int journalBufferTimeout_NIO
protected int journalBufferSize_NIO
protected boolean logJournalWriteRate
protected String clusterUser
protected String clusterPassword
protected boolean failoverOnServerShutdown
protected GroupingHandlerConfiguration groupingHandlerConfiguration
protected List<ConnectorServiceConfiguration> connectorServiceConfigurations
protected boolean populateValidatedUser
public Configuration setSystemPropertyPrefix(String systemPropertyPrefix)
Configuration
Configuration.setSystemPropertyPrefix(String)
.
The default should be 'brokerconfig.' (Including the ".").
For example if you want to set clustered through a system property you must do:
-Dbrokerconfig.clustered=true
The prefix is configured here.setSystemPropertyPrefix
in interface Configuration
public String getSystemPropertyPrefix()
Configuration
Configuration.setSystemPropertyPrefix(String)
.getSystemPropertyPrefix
in interface Configuration
public Configuration parseSystemProperties() throws Exception
parseSystemProperties
in interface Configuration
Exception
public Configuration parseSystemProperties(Properties properties) throws Exception
parseSystemProperties
in interface Configuration
Exception
public boolean isClustered()
Configuration
true
if Configuration.getClusterConfigurations()
is not empty.isClustered
in interface Configuration
public boolean isPersistenceEnabled()
Configuration
ActiveMQDefaultConfiguration.DEFAULT_PERSISTENCE_ENABLED
.isPersistenceEnabled
in interface Configuration
public int getMaxDiskUsage()
getMaxDiskUsage
in interface Configuration
public ConfigurationImpl setMaxDiskUsage(int maxDiskUsage)
setMaxDiskUsage
in interface Configuration
public ConfigurationImpl setGlobalMaxSize(long maxSize)
setGlobalMaxSize
in interface Configuration
public long getGlobalMaxSize()
getGlobalMaxSize
in interface Configuration
public ConfigurationImpl setPersistenceEnabled(boolean enable)
Configuration
setPersistenceEnabled
in interface Configuration
public boolean isJournalDatasync()
Configuration
isJournalDatasync
in interface Configuration
public ConfigurationImpl setJournalDatasync(boolean enable)
Configuration
Configuration.isJournalDatasync()
()}setJournalDatasync
in interface Configuration
public long getFileDeployerScanPeriod()
Configuration
ActiveMQDefaultConfiguration.DEFAULT_FILE_DEPLOYER_SCAN_PERIOD
.getFileDeployerScanPeriod
in interface Configuration
public ConfigurationImpl setFileDeployerScanPeriod(long period)
Configuration
setFileDeployerScanPeriod
in interface Configuration
public boolean isPersistDeliveryCountBeforeDelivery()
Configuration
ActiveMQDefaultConfiguration.DEFAULT_PERSIST_DELIVERY_COUNT_BEFORE_DELIVERY
isPersistDeliveryCountBeforeDelivery
in interface Configuration
public ConfigurationImpl setPersistDeliveryCountBeforeDelivery(boolean persistDeliveryCountBeforeDelivery)
Configuration
setPersistDeliveryCountBeforeDelivery
in interface Configuration
public int getScheduledThreadPoolMaxSize()
Configuration
ActiveMQDefaultConfiguration.DEFAULT_SCHEDULED_THREAD_POOL_MAX_SIZE
.getScheduledThreadPoolMaxSize
in interface Configuration
public ConfigurationImpl setScheduledThreadPoolMaxSize(int maxSize)
Configuration
setScheduledThreadPoolMaxSize
in interface Configuration
public int getThreadPoolMaxSize()
Configuration
ActiveMQDefaultConfiguration.DEFAULT_THREAD_POOL_MAX_SIZE
.getThreadPoolMaxSize
in interface Configuration
public ConfigurationImpl setThreadPoolMaxSize(int maxSize)
Configuration
setThreadPoolMaxSize
in interface Configuration
public long getSecurityInvalidationInterval()
Configuration
ActiveMQDefaultConfiguration.DEFAULT_SECURITY_INVALIDATION_INTERVAL
.getSecurityInvalidationInterval
in interface Configuration
public ConfigurationImpl setSecurityInvalidationInterval(long interval)
Configuration
setSecurityInvalidationInterval
in interface Configuration
public long getConnectionTTLOverride()
Configuration
ActiveMQDefaultConfiguration.DEFAULT_CONNECTION_TTL_OVERRIDE
.getConnectionTTLOverride
in interface Configuration
public ConfigurationImpl setConnectionTTLOverride(long ttl)
Configuration
setConnectionTTLOverride
in interface Configuration
public boolean isAmqpUseCoreSubscriptionNaming()
Configuration
isAmqpUseCoreSubscriptionNaming
in interface Configuration
public Configuration setAmqpUseCoreSubscriptionNaming(boolean amqpUseCoreSubscriptionNaming)
Configuration
setAmqpUseCoreSubscriptionNaming
in interface Configuration
public boolean isAsyncConnectionExecutionEnabled()
Configuration
ActiveMQDefaultConfiguration.DEFAULT_ASYNC_CONNECTION_EXECUTION_ENABLED
.isAsyncConnectionExecutionEnabled
in interface Configuration
public ConfigurationImpl setEnabledAsyncConnectionExecution(boolean enabled)
Configuration
setEnabledAsyncConnectionExecution
in interface Configuration
public List<String> getIncomingInterceptorClassNames()
Configuration
getIncomingInterceptorClassNames
in interface Configuration
public ConfigurationImpl setIncomingInterceptorClassNames(List<String> interceptors)
Configuration
Interceptor
.setIncomingInterceptorClassNames
in interface Configuration
public List<String> getOutgoingInterceptorClassNames()
Configuration
getOutgoingInterceptorClassNames
in interface Configuration
public ConfigurationImpl setOutgoingInterceptorClassNames(List<String> interceptors)
Configuration
Interceptor
.setOutgoingInterceptorClassNames
in interface Configuration
public Set<TransportConfiguration> getAcceptorConfigurations()
Configuration
getAcceptorConfigurations
in interface Configuration
public ConfigurationImpl setAcceptorConfigurations(Set<TransportConfiguration> infos)
Configuration
setAcceptorConfigurations
in interface Configuration
public ConfigurationImpl addAcceptorConfiguration(TransportConfiguration infos)
addAcceptorConfiguration
in interface Configuration
public ConfigurationImpl addAcceptorConfiguration(String name, String uri) throws Exception
Configuration
addAcceptorConfiguration
in interface Configuration
name
- the name of the acceptoruri
- the URI of the acceptorException
- in case of Parsing errors on the URIpublic ConfigurationImpl clearAcceptorConfigurations()
clearAcceptorConfigurations
in interface Configuration
public Map<String,TransportConfiguration> getConnectorConfigurations()
Configuration
getConnectorConfigurations
in interface Configuration
public ConfigurationImpl setConnectorConfigurations(Map<String,TransportConfiguration> infos)
Configuration
setConnectorConfigurations
in interface Configuration
public ConfigurationImpl addConnectorConfiguration(String key, TransportConfiguration info)
addConnectorConfiguration
in interface Configuration
public ConfigurationImpl addConnectorConfiguration(String name, String uri) throws Exception
addConnectorConfiguration
in interface Configuration
Exception
public ConfigurationImpl clearConnectorConfigurations()
clearConnectorConfigurations
in interface Configuration
public GroupingHandlerConfiguration getGroupingHandlerConfiguration()
Configuration
getGroupingHandlerConfiguration
in interface Configuration
public ConfigurationImpl setGroupingHandlerConfiguration(GroupingHandlerConfiguration groupingHandlerConfiguration)
Configuration
setGroupingHandlerConfiguration
in interface Configuration
public List<BridgeConfiguration> getBridgeConfigurations()
Configuration
getBridgeConfigurations
in interface Configuration
public ConfigurationImpl setBridgeConfigurations(List<BridgeConfiguration> configs)
Configuration
setBridgeConfigurations
in interface Configuration
public ConfigurationImpl addBridgeConfiguration(BridgeConfiguration config)
public List<BroadcastGroupConfiguration> getBroadcastGroupConfigurations()
Configuration
getBroadcastGroupConfigurations
in interface Configuration
public ConfigurationImpl setBroadcastGroupConfigurations(List<BroadcastGroupConfiguration> configs)
Configuration
setBroadcastGroupConfigurations
in interface Configuration
public ConfigurationImpl addBroadcastGroupConfiguration(BroadcastGroupConfiguration config)
addBroadcastGroupConfiguration
in interface Configuration
public List<ClusterConnectionConfiguration> getClusterConfigurations()
Configuration
Modifying the returned list will modify the list of ClusterConnectionConfiguration
used by this configuration.
getClusterConfigurations
in interface Configuration
public ConfigurationImpl setClusterConfigurations(List<ClusterConnectionConfiguration> configs)
Configuration
setClusterConfigurations
in interface Configuration
public ConfigurationImpl addClusterConfiguration(ClusterConnectionConfiguration config)
addClusterConfiguration
in interface Configuration
public ClusterConnectionConfiguration addClusterConfiguration(String name, String uri) throws Exception
addClusterConfiguration
in interface Configuration
Exception
public ConfigurationImpl clearClusterConfigurations()
clearClusterConfigurations
in interface Configuration
public List<DivertConfiguration> getDivertConfigurations()
Configuration
getDivertConfigurations
in interface Configuration
public ConfigurationImpl setDivertConfigurations(List<DivertConfiguration> configs)
Configuration
setDivertConfigurations
in interface Configuration
public ConfigurationImpl addDivertConfiguration(DivertConfiguration config)
addDivertConfiguration
in interface Configuration
public List<CoreQueueConfiguration> getQueueConfigurations()
Configuration
getQueueConfigurations
in interface Configuration
public ConfigurationImpl setQueueConfigurations(List<CoreQueueConfiguration> configs)
Configuration
setQueueConfigurations
in interface Configuration
public ConfigurationImpl addQueueConfiguration(CoreQueueConfiguration config)
addQueueConfiguration
in interface Configuration
public List<CoreAddressConfiguration> getAddressConfigurations()
Configuration
getAddressConfigurations
in interface Configuration
public Configuration setAddressConfigurations(List<CoreAddressConfiguration> configs)
Configuration
setAddressConfigurations
in interface Configuration
public Configuration addAddressConfiguration(CoreAddressConfiguration config)
Configuration
addAddressConfiguration
in interface Configuration
public Map<String,DiscoveryGroupConfiguration> getDiscoveryGroupConfigurations()
Configuration
getDiscoveryGroupConfigurations
in interface Configuration
public ConfigurationImpl setDiscoveryGroupConfigurations(Map<String,DiscoveryGroupConfiguration> discoveryGroupConfigurations)
Configuration
setDiscoveryGroupConfigurations
in interface Configuration
public ConfigurationImpl addDiscoveryGroupConfiguration(String key, DiscoveryGroupConfiguration discoveryGroupConfiguration)
addDiscoveryGroupConfiguration
in interface Configuration
public int getIDCacheSize()
Configuration
ActiveMQDefaultConfiguration.DEFAULT_ID_CACHE_SIZE
.getIDCacheSize
in interface Configuration
public ConfigurationImpl setIDCacheSize(int idCacheSize)
Configuration
setIDCacheSize
in interface Configuration
public boolean isPersistIDCache()
Configuration
ActiveMQDefaultConfiguration.DEFAULT_PERSIST_ID_CACHE
.isPersistIDCache
in interface Configuration
public ConfigurationImpl setPersistIDCache(boolean persist)
Configuration
setPersistIDCache
in interface Configuration
public File getBindingsLocation()
Configuration
getBindingsLocation
in interface Configuration
public String getBindingsDirectory()
Configuration
ActiveMQDefaultConfiguration.DEFAULT_BINDINGS_DIRECTORY
.getBindingsDirectory
in interface Configuration
public ConfigurationImpl setBindingsDirectory(String dir)
Configuration
setBindingsDirectory
in interface Configuration
public int getPageMaxConcurrentIO()
Configuration
Default value is ActiveMQDefaultConfiguration.DEFAULT_MAX_CONCURRENT_PAGE_IO
.
getPageMaxConcurrentIO
in interface Configuration
public ConfigurationImpl setPageMaxConcurrentIO(int maxIO)
Configuration
Default = 5
setPageMaxConcurrentIO
in interface Configuration
public File getJournalLocation()
Configuration
getJournalLocation
in interface Configuration
public String getJournalDirectory()
Configuration
ActiveMQDefaultConfiguration.DEFAULT_JOURNAL_DIR
.getJournalDirectory
in interface Configuration
public ConfigurationImpl setJournalDirectory(String dir)
Configuration
setJournalDirectory
in interface Configuration
public JournalType getJournalType()
Configuration
NIO
, ASYNCIO
or MAPPED
).
getJournalType
in interface Configuration
public ConfigurationImpl setPagingDirectory(String dir)
Configuration
setPagingDirectory
in interface Configuration
public File getPagingLocation()
Configuration
getPagingLocation
in interface Configuration
public String getPagingDirectory()
Configuration
ActiveMQDefaultConfiguration.DEFAULT_PAGING_DIR
.getPagingDirectory
in interface Configuration
public ConfigurationImpl setJournalType(JournalType type)
Configuration
NIO
or ASYNCIO
).setJournalType
in interface Configuration
public boolean isJournalSyncTransactional()
Configuration
ActiveMQDefaultConfiguration.DEFAULT_JOURNAL_SYNC_TRANSACTIONAL
.isJournalSyncTransactional
in interface Configuration
public ConfigurationImpl setJournalSyncTransactional(boolean sync)
Configuration
setJournalSyncTransactional
in interface Configuration
public boolean isJournalSyncNonTransactional()
Configuration
ActiveMQDefaultConfiguration.DEFAULT_JOURNAL_SYNC_NON_TRANSACTIONAL
.isJournalSyncNonTransactional
in interface Configuration
public ConfigurationImpl setJournalSyncNonTransactional(boolean sync)
Configuration
setJournalSyncNonTransactional
in interface Configuration
public int getJournalFileSize()
Configuration
ActiveMQDefaultConfiguration.DEFAULT_JOURNAL_FILE_SIZE
.getJournalFileSize
in interface Configuration
public ConfigurationImpl setJournalFileSize(int size)
Configuration
setJournalFileSize
in interface Configuration
public int getJournalPoolFiles()
Configuration
ActiveMQDefaultConfiguration.DEFAULT_JOURNAL_POOL_FILES
.getJournalPoolFiles
in interface Configuration
public Configuration setJournalPoolFiles(int poolSize)
Configuration
ActiveMQDefaultConfiguration.DEFAULT_JOURNAL_POOL_FILES
.setJournalPoolFiles
in interface Configuration
public int getJournalMinFiles()
Configuration
ActiveMQDefaultConfiguration.DEFAULT_JOURNAL_MIN_FILES
.getJournalMinFiles
in interface Configuration
public ConfigurationImpl setJournalMinFiles(int files)
Configuration
setJournalMinFiles
in interface Configuration
public boolean isLogJournalWriteRate()
isLogJournalWriteRate
in interface Configuration
public ConfigurationImpl setLogJournalWriteRate(boolean logJournalWriteRate)
setLogJournalWriteRate
in interface Configuration
public boolean isCreateBindingsDir()
Configuration
ActiveMQDefaultConfiguration.DEFAULT_CREATE_BINDINGS_DIR
.isCreateBindingsDir
in interface Configuration
public ConfigurationImpl setCreateBindingsDir(boolean create)
Configuration
setCreateBindingsDir
in interface Configuration
public boolean isCreateJournalDir()
Configuration
ActiveMQDefaultConfiguration.DEFAULT_CREATE_JOURNAL_DIR
.isCreateJournalDir
in interface Configuration
public ConfigurationImpl setCreateJournalDir(boolean create)
Configuration
setCreateJournalDir
in interface Configuration
@Deprecated public boolean isWildcardRoutingEnabled()
Configuration
ActiveMQDefaultConfiguration.DEFAULT_WILDCARD_ROUTING_ENABLED
.isWildcardRoutingEnabled
in interface Configuration
@Deprecated public ConfigurationImpl setWildcardRoutingEnabled(boolean enabled)
Configuration
setWildcardRoutingEnabled
in interface Configuration
public WildcardConfiguration getWildcardConfiguration()
getWildcardConfiguration
in interface Configuration
public Configuration setWildCardConfiguration(WildcardConfiguration wildcardConfiguration)
setWildCardConfiguration
in interface Configuration
public long getTransactionTimeout()
Configuration
ActiveMQDefaultConfiguration.DEFAULT_TRANSACTION_TIMEOUT
.getTransactionTimeout
in interface Configuration
public ConfigurationImpl setTransactionTimeout(long timeout)
Configuration
setTransactionTimeout
in interface Configuration
public long getTransactionTimeoutScanPeriod()
Configuration
ActiveMQDefaultConfiguration.DEFAULT_TRANSACTION_TIMEOUT_SCAN_PERIOD
.getTransactionTimeoutScanPeriod
in interface Configuration
public ConfigurationImpl setTransactionTimeoutScanPeriod(long period)
Configuration
setTransactionTimeoutScanPeriod
in interface Configuration
public long getMessageExpiryScanPeriod()
Configuration
ActiveMQDefaultConfiguration.DEFAULT_MESSAGE_EXPIRY_SCAN_PERIOD
.getMessageExpiryScanPeriod
in interface Configuration
public ConfigurationImpl setMessageExpiryScanPeriod(long messageExpiryScanPeriod)
Configuration
setMessageExpiryScanPeriod
in interface Configuration
public int getMessageExpiryThreadPriority()
Configuration
ActiveMQDefaultConfiguration.DEFAULT_MESSAGE_EXPIRY_THREAD_PRIORITY
.getMessageExpiryThreadPriority
in interface Configuration
public ConfigurationImpl setMessageExpiryThreadPriority(int messageExpiryThreadPriority)
Configuration
setMessageExpiryThreadPriority
in interface Configuration
public boolean isSecurityEnabled()
Configuration
ActiveMQDefaultConfiguration.DEFAULT_SECURITY_ENABLED
.isSecurityEnabled
in interface Configuration
public ConfigurationImpl setSecurityEnabled(boolean enabled)
Configuration
setSecurityEnabled
in interface Configuration
public boolean isGracefulShutdownEnabled()
Configuration
ActiveMQDefaultConfiguration.DEFAULT_GRACEFUL_SHUTDOWN_ENABLED
.isGracefulShutdownEnabled
in interface Configuration
public ConfigurationImpl setGracefulShutdownEnabled(boolean enabled)
Configuration
setGracefulShutdownEnabled
in interface Configuration
public long getGracefulShutdownTimeout()
Configuration
ActiveMQDefaultConfiguration.DEFAULT_GRACEFUL_SHUTDOWN_TIMEOUT
.getGracefulShutdownTimeout
in interface Configuration
public ConfigurationImpl setGracefulShutdownTimeout(long timeout)
Configuration
setGracefulShutdownTimeout
in interface Configuration
public boolean isJMXManagementEnabled()
Configuration
ActiveMQDefaultConfiguration.DEFAULT_JMX_MANAGEMENT_ENABLED
.isJMXManagementEnabled
in interface Configuration
public ConfigurationImpl setJMXManagementEnabled(boolean enabled)
Configuration
ActiveMQDefaultConfiguration.DEFAULT_JMX_MANAGEMENT_ENABLED
.setJMXManagementEnabled
in interface Configuration
public String getJMXDomain()
Configuration
ActiveMQDefaultConfiguration.DEFAULT_JMX_DOMAIN
.getJMXDomain
in interface Configuration
public ConfigurationImpl setJMXDomain(String domain)
Configuration
Changing this JMX domain is required if multiple ActiveMQ Artemis servers are run inside the same JVM and all servers are using the same MBeanServer.
setJMXDomain
in interface Configuration
public boolean isJMXUseBrokerName()
Configuration
isJMXUseBrokerName
in interface Configuration
public ConfigurationImpl setJMXUseBrokerName(boolean jmxUseBrokerName)
Configuration
setJMXUseBrokerName
in interface Configuration
public String getLargeMessagesDirectory()
Configuration
ActiveMQDefaultConfiguration.DEFAULT_LARGE_MESSAGES_DIR
.getLargeMessagesDirectory
in interface Configuration
public File getLargeMessagesLocation()
Configuration
getLargeMessagesLocation
in interface Configuration
public ConfigurationImpl setLargeMessagesDirectory(String directory)
Configuration
setLargeMessagesDirectory
in interface Configuration
public boolean isMessageCounterEnabled()
Configuration
ActiveMQDefaultConfiguration.DEFAULT_MESSAGE_COUNTER_ENABLED
.isMessageCounterEnabled
in interface Configuration
public ConfigurationImpl setMessageCounterEnabled(boolean enabled)
Configuration
setMessageCounterEnabled
in interface Configuration
public long getMessageCounterSamplePeriod()
Configuration
ActiveMQDefaultConfiguration.DEFAULT_MESSAGE_COUNTER_SAMPLE_PERIOD
.getMessageCounterSamplePeriod
in interface Configuration
public ConfigurationImpl setMessageCounterSamplePeriod(long period)
Configuration
setMessageCounterSamplePeriod
in interface Configuration
period
- value must be greater than 1000mspublic int getMessageCounterMaxDayHistory()
Configuration
ActiveMQDefaultConfiguration.DEFAULT_MESSAGE_COUNTER_MAX_DAY_HISTORY
.getMessageCounterMaxDayHistory
in interface Configuration
public ConfigurationImpl setMessageCounterMaxDayHistory(int maxDayHistory)
Configuration
setMessageCounterMaxDayHistory
in interface Configuration
maxDayHistory
- value must be greater than 0public SimpleString getManagementAddress()
Configuration
ActiveMQDefaultConfiguration.DEFAULT_MANAGEMENT_ADDRESS
.getManagementAddress
in interface Configuration
public ConfigurationImpl setManagementAddress(SimpleString address)
Configuration
setManagementAddress
in interface Configuration
public SimpleString getManagementNotificationAddress()
Configuration
ActiveMQDefaultConfiguration.DEFAULT_MANAGEMENT_NOTIFICATION_ADDRESS
.getManagementNotificationAddress
in interface Configuration
public ConfigurationImpl setManagementNotificationAddress(SimpleString address)
Configuration
setManagementNotificationAddress
in interface Configuration
public String getClusterUser()
Configuration
ActiveMQDefaultConfiguration.DEFAULT_CLUSTER_USER
.getClusterUser
in interface Configuration
public ConfigurationImpl setClusterUser(String user)
Configuration
setClusterUser
in interface Configuration
public String getClusterPassword()
Configuration
ActiveMQDefaultConfiguration.DEFAULT_CLUSTER_PASSWORD
.getClusterPassword
in interface Configuration
public boolean isFailoverOnServerShutdown()
public ConfigurationImpl setFailoverOnServerShutdown(boolean failoverOnServerShutdown)
public ConfigurationImpl setClusterPassword(String theclusterPassword)
Configuration
setClusterPassword
in interface Configuration
public int getJournalCompactMinFiles()
Configuration
ActiveMQDefaultConfiguration.DEFAULT_JOURNAL_COMPACT_MIN_FILES
.getJournalCompactMinFiles
in interface Configuration
public int getJournalCompactPercentage()
Configuration
ActiveMQDefaultConfiguration.DEFAULT_JOURNAL_COMPACT_PERCENTAGE
.getJournalCompactPercentage
in interface Configuration
public ConfigurationImpl setJournalCompactMinFiles(int minFiles)
Configuration
setJournalCompactMinFiles
in interface Configuration
public int getJournalFileOpenTimeout()
getJournalFileOpenTimeout
in interface Configuration
public Configuration setJournalFileOpenTimeout(int journalFileOpenTimeout)
Configuration
setJournalFileOpenTimeout
in interface Configuration
public ConfigurationImpl setJournalCompactPercentage(int percentage)
Configuration
setJournalCompactPercentage
in interface Configuration
public long getServerDumpInterval()
getServerDumpInterval
in interface Configuration
public ConfigurationImpl setServerDumpInterval(long intervalInMilliseconds)
setServerDumpInterval
in interface Configuration
public int getMemoryWarningThreshold()
getMemoryWarningThreshold
in interface Configuration
public ConfigurationImpl setMemoryWarningThreshold(int memoryWarningThreshold)
setMemoryWarningThreshold
in interface Configuration
public long getMemoryMeasureInterval()
getMemoryMeasureInterval
in interface Configuration
public ConfigurationImpl setMemoryMeasureInterval(long memoryMeasureInterval)
setMemoryMeasureInterval
in interface Configuration
public int getJournalMaxIO_AIO()
Configuration
ActiveMQDefaultConfiguration.DEFAULT_JOURNAL_MAX_IO_AIO
.getJournalMaxIO_AIO
in interface Configuration
public ConfigurationImpl setJournalMaxIO_AIO(int journalMaxIO)
Configuration
setJournalMaxIO_AIO
in interface Configuration
public int getJournalBufferTimeout_AIO()
Configuration
ArtemisConstants.DEFAULT_JOURNAL_BUFFER_TIMEOUT_AIO
.getJournalBufferTimeout_AIO
in interface Configuration
public ConfigurationImpl setJournalBufferTimeout_AIO(int journalBufferTimeout)
Configuration
setJournalBufferTimeout_AIO
in interface Configuration
public int getJournalBufferSize_AIO()
Configuration
ArtemisConstants.DEFAULT_JOURNAL_BUFFER_SIZE_AIO
.getJournalBufferSize_AIO
in interface Configuration
public ConfigurationImpl setJournalBufferSize_AIO(int journalBufferSize)
Configuration
setJournalBufferSize_AIO
in interface Configuration
public int getJournalMaxIO_NIO()
Configuration
ActiveMQDefaultConfiguration.DEFAULT_JOURNAL_MAX_IO_NIO
.getJournalMaxIO_NIO
in interface Configuration
public ConfigurationImpl setJournalMaxIO_NIO(int journalMaxIO)
Configuration
setJournalMaxIO_NIO
in interface Configuration
public int getJournalBufferTimeout_NIO()
Configuration
ArtemisConstants.DEFAULT_JOURNAL_BUFFER_TIMEOUT_NIO
.getJournalBufferTimeout_NIO
in interface Configuration
public ConfigurationImpl setJournalBufferTimeout_NIO(int journalBufferTimeout)
Configuration
setJournalBufferTimeout_NIO
in interface Configuration
public int getJournalBufferSize_NIO()
Configuration
ArtemisConstants.DEFAULT_JOURNAL_BUFFER_SIZE_NIO
.getJournalBufferSize_NIO
in interface Configuration
public ConfigurationImpl setJournalBufferSize_NIO(int journalBufferSize)
Configuration
setJournalBufferSize_NIO
in interface Configuration
public Map<String,AddressSettings> getAddressesSettings()
getAddressesSettings
in interface Configuration
public ConfigurationImpl setAddressesSettings(Map<String,AddressSettings> addressesSettings)
setAddressesSettings
in interface Configuration
addressesSettings
- list of AddressSettings per matching to be deployed to the address
settings repositorypublic ConfigurationImpl addAddressesSetting(String key, AddressSettings addressesSetting)
addAddressesSetting
in interface Configuration
public ConfigurationImpl clearAddressesSettings()
clearAddressesSettings
in interface Configuration
public Map<String,ResourceLimitSettings> getResourceLimitSettings()
getResourceLimitSettings
in interface Configuration
public ConfigurationImpl setResourceLimitSettings(Map<String,ResourceLimitSettings> resourceLimitSettings)
setResourceLimitSettings
in interface Configuration
resourceLimitSettings
- usernames mapped to ResourceLimitSettingspublic ConfigurationImpl addResourceLimitSettings(ResourceLimitSettings resourceLimitSettings)
addResourceLimitSettings
in interface Configuration
resourceLimitSettings
- usernames mapped to ResourceLimitSettingspublic Map<String,Set<Role>> getSecurityRoles()
getSecurityRoles
in interface Configuration
public ConfigurationImpl putSecurityRoles(String match, Set<Role> roles)
putSecurityRoles
in interface Configuration
public ConfigurationImpl setSecurityRoles(Map<String,Set<Role>> securitySettings)
setSecurityRoles
in interface Configuration
securitySettings
- a list of roles per matchingpublic Configuration addSecurityRoleNameMapping(String internalRole, Set<String> externalRoles)
addSecurityRoleNameMapping
in interface Configuration
public Map<String,Set<String>> getSecurityRoleNameMappings()
getSecurityRoleNameMappings
in interface Configuration
public List<ConnectorServiceConfiguration> getConnectorServiceConfigurations()
getConnectorServiceConfigurations
in interface Configuration
ConnectorServiceConfiguration
public List<SecuritySettingPlugin> getSecuritySettingPlugins()
getSecuritySettingPlugins
in interface Configuration
public void registerBrokerPlugins(List<ActiveMQServerPlugin> plugins)
registerBrokerPlugins
in interface Configuration
public void registerBrokerPlugin(ActiveMQServerPlugin plugin)
registerBrokerPlugin
in interface Configuration
public void unRegisterBrokerPlugin(ActiveMQServerPlugin plugin)
unRegisterBrokerPlugin
in interface Configuration
public List<ActiveMQServerPlugin> getBrokerPlugins()
getBrokerPlugins
in interface Configuration
public File getBrokerInstance()
Configuration
getBrokerInstance
in interface Configuration
public void setBrokerInstance(File directory)
Configuration
setBrokerInstance
in interface Configuration
public boolean isCheckForLiveServer()
public ConfigurationImpl setCheckForLiveServer(boolean checkForLiveServer)
public ConfigurationImpl setConnectorServiceConfigurations(List<ConnectorServiceConfiguration> configs)
setConnectorServiceConfigurations
in interface Configuration
public ConfigurationImpl addConnectorServiceConfiguration(ConnectorServiceConfiguration config)
addConnectorServiceConfiguration
in interface Configuration
public ConfigurationImpl setSecuritySettingPlugins(List<SecuritySettingPlugin> plugins)
setSecuritySettingPlugins
in interface Configuration
public ConfigurationImpl addSecuritySettingPlugin(SecuritySettingPlugin plugin)
addSecuritySettingPlugin
in interface Configuration
public Boolean isMaskPassword()
Configuration
isMaskPassword
in interface Configuration
public ConfigurationImpl setMaskPassword(Boolean maskPassword)
Configuration
setMaskPassword
in interface Configuration
public ConfigurationImpl setPasswordCodec(String codec)
Configuration
setPasswordCodec
in interface Configuration
public String getPasswordCodec()
Configuration
getPasswordCodec
in interface Configuration
public String getName()
Configuration
getName
in interface Configuration
public ConfigurationImpl setName(String name)
Configuration
setName
in interface Configuration
public ConfigurationImpl setResolveProtocols(boolean resolveProtocols)
setResolveProtocols
in interface Configuration
public TransportConfiguration[] getTransportConfigurations(String... connectorNames)
getTransportConfigurations
in interface Configuration
public TransportConfiguration[] getTransportConfigurations(List<String> connectorNames)
getTransportConfigurations
in interface Configuration
public String debugConnectors()
Configuration
debugConnectors
in interface Configuration
public boolean isResolveProtocols()
isResolveProtocols
in interface Configuration
public StoreConfiguration getStoreConfiguration()
getStoreConfiguration
in interface Configuration
public ConfigurationImpl setStoreConfiguration(StoreConfiguration storeConfiguration)
setStoreConfiguration
in interface Configuration
public boolean isPopulateValidatedUser()
isPopulateValidatedUser
in interface Configuration
public ConfigurationImpl setPopulateValidatedUser(boolean populateValidatedUser)
setPopulateValidatedUser
in interface Configuration
public long getConnectionTtlCheckInterval()
getConnectionTtlCheckInterval
in interface Configuration
public ConfigurationImpl setConnectionTtlCheckInterval(long connectionTtlCheckInterval)
setConnectionTtlCheckInterval
in interface Configuration
public Configuration copy() throws Exception
copy
in interface Configuration
Exception
public ConfigurationImpl setJournalLockAcquisitionTimeout(long journalLockAcquisitionTimeout)
setJournalLockAcquisitionTimeout
in interface Configuration
public long getJournalLockAcquisitionTimeout()
getJournalLockAcquisitionTimeout
in interface Configuration
public HAPolicyConfiguration getHAPolicyConfiguration()
getHAPolicyConfiguration
in interface Configuration
public ConfigurationImpl setHAPolicyConfiguration(HAPolicyConfiguration haPolicyConfiguration)
setHAPolicyConfiguration
in interface Configuration
public URL getConfigurationUrl()
getConfigurationUrl
in interface Configuration
public ConfigurationImpl setConfigurationUrl(URL configurationUrl)
setConfigurationUrl
in interface Configuration
public long getConfigurationFileRefreshPeriod()
getConfigurationFileRefreshPeriod
in interface Configuration
public ConfigurationImpl setConfigurationFileRefreshPeriod(long configurationFileRefreshPeriod)
setConfigurationFileRefreshPeriod
in interface Configuration
public int getDiskScanPeriod()
getDiskScanPeriod
in interface Configuration
public String getInternalNamingPrefix()
getInternalNamingPrefix
in interface Configuration
public ConfigurationImpl setInternalNamingPrefix(String internalNamingPrefix)
setInternalNamingPrefix
in interface Configuration
public ConfigurationImpl setDiskScanPeriod(int diskScanPeriod)
setDiskScanPeriod
in interface Configuration
public ConfigurationImpl setNetworkCheckList(String list)
Configuration
setNetworkCheckList
in interface Configuration
public String getNetworkCheckList()
getNetworkCheckList
in interface Configuration
public ConfigurationImpl setNetworkCheckURLList(String urls)
Configuration
setNetworkCheckURLList
in interface Configuration
public String getNetworkCheckURLList()
getNetworkCheckURLList
in interface Configuration
public ConfigurationImpl setNetworkCheckPeriod(long period)
setNetworkCheckPeriod
in interface Configuration
public long getNetworkCheckPeriod()
getNetworkCheckPeriod
in interface Configuration
public ConfigurationImpl setNetworkCheckTimeout(int timeout)
setNetworkCheckTimeout
in interface Configuration
public int getNetworkCheckTimeout()
getNetworkCheckTimeout
in interface Configuration
public Configuration setNetworCheckNIC(String nic)
Configuration
setNetworCheckNIC
in interface Configuration
public String getNetworkCheckNIC()
getNetworkCheckNIC
in interface Configuration
public String getNetworkCheckPingCommand()
getNetworkCheckPingCommand
in interface Configuration
public ConfigurationImpl setNetworkCheckPingCommand(String command)
setNetworkCheckPingCommand
in interface Configuration
public String getNetworkCheckPing6Command()
getNetworkCheckPing6Command
in interface Configuration
public Configuration setNetworkCheckPing6Command(String command)
setNetworkCheckPing6Command
in interface Configuration
public boolean isCriticalAnalyzer()
isCriticalAnalyzer
in interface Configuration
public Configuration setCriticalAnalyzer(boolean CriticalAnalyzer)
setCriticalAnalyzer
in interface Configuration
public long getCriticalAnalyzerTimeout()
getCriticalAnalyzerTimeout
in interface Configuration
public Configuration setCriticalAnalyzerTimeout(long timeout)
setCriticalAnalyzerTimeout
in interface Configuration
public long getCriticalAnalyzerCheckPeriod()
getCriticalAnalyzerCheckPeriod
in interface Configuration
public Configuration setCriticalAnalyzerCheckPeriod(long checkPeriod)
setCriticalAnalyzerCheckPeriod
in interface Configuration
public CriticalAnalyzerPolicy getCriticalAnalyzerPolicy()
getCriticalAnalyzerPolicy
in interface Configuration
public Configuration setCriticalAnalyzerPolicy(CriticalAnalyzerPolicy policy)
setCriticalAnalyzerPolicy
in interface Configuration
public static boolean checkoutDupCacheSize(int windowSize, int idCacheSize)
Copyright © 2018 JBoss by Red Hat. All rights reserved.