public interface Configuration
Modifier and Type | Method and Description |
---|---|
Configuration |
addAcceptorConfiguration(String name,
String uri)
Add an acceptor to the config
|
Configuration |
addAcceptorConfiguration(TransportConfiguration infos) |
Configuration |
addAddressesSetting(String key,
AddressSettings addressesSetting) |
Configuration |
addBroadcastGroupConfiguration(BroadcastGroupConfiguration config) |
Configuration |
addClusterConfiguration(ClusterConnectionConfiguration config) |
ClusterConnectionConfiguration |
addClusterConfiguration(String name,
String uri) |
Configuration |
addConnectorConfiguration(String name,
String uri) |
Configuration |
addConnectorConfiguration(String key,
TransportConfiguration info) |
Configuration |
addConnectorServiceConfiguration(ConnectorServiceConfiguration config) |
Configuration |
addDiscoveryGroupConfiguration(String key,
DiscoveryGroupConfiguration discoveryGroupConfiguration) |
Configuration |
addDivertConfiguration(DivertConfiguration config) |
Configuration |
addQueueConfiguration(CoreQueueConfiguration config) |
Configuration |
addResourceLimitSettings(ResourceLimitSettings resourceLimitSettings) |
Configuration |
addSecuritySettingPlugin(SecuritySettingPlugin plugin) |
Configuration |
clearAcceptorConfigurations() |
Configuration |
clearAddressesSettings() |
Configuration |
clearClusterConfigurations() |
Configuration |
clearConnectorConfigurations() |
Configuration |
copy() |
String |
debugConnectors()
It will return all the connectors in a toString manner for debug purposes.
|
Set<TransportConfiguration> |
getAcceptorConfigurations()
Returns the acceptors 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<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() |
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 |
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 |
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 |
getJournalPerfBlastPages() |
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<Role>> |
getSecurityRoles() |
List<SecuritySettingPlugin> |
getSecuritySettingPlugins() |
long |
getServerDumpInterval() |
StoreConfiguration |
getStoreConfiguration() |
String |
getSystemPropertyPrefix()
See doc at
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) |
boolean |
isAsyncConnectionExecutionEnabled()
Returns whether code coming from connection is executed asynchronously or not.
|
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 |
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 |
isRunSyncSpeedTest() |
boolean |
isSecurityEnabled()
Returns whether security is enabled for this server.
|
boolean |
isWildcardRoutingEnabled()
Returns whether wildcard routing is supported by this server.
|
Configuration |
parseSystemProperties() |
Configuration |
parseSystemProperties(Properties properties) |
Configuration |
putSecurityRoles(String match,
Set<Role> roles) |
Configuration |
setAcceptorConfigurations(Set<TransportConfiguration> infos)
Sets the acceptors configured for this server.
|
Configuration |
setAddressesSettings(Map<String,AddressSettings> addressesSettings) |
Configuration |
setBindingsDirectory(String dir)
Sets the file system directory used to store bindings.
|
Configuration |
setBridgeConfigurations(List<BridgeConfiguration> configs)
Sets the bridges configured for this server.
|
Configuration |
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.
|
Configuration |
setClusterConfigurations(List<ClusterConnectionConfiguration> configs)
Sets the cluster connections configured for this server.
|
Configuration |
setClusterPassword(String password)
Sets the cluster password for this server.
|
Configuration |
setClusterUser(String user)
Sets the cluster user for this server.
|
Configuration |
setConfigurationFileRefreshPeriod(long configurationFileRefreshPeriod) |
Configuration |
setConfigurationUrl(URL configurationUrl) |
Configuration |
setConnectionTtlCheckInterval(long connectionTtlCheckInterval) |
Configuration |
setConnectionTTLOverride(long ttl)
Sets the connection time to live.
|
Configuration |
setConnectorConfigurations(Map<String,TransportConfiguration> infos)
Sets the connectors configured for this server.
|
Configuration |
setConnectorServiceConfigurations(List<ConnectorServiceConfiguration> configs) |
Configuration |
setCreateBindingsDir(boolean create)
Sets whether the bindings directory is created on this server startup.
|
Configuration |
setCreateJournalDir(boolean create)
Sets whether the journal directory is created on this server startup.
|
Configuration |
setDiscoveryGroupConfigurations(Map<String,DiscoveryGroupConfiguration> configs)
Sets the discovery groups configured for this server.
|
Configuration |
setDiskScanPeriod(int diskScanPeriod) |
Configuration |
setDivertConfigurations(List<DivertConfiguration> configs)
Sets the diverts configured for this server.
|
Configuration |
setEnabledAsyncConnectionExecution(boolean enabled)
Sets whether code coming from connection is executed asynchronously or not.
|
Configuration |
setFileDeployerScanPeriod(long period)
Sets the period to scan configuration files used by deployment.
|
Configuration |
setGlobalMaxSize(long globalMaxSize) |
Configuration |
setGracefulShutdownEnabled(boolean enabled)
Sets whether security is enabled for this server.
|
Configuration |
setGracefulShutdownTimeout(long timeout)
Sets the graceful shutdown timeout
|
Configuration |
setGroupingHandlerConfiguration(GroupingHandlerConfiguration groupingHandlerConfiguration)
Sets the grouping handler configured for this server.
|
Configuration |
setHAPolicyConfiguration(HAPolicyConfiguration haPolicyConfiguration) |
Configuration |
setIDCacheSize(int idCacheSize)
Sets the size of the cache for pre-creating message IDs.
|
Configuration |
setIncomingInterceptorClassNames(List<String> interceptors)
Sets the list of interceptors classes used by this server for incoming messages (i.e.
|
Configuration |
setJMXDomain(String domain)
Sets the domain used by JMX MBeans (provided JMX management is enabled).
|
Configuration |
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
|
Configuration |
setJournalBufferSize_AIO(int journalBufferSize)
Sets the buffer size (in bytes) for AIO.
|
Configuration |
setJournalBufferSize_NIO(int journalBufferSize)
Sets the buffer size (in bytes) for NIO.
|
Configuration |
setJournalBufferTimeout_AIO(int journalBufferTimeout)
Sets the timeout (in nanoseconds) used to flush buffers in the AIO queue.
|
Configuration |
setJournalBufferTimeout_NIO(int journalBufferTimeout)
Sets the timeout (in nanoseconds) used to flush buffers in the NIO.
|
Configuration |
setJournalCompactMinFiles(int minFiles)
Sets the minimal number of journal files before compacting.
|
Configuration |
setJournalCompactPercentage(int percentage)
Sets the percentage of live data before compacting the journal.
|
Configuration |
setJournalDatasync(boolean enable)
documented at
isJournalDatasync() ()} |
Configuration |
setJournalDirectory(String dir)
Sets the file system directory used to store journal log.
|
Configuration |
setJournalFileSize(int size)
Sets the size (in bytes) of each journal files.
|
Configuration |
setJournalLockAcquisitionTimeout(long journalLockAcquisitionTimeout) |
Configuration |
setJournalMaxIO_AIO(int journalMaxIO)
Sets the maximum number of write requests that can be in the AIO queue at any given time.
|
Configuration |
setJournalMaxIO_NIO(int journalMaxIO)
Sets the maximum number of write requests for NIO journal.
|
Configuration |
setJournalMinFiles(int files)
Sets the number of journal files to pre-create.
|
Configuration |
setJournalPerfBlastPages(int pages) |
Configuration |
setJournalPoolFiles(int poolSize)
Number of files that would be acceptable to keep on a pool.
|
Configuration |
setJournalSyncNonTransactional(boolean sync)
Sets whether the journal is synchronized when receiving non-transactional data.
|
Configuration |
setJournalSyncTransactional(boolean sync)
Sets whether the journal is synchronized when receiving transactional data.
|
Configuration |
setJournalType(JournalType type)
Sets the type of journal used by this server (either
NIO or ASYNCIO ). |
Configuration |
setLargeMessagesDirectory(String directory)
Sets the file system directory used to store large messages.
|
Configuration |
setLogJournalWriteRate(boolean rate) |
Configuration |
setManagementAddress(SimpleString address)
Sets the management address of this server.
|
Configuration |
setManagementNotificationAddress(SimpleString address)
Sets the management notification address of this server.
|
Configuration |
setMaskPassword(boolean maskPassword)
Sets if passwords should be masked or not.
|
Configuration |
setMaxDiskUsage(int maxDiskUsage) |
Configuration |
setMemoryMeasureInterval(long memoryMeasureInterval) |
Configuration |
setMemoryWarningThreshold(int memoryWarningThreshold) |
Configuration |
setMessageCounterEnabled(boolean enabled)
Sets whether message counter is enabled for this server.
|
Configuration |
setMessageCounterMaxDayHistory(int maxDayHistory)
Sets the maximum number of days kept in memory for message counter.
|
Configuration |
setMessageCounterSamplePeriod(long period)
Sets the sample period to take message counter snapshot.
|
Configuration |
setMessageExpiryScanPeriod(long messageExpiryScanPeriod)
Sets the frequency (in milliseconds) to scan messages to detect which messages
have expired.
|
Configuration |
setMessageExpiryThreadPriority(int messageExpiryThreadPriority)
Sets the priority of the thread used to scan message expiration.
|
Configuration |
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
|
Configuration |
setNetworkCheckList(String list)
A comma separated list of IPs we could use to validate if the network is UP.
|
Configuration |
setNetworkCheckPeriod(long period)
The interval on which we will perform network checks.
|
Configuration |
setNetworkCheckPing6Command(String command) |
Configuration |
setNetworkCheckPingCommand(String command) |
Configuration |
setNetworkCheckTimeout(int timeout)
Time in ms for how long we should wait for a ping to finish.
|
Configuration |
setNetworkCheckURLList(String uris)
A comma separated list of URIs we could use to validate if the network is UP.
|
Configuration |
setOutgoingInterceptorClassNames(List<String> interceptors)
Sets the list of interceptors classes used by this server for outgoing messages (i.e.
|
Configuration |
setPageMaxConcurrentIO(int maxIO)
The max number of concurrent reads allowed on paging.
|
Configuration |
setPagingDirectory(String dir)
Sets the file system directory used to store paging files.
|
Configuration |
setPasswordCodec(String codec)
The default password decoder
|
Configuration |
setPersistDeliveryCountBeforeDelivery(boolean persistDeliveryCountBeforeDelivery)
Sets whether delivery count is persisted before messages are delivered to consumers.
|
Configuration |
setPersistenceEnabled(boolean enable)
Sets whether this server is using persistence and store data.
|
Configuration |
setPersistIDCache(boolean persist)
Sets whether message ID cache is persisted.
|
Configuration |
setPopulateValidatedUser(boolean populateValidatedUser) |
Configuration |
setQueueConfigurations(List<CoreQueueConfiguration> configs)
Sets the queues configured for this server.
|
Configuration |
setResolveProtocols(boolean resolveProtocols) |
Configuration |
setResourceLimitSettings(Map<String,ResourceLimitSettings> resourceLimitSettings) |
Configuration |
setRunSyncSpeedTest(boolean run) |
Configuration |
setScheduledThreadPoolMaxSize(int maxSize)
Sets the maximum number of threads in the scheduled thread pool of this server.
|
Configuration |
setSecurityEnabled(boolean enabled)
Sets whether security is enabled for this server.
|
Configuration |
setSecurityInvalidationInterval(long interval)
Sets the interval time (in milliseconds) to invalidate security credentials.
|
Configuration |
setSecurityRoles(Map<String,Set<Role>> roles) |
Configuration |
setSecuritySettingPlugins(List<SecuritySettingPlugin> plugins) |
Configuration |
setServerDumpInterval(long interval) |
Configuration |
setStoreConfiguration(StoreConfiguration storeConfiguration) |
Configuration |
setSystemPropertyPrefix(String systemPropertyPrefix)
We use Bean-utils to pass in System.properties that start with
setSystemPropertyPrefix(String) . |
Configuration |
setThreadPoolMaxSize(int maxSize)
Sets the maximum number of threads in the thread pool of this server.
|
Configuration |
setTransactionTimeout(long timeout)
Sets the timeout (in milliseconds) after which transactions is removed
from the resource manager after it was created.
|
Configuration |
setTransactionTimeoutScanPeriod(long period)
Sets the frequency (in milliseconds) to scan transactions to detect which transactions
have timed out.
|
Configuration |
setWildcardRoutingEnabled(boolean enabled)
Sets whether wildcard routing is supported by this server.
|
String getName()
Configuration setName(String name)
Configuration setSystemPropertyPrefix(String systemPropertyPrefix)
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.systemPropertyPrefix
- String getSystemPropertyPrefix()
setSystemPropertyPrefix(String)
.Configuration parseSystemProperties() throws Exception
Exception
Configuration parseSystemProperties(Properties properties) throws Exception
Exception
boolean isClustered()
boolean isPersistDeliveryCountBeforeDelivery()
ActiveMQDefaultConfiguration.DEFAULT_PERSIST_DELIVERY_COUNT_BEFORE_DELIVERY
Configuration setPersistDeliveryCountBeforeDelivery(boolean persistDeliveryCountBeforeDelivery)
boolean isPersistenceEnabled()
ActiveMQDefaultConfiguration.DEFAULT_PERSISTENCE_ENABLED
.Configuration setPersistenceEnabled(boolean enable)
boolean isJournalDatasync()
Configuration setJournalDatasync(boolean enable)
isJournalDatasync()
()}enable
- Map<String,ResourceLimitSettings> getResourceLimitSettings()
Configuration setResourceLimitSettings(Map<String,ResourceLimitSettings> resourceLimitSettings)
resourceLimitSettings
- usernames mapped to ResourceLimitSettingsConfiguration addResourceLimitSettings(ResourceLimitSettings resourceLimitSettings)
resourceLimitSettings
- usernames mapped to ResourceLimitSettingslong getFileDeployerScanPeriod()
ActiveMQDefaultConfiguration.DEFAULT_FILE_DEPLOYER_SCAN_PERIOD
.Configuration setFileDeployerScanPeriod(long period)
int getThreadPoolMaxSize()
ActiveMQDefaultConfiguration.DEFAULT_THREAD_POOL_MAX_SIZE
.Configuration setThreadPoolMaxSize(int maxSize)
int getScheduledThreadPoolMaxSize()
ActiveMQDefaultConfiguration.DEFAULT_SCHEDULED_THREAD_POOL_MAX_SIZE
.Configuration setScheduledThreadPoolMaxSize(int maxSize)
long getSecurityInvalidationInterval()
ActiveMQDefaultConfiguration.DEFAULT_SECURITY_INVALIDATION_INTERVAL
.Configuration setSecurityInvalidationInterval(long interval)
boolean isSecurityEnabled()
ActiveMQDefaultConfiguration.DEFAULT_SECURITY_ENABLED
.Configuration setSecurityEnabled(boolean enabled)
boolean isGracefulShutdownEnabled()
ActiveMQDefaultConfiguration.DEFAULT_SECURITY_ENABLED
.Configuration setGracefulShutdownEnabled(boolean enabled)
long getGracefulShutdownTimeout()
ActiveMQDefaultConfiguration.DEFAULT_GRACEFUL_SHUTDOWN_TIMEOUT
.Configuration setGracefulShutdownTimeout(long timeout)
boolean isJMXManagementEnabled()
ActiveMQDefaultConfiguration.DEFAULT_JMX_MANAGEMENT_ENABLED
.Configuration setJMXManagementEnabled(boolean enabled)
ActiveMQDefaultConfiguration.DEFAULT_JMX_MANAGEMENT_ENABLED
.String getJMXDomain()
ActiveMQDefaultConfiguration.DEFAULT_JMX_DOMAIN
.Configuration setJMXDomain(String domain)
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.
boolean isJMXUseBrokerName()
ConfigurationImpl setJMXUseBrokerName(boolean jmxUseBrokerName)
List<String> getIncomingInterceptorClassNames()
List<String> getOutgoingInterceptorClassNames()
Configuration setIncomingInterceptorClassNames(List<String> interceptors)
Interceptor
.Configuration setOutgoingInterceptorClassNames(List<String> interceptors)
Interceptor
.long getConnectionTTLOverride()
ActiveMQDefaultConfiguration.DEFAULT_CONNECTION_TTL_OVERRIDE
.Configuration setConnectionTTLOverride(long ttl)
boolean isAsyncConnectionExecutionEnabled()
ActiveMQDefaultConfiguration.DEFAULT_ASYNC_CONNECTION_EXECUTION_ENABLED
.Configuration setEnabledAsyncConnectionExecution(boolean enabled)
Set<TransportConfiguration> getAcceptorConfigurations()
Configuration setAcceptorConfigurations(Set<TransportConfiguration> infos)
Configuration addAcceptorConfiguration(TransportConfiguration infos)
Configuration addAcceptorConfiguration(String name, String uri) throws Exception
name
- the name of the acceptoruri
- the URI of the acceptorException
- in case of Parsing errors on the URIConfiguration clearAcceptorConfigurations()
Map<String,TransportConfiguration> getConnectorConfigurations()
Configuration setConnectorConfigurations(Map<String,TransportConfiguration> infos)
Configuration addConnectorConfiguration(String key, TransportConfiguration info)
Configuration addConnectorConfiguration(String name, String uri) throws Exception
Exception
Configuration clearConnectorConfigurations()
List<BroadcastGroupConfiguration> getBroadcastGroupConfigurations()
Configuration setBroadcastGroupConfigurations(List<BroadcastGroupConfiguration> configs)
Configuration addBroadcastGroupConfiguration(BroadcastGroupConfiguration config)
Map<String,DiscoveryGroupConfiguration> getDiscoveryGroupConfigurations()
Configuration setDiscoveryGroupConfigurations(Map<String,DiscoveryGroupConfiguration> configs)
Configuration addDiscoveryGroupConfiguration(String key, DiscoveryGroupConfiguration discoveryGroupConfiguration)
GroupingHandlerConfiguration getGroupingHandlerConfiguration()
Configuration setGroupingHandlerConfiguration(GroupingHandlerConfiguration groupingHandlerConfiguration)
List<BridgeConfiguration> getBridgeConfigurations()
Configuration setBridgeConfigurations(List<BridgeConfiguration> configs)
List<DivertConfiguration> getDivertConfigurations()
Configuration setDivertConfigurations(List<DivertConfiguration> configs)
Configuration addDivertConfiguration(DivertConfiguration config)
List<ClusterConnectionConfiguration> getClusterConfigurations()
Modifying the returned list will modify the list of ClusterConnectionConfiguration
used by this configuration.
Configuration setClusterConfigurations(List<ClusterConnectionConfiguration> configs)
Configuration addClusterConfiguration(ClusterConnectionConfiguration config)
ClusterConnectionConfiguration addClusterConfiguration(String name, String uri) throws Exception
Exception
Configuration clearClusterConfigurations()
List<CoreQueueConfiguration> getQueueConfigurations()
Configuration setQueueConfigurations(List<CoreQueueConfiguration> configs)
Configuration addQueueConfiguration(CoreQueueConfiguration config)
SimpleString getManagementAddress()
ActiveMQDefaultConfiguration.DEFAULT_MANAGEMENT_ADDRESS
.Configuration setManagementAddress(SimpleString address)
SimpleString getManagementNotificationAddress()
ActiveMQDefaultConfiguration.DEFAULT_MANAGEMENT_NOTIFICATION_ADDRESS
.Configuration setManagementNotificationAddress(SimpleString address)
String getClusterUser()
ActiveMQDefaultConfiguration.DEFAULT_CLUSTER_USER
.Configuration setClusterUser(String user)
String getClusterPassword()
ActiveMQDefaultConfiguration.DEFAULT_CLUSTER_PASSWORD
.Configuration setClusterPassword(String password)
int getIDCacheSize()
ActiveMQDefaultConfiguration.DEFAULT_ID_CACHE_SIZE
.Configuration setIDCacheSize(int idCacheSize)
boolean isPersistIDCache()
ActiveMQDefaultConfiguration.DEFAULT_PERSIST_ID_CACHE
.Configuration setPersistIDCache(boolean persist)
String getBindingsDirectory()
ActiveMQDefaultConfiguration.DEFAULT_BINDINGS_DIRECTORY
.File getBindingsLocation()
Configuration setBindingsDirectory(String dir)
int getPageMaxConcurrentIO()
Default value is ActiveMQDefaultConfiguration.DEFAULT_MAX_CONCURRENT_PAGE_IO
.
Configuration setPageMaxConcurrentIO(int maxIO)
Default = 5
String getJournalDirectory()
ActiveMQDefaultConfiguration.DEFAULT_JOURNAL_DIR
.File getJournalLocation()
Configuration setJournalDirectory(String dir)
JournalType getJournalType()
NIO
, ASYNCIO
or MAPPED
).
Configuration setJournalType(JournalType type)
NIO
or ASYNCIO
).boolean isJournalSyncTransactional()
ActiveMQDefaultConfiguration.DEFAULT_JOURNAL_SYNC_TRANSACTIONAL
.Configuration setJournalSyncTransactional(boolean sync)
boolean isJournalSyncNonTransactional()
ActiveMQDefaultConfiguration.DEFAULT_JOURNAL_SYNC_NON_TRANSACTIONAL
.Configuration setJournalSyncNonTransactional(boolean sync)
int getJournalFileSize()
ActiveMQDefaultConfiguration.DEFAULT_JOURNAL_FILE_SIZE
.Configuration setJournalFileSize(int size)
int getJournalCompactMinFiles()
ActiveMQDefaultConfiguration.DEFAULT_JOURNAL_COMPACT_MIN_FILES
.Configuration setJournalCompactMinFiles(int minFiles)
int getJournalPoolFiles()
ActiveMQDefaultConfiguration.DEFAULT_JOURNAL_POOL_FILES
.Configuration setJournalPoolFiles(int poolSize)
ActiveMQDefaultConfiguration.DEFAULT_JOURNAL_POOL_FILES
.int getJournalCompactPercentage()
ActiveMQDefaultConfiguration.DEFAULT_JOURNAL_COMPACT_PERCENTAGE
.Configuration setJournalCompactPercentage(int percentage)
int getJournalMinFiles()
ActiveMQDefaultConfiguration.DEFAULT_JOURNAL_MIN_FILES
.Configuration setJournalMinFiles(int files)
int getJournalMaxIO_AIO()
ActiveMQDefaultConfiguration.DEFAULT_JOURNAL_MAX_IO_AIO
.Configuration setJournalMaxIO_AIO(int journalMaxIO)
int getJournalBufferTimeout_AIO()
ArtemisConstants.DEFAULT_JOURNAL_BUFFER_TIMEOUT_AIO
.Configuration setJournalBufferTimeout_AIO(int journalBufferTimeout)
int getJournalBufferSize_AIO()
ArtemisConstants.DEFAULT_JOURNAL_BUFFER_SIZE_AIO
.Configuration setJournalBufferSize_AIO(int journalBufferSize)
int getJournalMaxIO_NIO()
ActiveMQDefaultConfiguration.DEFAULT_JOURNAL_MAX_IO_NIO
.Configuration setJournalMaxIO_NIO(int journalMaxIO)
int getJournalBufferTimeout_NIO()
ArtemisConstants.DEFAULT_JOURNAL_BUFFER_TIMEOUT_NIO
.Configuration setJournalBufferTimeout_NIO(int journalBufferTimeout)
int getJournalBufferSize_NIO()
ArtemisConstants.DEFAULT_JOURNAL_BUFFER_SIZE_NIO
.Configuration setJournalBufferSize_NIO(int journalBufferSize)
boolean isCreateBindingsDir()
ActiveMQDefaultConfiguration.DEFAULT_CREATE_BINDINGS_DIR
.Configuration setCreateBindingsDir(boolean create)
boolean isCreateJournalDir()
ActiveMQDefaultConfiguration.DEFAULT_CREATE_JOURNAL_DIR
.Configuration setCreateJournalDir(boolean create)
boolean isLogJournalWriteRate()
Configuration setLogJournalWriteRate(boolean rate)
int getJournalPerfBlastPages()
Configuration setJournalPerfBlastPages(int pages)
long getServerDumpInterval()
Configuration setServerDumpInterval(long interval)
int getMemoryWarningThreshold()
Configuration setMemoryWarningThreshold(int memoryWarningThreshold)
long getMemoryMeasureInterval()
Configuration setMemoryMeasureInterval(long memoryMeasureInterval)
boolean isRunSyncSpeedTest()
Configuration setRunSyncSpeedTest(boolean run)
String getPagingDirectory()
ActiveMQDefaultConfiguration.DEFAULT_PAGING_DIR
.Configuration setPagingDirectory(String dir)
File getPagingLocation()
String getLargeMessagesDirectory()
ActiveMQDefaultConfiguration.DEFAULT_LARGE_MESSAGES_DIR
.File getLargeMessagesLocation()
Configuration setLargeMessagesDirectory(String directory)
boolean isWildcardRoutingEnabled()
ActiveMQDefaultConfiguration.DEFAULT_WILDCARD_ROUTING_ENABLED
.Configuration setWildcardRoutingEnabled(boolean enabled)
long getTransactionTimeout()
ActiveMQDefaultConfiguration.DEFAULT_TRANSACTION_TIMEOUT
.Configuration setTransactionTimeout(long timeout)
boolean isMessageCounterEnabled()
ActiveMQDefaultConfiguration.DEFAULT_MESSAGE_COUNTER_ENABLED
.Configuration setMessageCounterEnabled(boolean enabled)
long getMessageCounterSamplePeriod()
ActiveMQDefaultConfiguration.DEFAULT_MESSAGE_COUNTER_SAMPLE_PERIOD
.Configuration setMessageCounterSamplePeriod(long period)
period
- value must be greater than 1000msint getMessageCounterMaxDayHistory()
ActiveMQDefaultConfiguration.DEFAULT_MESSAGE_COUNTER_MAX_DAY_HISTORY
.Configuration setMessageCounterMaxDayHistory(int maxDayHistory)
maxDayHistory
- value must be greater than 0long getTransactionTimeoutScanPeriod()
ActiveMQDefaultConfiguration.DEFAULT_TRANSACTION_TIMEOUT_SCAN_PERIOD
.Configuration setTransactionTimeoutScanPeriod(long period)
long getMessageExpiryScanPeriod()
ActiveMQDefaultConfiguration.DEFAULT_MESSAGE_EXPIRY_SCAN_PERIOD
.Configuration setMessageExpiryScanPeriod(long messageExpiryScanPeriod)
int getMessageExpiryThreadPriority()
ActiveMQDefaultConfiguration.DEFAULT_MESSAGE_EXPIRY_THREAD_PRIORITY
.Configuration setMessageExpiryThreadPriority(int messageExpiryThreadPriority)
Map<String,AddressSettings> getAddressesSettings()
Configuration setAddressesSettings(Map<String,AddressSettings> addressesSettings)
addressesSettings
- list of AddressSettings per matching to be deployed to the address
settings repositoryConfiguration addAddressesSetting(String key, AddressSettings addressesSetting)
Configuration clearAddressesSettings()
Configuration setSecurityRoles(Map<String,Set<Role>> roles)
roles
- a list of roles per matchingConfiguration putSecurityRoles(String match, Set<Role> roles)
Configuration setConnectorServiceConfigurations(List<ConnectorServiceConfiguration> configs)
Configuration addConnectorServiceConfiguration(ConnectorServiceConfiguration config)
Configuration setSecuritySettingPlugins(List<SecuritySettingPlugin> plugins)
Configuration addSecuritySettingPlugin(SecuritySettingPlugin plugin)
List<ConnectorServiceConfiguration> getConnectorServiceConfigurations()
ConnectorServiceConfiguration
List<SecuritySettingPlugin> getSecuritySettingPlugins()
Configuration setPasswordCodec(String codec)
String getPasswordCodec()
Configuration setMaskPassword(boolean maskPassword)
boolean isMaskPassword()
Configuration setResolveProtocols(boolean resolveProtocols)
TransportConfiguration[] getTransportConfigurations(String... connectorNames)
TransportConfiguration[] getTransportConfigurations(List<String> connectorNames)
boolean isResolveProtocols()
Configuration copy() throws Exception
Exception
Configuration setJournalLockAcquisitionTimeout(long journalLockAcquisitionTimeout)
long getJournalLockAcquisitionTimeout()
HAPolicyConfiguration getHAPolicyConfiguration()
Configuration setHAPolicyConfiguration(HAPolicyConfiguration haPolicyConfiguration)
void setBrokerInstance(File directory)
File getBrokerInstance()
StoreConfiguration getStoreConfiguration()
Configuration setStoreConfiguration(StoreConfiguration storeConfiguration)
boolean isPopulateValidatedUser()
Configuration setPopulateValidatedUser(boolean populateValidatedUser)
String debugConnectors()
Configuration setConnectionTtlCheckInterval(long connectionTtlCheckInterval)
long getConnectionTtlCheckInterval()
URL getConfigurationUrl()
Configuration setConfigurationUrl(URL configurationUrl)
long getConfigurationFileRefreshPeriod()
Configuration setConfigurationFileRefreshPeriod(long configurationFileRefreshPeriod)
long getGlobalMaxSize()
Configuration setGlobalMaxSize(long globalMaxSize)
int getMaxDiskUsage()
Configuration setMaxDiskUsage(int maxDiskUsage)
Configuration setDiskScanPeriod(int diskScanPeriod)
int getDiskScanPeriod()
Configuration setNetworkCheckList(String list)
String getNetworkCheckList()
Configuration setNetworkCheckURLList(String uris)
String getNetworkCheckURLList()
Configuration setNetworkCheckPeriod(long period)
long getNetworkCheckPeriod()
Configuration setNetworkCheckTimeout(int timeout)
int getNetworkCheckTimeout()
Configuration setNetworCheckNIC(String nic)
String getNetworkCheckNIC()
String getNetworkCheckPingCommand()
Configuration setNetworkCheckPingCommand(String command)
String getNetworkCheckPing6Command()
Configuration setNetworkCheckPing6Command(String command)
Copyright © 2017 JBoss by Red Hat. All rights reserved.