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) |
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 |
clearAcceptorConfigurations() |
Configuration |
clearAddressesSettings() |
Configuration |
clearClusterConfigurations() |
Configuration |
clearConnectorConfigurations() |
Configuration |
copy() |
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 |
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.
|
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 |
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 (either
NIO or ASYNCIO ). |
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.
|
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
|
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() |
long |
getServerDumpInterval() |
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.
|
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 |
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 |
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 |
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 |
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 |
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 |
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.
|
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 |
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 |
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 |
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 |
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 |
setServerDumpInterval(long interval) |
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)
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)
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.
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)
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
or ASYNCIO
).
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()
org.apache.activemq.artemis.api.config.ActiveMQDefaultConfiguration#DEFAULT_JOURNAL_POOL_SIZE
.Configuration setJournalPoolFiles(int poolSize)
org.apache.activemq.artemis.api.config.ActiveMQDefaultConfiguration#DEFAULT_JOURNAL_POOL_SIZE
.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()
JournalConstants.DEFAULT_JOURNAL_BUFFER_TIMEOUT_AIO
.Configuration setJournalBufferTimeout_AIO(int journalBufferTimeout)
int getJournalBufferSize_AIO()
JournalConstants.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()
JournalConstants.DEFAULT_JOURNAL_BUFFER_TIMEOUT_NIO
.Configuration setJournalBufferTimeout_NIO(int journalBufferTimeout)
int getJournalBufferSize_NIO()
JournalConstants.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 setConnectorServiceConfigurations(List<ConnectorServiceConfiguration> configs)
Configuration addConnectorServiceConfiguration(ConnectorServiceConfiguration config)
List<ConnectorServiceConfiguration> getConnectorServiceConfigurations()
ConnectorServiceConfiguration
Configuration setPasswordCodec(String codec)
String getPasswordCodec()
Configuration setMaskPassword(boolean maskPassword)
boolean isMaskPassword()
Configuration setResolveProtocols(boolean resolveProtocols)
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()
Copyright © 2016 JBoss by Red Hat. All rights reserved.