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) |
ConfigurationImpl |
addAddressesSetting(String key,
AddressSettings addressesSetting) |
ConfigurationImpl |
addBridgeConfiguration(BridgeConfiguration config) |
ConfigurationImpl |
addBroadcastGroupConfiguration(BroadcastGroupConfiguration config) |
ConfigurationImpl |
addClusterConfiguration(ClusterConnectionConfiguration config) |
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) |
ConfigurationImpl |
clearAcceptorConfigurations() |
ConfigurationImpl |
clearAddressesSettings() |
ConfigurationImpl |
clearClusterConfigurations() |
ConfigurationImpl |
clearConnectorConfigurations() |
Configuration |
copy() |
boolean |
equals(Object obj) |
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.
|
int |
hashCode() |
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 |
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 |
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.
|
ConfigurationImpl |
setAcceptorConfigurations(Set<TransportConfiguration> infos)
Sets the acceptors configured for this server.
|
ConfigurationImpl |
setAddressesSettings(Map<String,AddressSettings> addressesSettings) |
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 |
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.
|
ConfigurationImpl |
setDiscoveryGroupConfigurations(Map<String,DiscoveryGroupConfiguration> discoveryGroupConfigurations)
Sets the discovery groups configured for this server.
|
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 |
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 |
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 |
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 |
setJournalDirectory(String dir)
Sets the file system directory used to store journal log.
|
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.
|
ConfigurationImpl |
setJournalPerfBlastPages(int journalPerfBlastPages) |
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 |
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
|
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 |
setQueueConfigurations(List<CoreQueueConfiguration> configs)
Sets the queues configured for this server.
|
ConfigurationImpl |
setResolveProtocols(boolean resolveProtocols) |
ConfigurationImpl |
setResourceLimitSettings(Map<String,ResourceLimitSettings> resourceLimitSettings) |
ConfigurationImpl |
setRunSyncSpeedTest(boolean run) |
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 |
setServerDumpInterval(long intervalInMilliseconds) |
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.
|
ConfigurationImpl |
setWildcardRoutingEnabled(boolean enabled)
Sets whether wildcard routing is supported by this server.
|
String |
toString() |
public static final JournalType DEFAULT_JOURNAL_TYPE
protected long fileDeploymentScanPeriod
protected boolean jmxManagementEnabled
protected String jmxDomain
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 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 int journalPerfBlastPages
protected boolean runSyncSpeedTest
protected String clusterUser
protected String clusterPassword
protected boolean failoverOnServerShutdown
protected GroupingHandlerConfiguration groupingHandlerConfiguration
protected List<ConnectorServiceConfiguration> connectorServiceConfigurations
public boolean isClustered()
Configurationtrue if Configuration.getClusterConfigurations() is not empty.isClustered in interface Configurationpublic boolean isPersistenceEnabled()
ConfigurationActiveMQDefaultConfiguration.DEFAULT_PERSISTENCE_ENABLED.isPersistenceEnabled in interface Configurationpublic ConfigurationImpl setPersistenceEnabled(boolean enable)
ConfigurationsetPersistenceEnabled in interface Configurationpublic long getFileDeployerScanPeriod()
ConfigurationActiveMQDefaultConfiguration.DEFAULT_FILE_DEPLOYER_SCAN_PERIOD.getFileDeployerScanPeriod in interface Configurationpublic ConfigurationImpl setFileDeployerScanPeriod(long period)
ConfigurationsetFileDeployerScanPeriod in interface Configurationpublic boolean isPersistDeliveryCountBeforeDelivery()
ConfigurationActiveMQDefaultConfiguration.DEFAULT_PERSIST_DELIVERY_COUNT_BEFORE_DELIVERYisPersistDeliveryCountBeforeDelivery in interface Configurationpublic ConfigurationImpl setPersistDeliveryCountBeforeDelivery(boolean persistDeliveryCountBeforeDelivery)
ConfigurationsetPersistDeliveryCountBeforeDelivery in interface Configurationpublic int getScheduledThreadPoolMaxSize()
ConfigurationActiveMQDefaultConfiguration.DEFAULT_SCHEDULED_THREAD_POOL_MAX_SIZE.getScheduledThreadPoolMaxSize in interface Configurationpublic ConfigurationImpl setScheduledThreadPoolMaxSize(int maxSize)
ConfigurationsetScheduledThreadPoolMaxSize in interface Configurationpublic int getThreadPoolMaxSize()
ConfigurationActiveMQDefaultConfiguration.DEFAULT_THREAD_POOL_MAX_SIZE.getThreadPoolMaxSize in interface Configurationpublic ConfigurationImpl setThreadPoolMaxSize(int maxSize)
ConfigurationsetThreadPoolMaxSize in interface Configurationpublic long getSecurityInvalidationInterval()
ConfigurationActiveMQDefaultConfiguration.DEFAULT_SECURITY_INVALIDATION_INTERVAL.getSecurityInvalidationInterval in interface Configurationpublic ConfigurationImpl setSecurityInvalidationInterval(long interval)
ConfigurationsetSecurityInvalidationInterval in interface Configurationpublic long getConnectionTTLOverride()
ConfigurationActiveMQDefaultConfiguration.DEFAULT_CONNECTION_TTL_OVERRIDE.getConnectionTTLOverride in interface Configurationpublic ConfigurationImpl setConnectionTTLOverride(long ttl)
ConfigurationsetConnectionTTLOverride in interface Configurationpublic boolean isAsyncConnectionExecutionEnabled()
ConfigurationActiveMQDefaultConfiguration.DEFAULT_ASYNC_CONNECTION_EXECUTION_ENABLED.isAsyncConnectionExecutionEnabled in interface Configurationpublic ConfigurationImpl setEnabledAsyncConnectionExecution(boolean enabled)
ConfigurationsetEnabledAsyncConnectionExecution in interface Configurationpublic List<String> getIncomingInterceptorClassNames()
ConfigurationgetIncomingInterceptorClassNames in interface Configurationpublic ConfigurationImpl setIncomingInterceptorClassNames(List<String> interceptors)
ConfigurationInterceptor.setIncomingInterceptorClassNames in interface Configurationpublic List<String> getOutgoingInterceptorClassNames()
ConfigurationgetOutgoingInterceptorClassNames in interface Configurationpublic ConfigurationImpl setOutgoingInterceptorClassNames(List<String> interceptors)
ConfigurationInterceptor.setOutgoingInterceptorClassNames in interface Configurationpublic Set<TransportConfiguration> getAcceptorConfigurations()
ConfigurationgetAcceptorConfigurations in interface Configurationpublic ConfigurationImpl setAcceptorConfigurations(Set<TransportConfiguration> infos)
ConfigurationsetAcceptorConfigurations in interface Configurationpublic ConfigurationImpl addAcceptorConfiguration(TransportConfiguration infos)
addAcceptorConfiguration in interface Configurationpublic ConfigurationImpl addAcceptorConfiguration(String name, String uri) throws Exception
ConfigurationaddAcceptorConfiguration in interface Configurationname - the name of the acceptoruri - the URI of the acceptorException - in case of Parsing errors on the URIpublic ConfigurationImpl clearAcceptorConfigurations()
clearAcceptorConfigurations in interface Configurationpublic Map<String,TransportConfiguration> getConnectorConfigurations()
ConfigurationgetConnectorConfigurations in interface Configurationpublic ConfigurationImpl setConnectorConfigurations(Map<String,TransportConfiguration> infos)
ConfigurationsetConnectorConfigurations in interface Configurationpublic ConfigurationImpl addConnectorConfiguration(String key, TransportConfiguration info)
addConnectorConfiguration in interface Configurationpublic ConfigurationImpl addConnectorConfiguration(String name, String uri) throws Exception
addConnectorConfiguration in interface ConfigurationExceptionpublic ConfigurationImpl clearConnectorConfigurations()
clearConnectorConfigurations in interface Configurationpublic GroupingHandlerConfiguration getGroupingHandlerConfiguration()
ConfigurationgetGroupingHandlerConfiguration in interface Configurationpublic ConfigurationImpl setGroupingHandlerConfiguration(GroupingHandlerConfiguration groupingHandlerConfiguration)
ConfigurationsetGroupingHandlerConfiguration in interface Configurationpublic List<BridgeConfiguration> getBridgeConfigurations()
ConfigurationgetBridgeConfigurations in interface Configurationpublic ConfigurationImpl setBridgeConfigurations(List<BridgeConfiguration> configs)
ConfigurationsetBridgeConfigurations in interface Configurationpublic ConfigurationImpl addBridgeConfiguration(BridgeConfiguration config)
public List<BroadcastGroupConfiguration> getBroadcastGroupConfigurations()
ConfigurationgetBroadcastGroupConfigurations in interface Configurationpublic ConfigurationImpl setBroadcastGroupConfigurations(List<BroadcastGroupConfiguration> configs)
ConfigurationsetBroadcastGroupConfigurations in interface Configurationpublic ConfigurationImpl addBroadcastGroupConfiguration(BroadcastGroupConfiguration config)
addBroadcastGroupConfiguration in interface Configurationpublic List<ClusterConnectionConfiguration> getClusterConfigurations()
Configuration
Modifying the returned list will modify the list of ClusterConnectionConfiguration
used by this configuration.
getClusterConfigurations in interface Configurationpublic ConfigurationImpl setClusterConfigurations(List<ClusterConnectionConfiguration> configs)
ConfigurationsetClusterConfigurations in interface Configurationpublic ConfigurationImpl addClusterConfiguration(ClusterConnectionConfiguration config)
addClusterConfiguration in interface Configurationpublic ConfigurationImpl clearClusterConfigurations()
clearClusterConfigurations in interface Configurationpublic List<DivertConfiguration> getDivertConfigurations()
ConfigurationgetDivertConfigurations in interface Configurationpublic ConfigurationImpl setDivertConfigurations(List<DivertConfiguration> configs)
ConfigurationsetDivertConfigurations in interface Configurationpublic ConfigurationImpl addDivertConfiguration(DivertConfiguration config)
addDivertConfiguration in interface Configurationpublic List<CoreQueueConfiguration> getQueueConfigurations()
ConfigurationgetQueueConfigurations in interface Configurationpublic ConfigurationImpl setQueueConfigurations(List<CoreQueueConfiguration> configs)
ConfigurationsetQueueConfigurations in interface Configurationpublic ConfigurationImpl addQueueConfiguration(CoreQueueConfiguration config)
addQueueConfiguration in interface Configurationpublic Map<String,DiscoveryGroupConfiguration> getDiscoveryGroupConfigurations()
ConfigurationgetDiscoveryGroupConfigurations in interface Configurationpublic ConfigurationImpl setDiscoveryGroupConfigurations(Map<String,DiscoveryGroupConfiguration> discoveryGroupConfigurations)
ConfigurationsetDiscoveryGroupConfigurations in interface Configurationpublic ConfigurationImpl addDiscoveryGroupConfiguration(String key, DiscoveryGroupConfiguration discoveryGroupConfiguration)
addDiscoveryGroupConfiguration in interface Configurationpublic int getIDCacheSize()
ConfigurationActiveMQDefaultConfiguration.DEFAULT_ID_CACHE_SIZE.getIDCacheSize in interface Configurationpublic ConfigurationImpl setIDCacheSize(int idCacheSize)
ConfigurationsetIDCacheSize in interface Configurationpublic boolean isPersistIDCache()
ConfigurationActiveMQDefaultConfiguration.DEFAULT_PERSIST_ID_CACHE.isPersistIDCache in interface Configurationpublic ConfigurationImpl setPersistIDCache(boolean persist)
ConfigurationsetPersistIDCache in interface Configurationpublic File getBindingsLocation()
ConfigurationgetBindingsLocation in interface Configurationpublic String getBindingsDirectory()
ConfigurationActiveMQDefaultConfiguration.DEFAULT_BINDINGS_DIRECTORY.getBindingsDirectory in interface Configurationpublic ConfigurationImpl setBindingsDirectory(String dir)
ConfigurationsetBindingsDirectory in interface Configurationpublic int getPageMaxConcurrentIO()
Configuration
Default value is ActiveMQDefaultConfiguration.DEFAULT_MAX_CONCURRENT_PAGE_IO.
getPageMaxConcurrentIO in interface Configurationpublic ConfigurationImpl setPageMaxConcurrentIO(int maxIO)
ConfigurationDefault = 5
setPageMaxConcurrentIO in interface Configurationpublic File getJournalLocation()
ConfigurationgetJournalLocation in interface Configurationpublic String getJournalDirectory()
ConfigurationActiveMQDefaultConfiguration.DEFAULT_JOURNAL_DIR.getJournalDirectory in interface Configurationpublic ConfigurationImpl setJournalDirectory(String dir)
ConfigurationsetJournalDirectory in interface Configurationpublic JournalType getJournalType()
ConfigurationNIO or ASYNCIO).
getJournalType in interface Configurationpublic ConfigurationImpl setPagingDirectory(String dir)
ConfigurationsetPagingDirectory in interface Configurationpublic File getPagingLocation()
ConfigurationgetPagingLocation in interface Configurationpublic String getPagingDirectory()
ConfigurationActiveMQDefaultConfiguration.DEFAULT_PAGING_DIR.getPagingDirectory in interface Configurationpublic ConfigurationImpl setJournalType(JournalType type)
ConfigurationNIO or ASYNCIO).setJournalType in interface Configurationpublic boolean isJournalSyncTransactional()
ConfigurationActiveMQDefaultConfiguration.DEFAULT_JOURNAL_SYNC_TRANSACTIONAL.isJournalSyncTransactional in interface Configurationpublic ConfigurationImpl setJournalSyncTransactional(boolean sync)
ConfigurationsetJournalSyncTransactional in interface Configurationpublic boolean isJournalSyncNonTransactional()
ConfigurationActiveMQDefaultConfiguration.DEFAULT_JOURNAL_SYNC_NON_TRANSACTIONAL.isJournalSyncNonTransactional in interface Configurationpublic ConfigurationImpl setJournalSyncNonTransactional(boolean sync)
ConfigurationsetJournalSyncNonTransactional in interface Configurationpublic int getJournalFileSize()
ConfigurationActiveMQDefaultConfiguration.DEFAULT_JOURNAL_FILE_SIZE.getJournalFileSize in interface Configurationpublic ConfigurationImpl setJournalFileSize(int size)
ConfigurationsetJournalFileSize in interface Configurationpublic int getJournalPoolFiles()
Configurationorg.apache.activemq.artemis.api.config.ActiveMQDefaultConfiguration#DEFAULT_JOURNAL_POOL_SIZE.getJournalPoolFiles in interface Configurationpublic Configuration setJournalPoolFiles(int poolSize)
Configurationorg.apache.activemq.artemis.api.config.ActiveMQDefaultConfiguration#DEFAULT_JOURNAL_POOL_SIZE.setJournalPoolFiles in interface Configurationpublic int getJournalMinFiles()
ConfigurationActiveMQDefaultConfiguration.DEFAULT_JOURNAL_MIN_FILES.getJournalMinFiles in interface Configurationpublic ConfigurationImpl setJournalMinFiles(int files)
ConfigurationsetJournalMinFiles in interface Configurationpublic boolean isLogJournalWriteRate()
isLogJournalWriteRate in interface Configurationpublic ConfigurationImpl setLogJournalWriteRate(boolean logJournalWriteRate)
setLogJournalWriteRate in interface Configurationpublic int getJournalPerfBlastPages()
getJournalPerfBlastPages in interface Configurationpublic ConfigurationImpl setJournalPerfBlastPages(int journalPerfBlastPages)
setJournalPerfBlastPages in interface Configurationpublic boolean isRunSyncSpeedTest()
isRunSyncSpeedTest in interface Configurationpublic ConfigurationImpl setRunSyncSpeedTest(boolean run)
setRunSyncSpeedTest in interface Configurationpublic boolean isCreateBindingsDir()
ConfigurationActiveMQDefaultConfiguration.DEFAULT_CREATE_BINDINGS_DIR.isCreateBindingsDir in interface Configurationpublic ConfigurationImpl setCreateBindingsDir(boolean create)
ConfigurationsetCreateBindingsDir in interface Configurationpublic boolean isCreateJournalDir()
ConfigurationActiveMQDefaultConfiguration.DEFAULT_CREATE_JOURNAL_DIR.isCreateJournalDir in interface Configurationpublic ConfigurationImpl setCreateJournalDir(boolean create)
ConfigurationsetCreateJournalDir in interface Configurationpublic boolean isWildcardRoutingEnabled()
ConfigurationActiveMQDefaultConfiguration.DEFAULT_WILDCARD_ROUTING_ENABLED.isWildcardRoutingEnabled in interface Configurationpublic ConfigurationImpl setWildcardRoutingEnabled(boolean enabled)
ConfigurationsetWildcardRoutingEnabled in interface Configurationpublic long getTransactionTimeout()
ConfigurationActiveMQDefaultConfiguration.DEFAULT_TRANSACTION_TIMEOUT.getTransactionTimeout in interface Configurationpublic ConfigurationImpl setTransactionTimeout(long timeout)
ConfigurationsetTransactionTimeout in interface Configurationpublic long getTransactionTimeoutScanPeriod()
ConfigurationActiveMQDefaultConfiguration.DEFAULT_TRANSACTION_TIMEOUT_SCAN_PERIOD.getTransactionTimeoutScanPeriod in interface Configurationpublic ConfigurationImpl setTransactionTimeoutScanPeriod(long period)
ConfigurationsetTransactionTimeoutScanPeriod in interface Configurationpublic long getMessageExpiryScanPeriod()
ConfigurationActiveMQDefaultConfiguration.DEFAULT_MESSAGE_EXPIRY_SCAN_PERIOD.getMessageExpiryScanPeriod in interface Configurationpublic ConfigurationImpl setMessageExpiryScanPeriod(long messageExpiryScanPeriod)
ConfigurationsetMessageExpiryScanPeriod in interface Configurationpublic int getMessageExpiryThreadPriority()
ConfigurationActiveMQDefaultConfiguration.DEFAULT_MESSAGE_EXPIRY_THREAD_PRIORITY.getMessageExpiryThreadPriority in interface Configurationpublic ConfigurationImpl setMessageExpiryThreadPriority(int messageExpiryThreadPriority)
ConfigurationsetMessageExpiryThreadPriority in interface Configurationpublic boolean isSecurityEnabled()
ConfigurationActiveMQDefaultConfiguration.DEFAULT_SECURITY_ENABLED.isSecurityEnabled in interface Configurationpublic ConfigurationImpl setSecurityEnabled(boolean enabled)
ConfigurationsetSecurityEnabled in interface Configurationpublic boolean isGracefulShutdownEnabled()
ConfigurationActiveMQDefaultConfiguration.DEFAULT_SECURITY_ENABLED.isGracefulShutdownEnabled in interface Configurationpublic ConfigurationImpl setGracefulShutdownEnabled(boolean enabled)
ConfigurationsetGracefulShutdownEnabled in interface Configurationpublic long getGracefulShutdownTimeout()
ConfigurationActiveMQDefaultConfiguration.DEFAULT_GRACEFUL_SHUTDOWN_TIMEOUT.getGracefulShutdownTimeout in interface Configurationpublic ConfigurationImpl setGracefulShutdownTimeout(long timeout)
ConfigurationsetGracefulShutdownTimeout in interface Configurationpublic boolean isJMXManagementEnabled()
ConfigurationActiveMQDefaultConfiguration.DEFAULT_JMX_MANAGEMENT_ENABLED.isJMXManagementEnabled in interface Configurationpublic ConfigurationImpl setJMXManagementEnabled(boolean enabled)
ConfigurationActiveMQDefaultConfiguration.DEFAULT_JMX_MANAGEMENT_ENABLED.setJMXManagementEnabled in interface Configurationpublic String getJMXDomain()
ConfigurationActiveMQDefaultConfiguration.DEFAULT_JMX_DOMAIN.getJMXDomain in interface Configurationpublic ConfigurationImpl setJMXDomain(String domain)
ConfigurationChanging 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 Configurationpublic String getLargeMessagesDirectory()
ConfigurationActiveMQDefaultConfiguration.DEFAULT_LARGE_MESSAGES_DIR.getLargeMessagesDirectory in interface Configurationpublic File getLargeMessagesLocation()
ConfigurationgetLargeMessagesLocation in interface Configurationpublic ConfigurationImpl setLargeMessagesDirectory(String directory)
ConfigurationsetLargeMessagesDirectory in interface Configurationpublic boolean isMessageCounterEnabled()
ConfigurationActiveMQDefaultConfiguration.DEFAULT_MESSAGE_COUNTER_ENABLED.isMessageCounterEnabled in interface Configurationpublic ConfigurationImpl setMessageCounterEnabled(boolean enabled)
ConfigurationsetMessageCounterEnabled in interface Configurationpublic long getMessageCounterSamplePeriod()
ConfigurationActiveMQDefaultConfiguration.DEFAULT_MESSAGE_COUNTER_SAMPLE_PERIOD.getMessageCounterSamplePeriod in interface Configurationpublic ConfigurationImpl setMessageCounterSamplePeriod(long period)
ConfigurationsetMessageCounterSamplePeriod in interface Configurationperiod - value must be greater than 1000mspublic int getMessageCounterMaxDayHistory()
ConfigurationActiveMQDefaultConfiguration.DEFAULT_MESSAGE_COUNTER_MAX_DAY_HISTORY.getMessageCounterMaxDayHistory in interface Configurationpublic ConfigurationImpl setMessageCounterMaxDayHistory(int maxDayHistory)
ConfigurationsetMessageCounterMaxDayHistory in interface ConfigurationmaxDayHistory - value must be greater than 0public SimpleString getManagementAddress()
ConfigurationActiveMQDefaultConfiguration.DEFAULT_MANAGEMENT_ADDRESS.getManagementAddress in interface Configurationpublic ConfigurationImpl setManagementAddress(SimpleString address)
ConfigurationsetManagementAddress in interface Configurationpublic SimpleString getManagementNotificationAddress()
ConfigurationActiveMQDefaultConfiguration.DEFAULT_MANAGEMENT_NOTIFICATION_ADDRESS.getManagementNotificationAddress in interface Configurationpublic ConfigurationImpl setManagementNotificationAddress(SimpleString address)
ConfigurationsetManagementNotificationAddress in interface Configurationpublic String getClusterUser()
ConfigurationActiveMQDefaultConfiguration.DEFAULT_CLUSTER_USER.getClusterUser in interface Configurationpublic ConfigurationImpl setClusterUser(String user)
ConfigurationsetClusterUser in interface Configurationpublic String getClusterPassword()
ConfigurationActiveMQDefaultConfiguration.DEFAULT_CLUSTER_PASSWORD.getClusterPassword in interface Configurationpublic boolean isFailoverOnServerShutdown()
public ConfigurationImpl setFailoverOnServerShutdown(boolean failoverOnServerShutdown)
public ConfigurationImpl setClusterPassword(String theclusterPassword)
ConfigurationsetClusterPassword in interface Configurationpublic int getJournalCompactMinFiles()
ConfigurationActiveMQDefaultConfiguration.DEFAULT_JOURNAL_COMPACT_MIN_FILES.getJournalCompactMinFiles in interface Configurationpublic int getJournalCompactPercentage()
ConfigurationActiveMQDefaultConfiguration.DEFAULT_JOURNAL_COMPACT_PERCENTAGE.getJournalCompactPercentage in interface Configurationpublic ConfigurationImpl setJournalCompactMinFiles(int minFiles)
ConfigurationsetJournalCompactMinFiles in interface Configurationpublic ConfigurationImpl setJournalCompactPercentage(int percentage)
ConfigurationsetJournalCompactPercentage in interface Configurationpublic long getServerDumpInterval()
getServerDumpInterval in interface Configurationpublic ConfigurationImpl setServerDumpInterval(long intervalInMilliseconds)
setServerDumpInterval in interface Configurationpublic int getMemoryWarningThreshold()
getMemoryWarningThreshold in interface Configurationpublic ConfigurationImpl setMemoryWarningThreshold(int memoryWarningThreshold)
setMemoryWarningThreshold in interface Configurationpublic long getMemoryMeasureInterval()
getMemoryMeasureInterval in interface Configurationpublic ConfigurationImpl setMemoryMeasureInterval(long memoryMeasureInterval)
setMemoryMeasureInterval in interface Configurationpublic int getJournalMaxIO_AIO()
ConfigurationActiveMQDefaultConfiguration.DEFAULT_JOURNAL_MAX_IO_AIO.getJournalMaxIO_AIO in interface Configurationpublic ConfigurationImpl setJournalMaxIO_AIO(int journalMaxIO)
ConfigurationsetJournalMaxIO_AIO in interface Configurationpublic int getJournalBufferTimeout_AIO()
ConfigurationJournalConstants.DEFAULT_JOURNAL_BUFFER_TIMEOUT_AIO.getJournalBufferTimeout_AIO in interface Configurationpublic ConfigurationImpl setJournalBufferTimeout_AIO(int journalBufferTimeout)
ConfigurationsetJournalBufferTimeout_AIO in interface Configurationpublic int getJournalBufferSize_AIO()
ConfigurationJournalConstants.DEFAULT_JOURNAL_BUFFER_SIZE_AIO.getJournalBufferSize_AIO in interface Configurationpublic ConfigurationImpl setJournalBufferSize_AIO(int journalBufferSize)
ConfigurationsetJournalBufferSize_AIO in interface Configurationpublic int getJournalMaxIO_NIO()
ConfigurationActiveMQDefaultConfiguration.DEFAULT_JOURNAL_MAX_IO_NIO.getJournalMaxIO_NIO in interface Configurationpublic ConfigurationImpl setJournalMaxIO_NIO(int journalMaxIO)
ConfigurationsetJournalMaxIO_NIO in interface Configurationpublic int getJournalBufferTimeout_NIO()
ConfigurationJournalConstants.DEFAULT_JOURNAL_BUFFER_TIMEOUT_NIO.getJournalBufferTimeout_NIO in interface Configurationpublic ConfigurationImpl setJournalBufferTimeout_NIO(int journalBufferTimeout)
ConfigurationsetJournalBufferTimeout_NIO in interface Configurationpublic int getJournalBufferSize_NIO()
ConfigurationJournalConstants.DEFAULT_JOURNAL_BUFFER_SIZE_NIO.getJournalBufferSize_NIO in interface Configurationpublic ConfigurationImpl setJournalBufferSize_NIO(int journalBufferSize)
ConfigurationsetJournalBufferSize_NIO in interface Configurationpublic Map<String,AddressSettings> getAddressesSettings()
getAddressesSettings in interface Configurationpublic ConfigurationImpl setAddressesSettings(Map<String,AddressSettings> addressesSettings)
setAddressesSettings in interface ConfigurationaddressesSettings - list of AddressSettings per matching to be deployed to the address
settings repositorypublic ConfigurationImpl addAddressesSetting(String key, AddressSettings addressesSetting)
addAddressesSetting in interface Configurationpublic ConfigurationImpl clearAddressesSettings()
clearAddressesSettings in interface Configurationpublic Map<String,ResourceLimitSettings> getResourceLimitSettings()
getResourceLimitSettings in interface Configurationpublic ConfigurationImpl setResourceLimitSettings(Map<String,ResourceLimitSettings> resourceLimitSettings)
setResourceLimitSettings in interface ConfigurationresourceLimitSettings - usernames mapped to ResourceLimitSettingspublic ConfigurationImpl addResourceLimitSettings(ResourceLimitSettings resourceLimitSettings)
addResourceLimitSettings in interface ConfigurationresourceLimitSettings - usernames mapped to ResourceLimitSettingspublic Map<String,Set<Role>> getSecurityRoles()
getSecurityRoles in interface Configurationpublic ConfigurationImpl setSecurityRoles(Map<String,Set<Role>> securitySettings)
setSecurityRoles in interface ConfigurationsecuritySettings - a list of roles per matchingpublic List<ConnectorServiceConfiguration> getConnectorServiceConfigurations()
getConnectorServiceConfigurations in interface ConfigurationConnectorServiceConfigurationpublic File getBrokerInstance()
ConfigurationgetBrokerInstance in interface Configurationpublic void setBrokerInstance(File directory)
ConfigurationsetBrokerInstance in interface Configurationpublic boolean isCheckForLiveServer()
public ConfigurationImpl setCheckForLiveServer(boolean checkForLiveServer)
public ConfigurationImpl setConnectorServiceConfigurations(List<ConnectorServiceConfiguration> configs)
setConnectorServiceConfigurations in interface Configurationpublic ConfigurationImpl addConnectorServiceConfiguration(ConnectorServiceConfiguration config)
addConnectorServiceConfiguration in interface Configurationpublic boolean isMaskPassword()
ConfigurationisMaskPassword in interface Configurationpublic ConfigurationImpl setMaskPassword(boolean maskPassword)
ConfigurationsetMaskPassword in interface Configurationpublic ConfigurationImpl setPasswordCodec(String codec)
ConfigurationsetPasswordCodec in interface Configurationpublic String getPasswordCodec()
ConfigurationgetPasswordCodec in interface Configurationpublic String getName()
ConfigurationgetName in interface Configurationpublic ConfigurationImpl setName(String name)
ConfigurationsetName in interface Configurationpublic ConfigurationImpl setResolveProtocols(boolean resolveProtocols)
setResolveProtocols in interface Configurationpublic boolean isResolveProtocols()
isResolveProtocols in interface Configurationpublic Configuration copy() throws Exception
copy in interface ConfigurationExceptionpublic ConfigurationImpl setJournalLockAcquisitionTimeout(long journalLockAcquisitionTimeout)
setJournalLockAcquisitionTimeout in interface Configurationpublic long getJournalLockAcquisitionTimeout()
getJournalLockAcquisitionTimeout in interface Configurationpublic HAPolicyConfiguration getHAPolicyConfiguration()
getHAPolicyConfiguration in interface Configurationpublic ConfigurationImpl setHAPolicyConfiguration(HAPolicyConfiguration haPolicyConfiguration)
setHAPolicyConfiguration in interface ConfigurationCopyright © 2016 JBoss by Red Hat. All rights reserved.