Package org.apache.activemq.artemis.core.config.impl

Class ConfigurationImpl

java.lang.Object

org.apache.activemq.artemis.core.config.impl.ConfigurationImpl

All Implemented Interfaces:

Serializable, Configuration

Direct Known Subclasses:

FileConfiguration

public class ConfigurationImpl
extends Object
implements Configuration, Serializable

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ConfigurationImpl.InsertionOrderedProperties

Field Summary

Fields

Modifier and Type	Field	Description
protected List<AMQPBrokerConnectConfiguration>	amqpBrokerConnectConfigurations
protected boolean	asyncConnectionExecutionEnabled
protected String	bindingsDirectory
protected List<BridgeConfiguration>	bridgeConfigurations
protected List<BroadcastGroupConfiguration>	broadcastGroupConfigurations
protected List<ClusterConnectionConfiguration>	clusterConfigurations
protected String	clusterPassword
protected String	clusterUser
protected List<ConnectionRouterConfiguration>	connectionRouters
protected long	connectionTTLOverride
protected Map<String,TransportConfiguration>	connectorConfigs
protected List<ConnectorServiceConfiguration>	connectorServiceConfigurations
protected boolean	createBindingsDir
protected boolean	createJournalDir
static final JournalType	DEFAULT_JOURNAL_TYPE
protected Integer	deviceBlockSize
protected Map<String,DiscoveryGroupConfiguration>	discoveryGroupConfigurations
protected List<DivertConfiguration>	divertConfigurations
protected boolean	failoverOnServerShutdown
protected List<FederationConfiguration>	federationConfigurations
protected long	fileDeploymentScanPeriod
protected GroupingHandlerConfiguration	groupingHandlerConfiguration
protected int	idCacheSize
protected String	jmxDomain
protected boolean	jmxManagementEnabled
protected boolean	jmxUseBrokerName
protected int	journalBufferSize_AIO
protected int	journalBufferSize_NIO
protected int	journalBufferTimeout_AIO
protected int	journalBufferTimeout_NIO
protected int	journalCompactMinFiles
protected int	journalCompactPercentage
protected String	journalDirectory
protected int	journalFileOpenTimeout
protected int	journalFileSize
protected int	journalMaxAtticFilesFiles
protected int	journalMaxIO_AIO
protected int	journalMaxIO_NIO
protected int	journalMinFiles
protected int	journalPoolFiles
protected String	journalRetentionDirectory
protected long	journalRetentionMaxBytes
protected long	journalRetentionPeriod
protected boolean	journalSyncNonTransactional
protected boolean	journalSyncTransactional
JournalType	journalType
protected String	largeMessagesDirectory
protected boolean	largeMessageSync
protected boolean	logJournalWriteRate
protected String	nodeManagerLockDirectory
protected boolean	populateValidatedUser
static final String	PROPERTY_CLASS_SUFFIX
static final String	REDACTED
protected boolean	rejectEmptyValidatedUser

Constructor Summary

Constructors

Constructor	Description
ConfigurationImpl()

Method Summary

Modifier and Type	Method	Description
ConfigurationImpl	addAcceptorConfiguration(String name, String uri)	Add an acceptor to the config
ConfigurationImpl	addAcceptorConfiguration(TransportConfiguration infos)
Configuration	addAddressConfiguration(CoreAddressConfiguration config)	Adds an addresses configuration
ConfigurationImpl	addAddressesSetting(String key, AddressSettings addressesSetting)	Deprecated.
ConfigurationImpl	addAddressSetting(String key, AddressSettings addressesSetting)	Add an AddressSettings to the underlying collection.
ConfigurationImpl	addAMQPConnection(AMQPBrokerConnectConfiguration amqpBrokerConnectConfiguration)
ConfigurationImpl	addBridgeConfiguration(BridgeConfiguration config)
ConfigurationImpl	addBroadcastGroupConfiguration(BroadcastGroupConfiguration config)
void	addBrokerPlugin(ActiveMQServerBasePlugin type)
ClusterConnectionConfiguration	addClusterConfiguration(String name, String uri)
ConfigurationImpl	addClusterConfiguration(ClusterConnectionConfiguration config)
ConfigurationImpl	addConnectionRouter(ConnectionRouterConfiguration config)
ConfigurationImpl	addConnectorConfiguration(String name, String uri)
ConfigurationImpl	addConnectorConfiguration(String key, TransportConfiguration info)
ConfigurationImpl	addConnectorConfiguration(TransportConfiguration info)
ConfigurationImpl	addConnectorServiceConfiguration(ConnectorServiceConfiguration config)
ConfigurationImpl	addDiscoveryGroupConfiguration(String key, DiscoveryGroupConfiguration discoveryGroupConfiguration)
ConfigurationImpl	addDivertConfiguration(DivertConfiguration config)
void	addFederationConfiguration(FederationConfiguration federationConfiguration)
ConfigurationImpl	addQueueConfiguration(QueueConfiguration config)
ConfigurationImpl	addQueueConfiguration(CoreQueueConfiguration config)	Deprecated.
ConfigurationImpl	addResourceLimitSetting(ResourceLimitSettings resourceLimitSettings)
ConfigurationImpl	addResourceLimitSettings(ResourceLimitSettings resourceLimitSettings)	Add a resource limit to the underlying collection.
ConfigurationImpl	addSecurityRole(String match, RoleSet roles)
Configuration	addSecurityRoleNameMapping(String internalRole, Set<String> externalRoles)
ConfigurationImpl	addSecuritySettingPlugin(SecuritySettingPlugin plugin)
ConfigurationImpl	clearAcceptorConfigurations()
ConfigurationImpl	clearAddressesSettings()	Deprecated.
ConfigurationImpl	clearAddressSettings()
Configuration	clearAMQPConnectionConfigurations()	Clears the current configuration object of all set or added AMQP connection configuration elements.
ConfigurationImpl	clearClusterConfigurations()
ConfigurationImpl	clearConnectorConfigurations()
Configuration	copy()
String	debugConnectors()	It will return all the connectors in a toString manner for debug purposes.
boolean	equals(Object obj)
void	exportAsProperties(File file)
protected static String	extractPropertyClassName(String property)
Set<TransportConfiguration>	getAcceptorConfigurations()	Returns the acceptors configured for this server.
List<CoreAddressConfiguration>	getAddressConfigurations()	Returns the addresses configured for this server.
Map<String,AddressSettings>	getAddressesSettings()	Deprecated.
long	getAddressQueueScanPeriod()	Returns the frequency (in milliseconds) to scan addresses and queues to detect which ones should be deleted; default is ActiveMQDefaultConfiguration.DEFAULT_MESSAGE_EXPIRY_SCAN_PERIOD.
Map<String,AddressSettings>	getAddressSettings()	Returns A list of AddressSettings per matching to be deployed to the address settings repository.
List<AMQPBrokerConnectConfiguration>	getAMQPConnection()
List<AMQPBrokerConnectConfiguration>	getAMQPConnections()
long	getAuthenticationCacheSize()	Returns the configured size of the authentication cache; default is ActiveMQDefaultConfiguration.DEFAULT_AUTHENTICATION_CACHE_SIZE.
long	getAuthorizationCacheSize()	Returns the configured size of the authorization cache; default is ActiveMQDefaultConfiguration.DEFAULT_AUTHORIZATION_CACHE_SIZE.
String	getBindingsDirectory()	Returns the file system directory used to store bindings; default is ActiveMQDefaultConfiguration.DEFAULT_BINDINGS_DIRECTORY.
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.
List<ActiveMQServerAddressPlugin>	getBrokerAddressPlugins()
List<AMQPFederationBrokerPlugin>	getBrokerAMQPFederationPlugins()
List<ActiveMQServerBindingPlugin>	getBrokerBindingPlugins()
List<ActiveMQServerBridgePlugin>	getBrokerBridgePlugins()
List<ActiveMQServerConnectionPlugin>	getBrokerConnectionPlugins()
List<ActiveMQServerConsumerPlugin>	getBrokerConsumerPlugins()
List<ActiveMQServerCriticalPlugin>	getBrokerCriticalPlugins()
List<ActiveMQServerFederationPlugin>	getBrokerFederationPlugins()
File	getBrokerInstance()	Set the Artemis instance relative folder for data and stuff.
List<ActiveMQServerMessagePlugin>	getBrokerMessagePlugins()
List<ActiveMQServerBasePlugin>	getBrokerPlugins()
String	getBrokerPropertiesKeySurround()
String	getBrokerPropertiesRemoveValue()
List<ActiveMQServerQueuePlugin>	getBrokerQueuePlugins()
List<ActiveMQServerResourcePlugin>	getBrokerResourcePlugins()
List<ActiveMQServerSessionPlugin>	getBrokerSessionPlugins()
List<ClusterConnectionConfiguration>	getClusterConfigurations()	Returns the cluster connections configured for this server; modifying the returned list will modify the list of ClusterConnectionConfiguration used by this configuration.
String	getClusterPassword()	Returns the cluster password for this server; default is ActiveMQDefaultConfiguration.DEFAULT_CLUSTER_PASSWORD.
String	getClusterUser()	Returns the cluster user for this server; default is ActiveMQDefaultConfiguration.DEFAULT_CLUSTER_USER.
long	getConfigurationFileRefreshPeriod()
URL	getConfigurationUrl()
List<ConnectionRouterConfiguration>	getConnectionRouters()	Returns the redirects configured for this server.
long	getConnectionTtlCheckInterval()
long	getConnectionTTLOverride()	Returns the connection time to live; This value overrides the connection time-to-live sent by the client; default is ActiveMQDefaultConfiguration.DEFAULT_CONNECTION_TTL_OVERRIDE.
Map<String,TransportConfiguration>	getConnectorConfigurations()	Returns the connectors configured for this server.
List<ConnectorServiceConfiguration>	getConnectorServiceConfigurations()	Returns list of ConnectorServiceConfiguration.
long	getCriticalAnalyzerCheckPeriod()
CriticalAnalyzerPolicy	getCriticalAnalyzerPolicy()
long	getCriticalAnalyzerTimeout()
Map<String,DiscoveryGroupConfiguration>	getDiscoveryGroupConfigurations()	Returns the discovery groups configured for this server.
int	getDiskScanPeriod()
List<DivertConfiguration>	getDivertConfigurations()	Returns the diverts configured for this server.
List<FederationConfiguration>	getFederationConfigurations()
long	getFileDeployerScanPeriod()	Returns the period (in milliseconds) to scan configuration files used by deployment; default is ActiveMQDefaultConfiguration.DEFAULT_FILE_DEPLOYER_SCAN_PERIOD.
long	getGlobalMaxMessages()
long	getGlobalMaxSize()
int	getGlobalMaxSizePercentOfJvmMaxMemory()
long	getGracefulShutdownTimeout()	Returns the graceful shutdown timeout for this server; default is ActiveMQDefaultConfiguration.DEFAULT_GRACEFUL_SHUTDOWN_TIMEOUT.
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; default is ActiveMQDefaultConfiguration.DEFAULT_ID_CACHE_SIZE.
List<String>	getIncomingInterceptorClassNames()	Returns the list of interceptors classes used by this server for incoming messages (i.e. those being delivered to the server from clients).
String	getInternalNamingPrefix()
String	getJMXDomain()	Returns the domain used by JMX MBeans (provided JMX management is enabled); default is ActiveMQDefaultConfiguration.DEFAULT_JMX_DOMAIN.
int	getJournalBufferSize_AIO()	Returns the buffer size (in bytes) for AIO; default is ArtemisConstants.DEFAULT_JOURNAL_BUFFER_SIZE_AIO.
int	getJournalBufferSize_NIO()	Returns the buffer size (in bytes) for NIO; default is ArtemisConstants.DEFAULT_JOURNAL_BUFFER_SIZE_NIO.
int	getJournalBufferTimeout_AIO()	Returns the timeout (in nanoseconds) used to flush buffers in the AIO queue; default is ArtemisConstants.DEFAULT_JOURNAL_BUFFER_TIMEOUT_AIO.
int	getJournalBufferTimeout_NIO()	Returns the timeout (in nanoseconds) used to flush buffers in the NIO; default is ArtemisConstants.DEFAULT_JOURNAL_BUFFER_TIMEOUT_NIO.
int	getJournalCompactMinFiles()	Returns the minimal number of journal files before compacting; default is ActiveMQDefaultConfiguration.DEFAULT_JOURNAL_COMPACT_MIN_FILES.
int	getJournalCompactPercentage()	Returns the percentage of live data before compacting the journal; default is ActiveMQDefaultConfiguration.DEFAULT_JOURNAL_COMPACT_PERCENTAGE.
Integer	getJournalDeviceBlockSize()	This is the device block size used on writing.
String	getJournalDirectory()	Returns the file system directory used to store journal log; default is ActiveMQDefaultConfiguration.DEFAULT_JOURNAL_DIR.
int	getJournalFileOpenTimeout()	Returns How long to wait when opening a new Journal file before failing.
int	getJournalFileSize()	Returns the size (in bytes) of each journal files; default is ActiveMQDefaultConfiguration.DEFAULT_JOURNAL_FILE_SIZE.
File	getJournalLocation()	Returns the location of the journal related to artemis.instance.
long	getJournalLockAcquisitionTimeout()
int	getJournalMaxAtticFiles()	Returns the maximal number of data files before we can start deleting corrupted files instead of moving them to attic; default value is ActiveMQDefaultConfiguration.DEFAULT_JOURNAL_MAX_ATTIC_FILES.
int	getJournalMaxIO_AIO()	Returns the maximum number of write requests that can be in the AIO queue at any given time; default is ActiveMQDefaultConfiguration.DEFAULT_JOURNAL_MAX_IO_AIO.
int	getJournalMaxIO_NIO()	Returns the maximum number of write requests for NIO journal; default is ActiveMQDefaultConfiguration.DEFAULT_JOURNAL_MAX_IO_NIO.
int	getJournalMinFiles()	Returns the number of journal files to pre-create; default is ActiveMQDefaultConfiguration.DEFAULT_JOURNAL_MIN_FILES.
int	getJournalPoolFiles()	Number of files that would be acceptable to keep on a pool; default is ActiveMQDefaultConfiguration.DEFAULT_JOURNAL_POOL_FILES}
String	getJournalRetentionDirectory()
File	getJournalRetentionLocation()
long	getJournalRetentionMaxBytes()
long	getJournalRetentionPeriod()	Returns the retention period for the journal in milliseconds (always in milliseconds, a conversion is performed on set).
JournalType	getJournalType()	Returns the type of journal used by this server (NIO, ASYNCIO or MAPPED); default is ASYNCIO.
String	getLargeMessagesDirectory()	Returns the file system directory used to store large messages; default is ActiveMQDefaultConfiguration.DEFAULT_LARGE_MESSAGES_DIR.
File	getLargeMessagesLocation()	The large message location related to artemis.instance
String	getLiteralMatchMarkers()
SimpleString	getManagementAddress()	Returns the management address of this server; Clients can send management messages to this address to manage this server; default is ActiveMQDefaultConfiguration.DEFAULT_MANAGEMENT_ADDRESS.
SimpleString	getManagementNotificationAddress()	Returns the management notification address of this server; Clients can bind queues to this address to receive management notifications emitted by this server; default is ActiveMQDefaultConfiguration.DEFAULT_MANAGEMENT_NOTIFICATION_ADDRESS.
String	getManagementRbacPrefix()
int	getMaxDiskUsage()
int	getMaxRedeliveryRecords()
long	getMemoryMeasureInterval()
int	getMemoryWarningThreshold()
int	getMessageCounterMaxDayHistory()	Returns the maximum number of days kept in memory for message counter; default is ActiveMQDefaultConfiguration.DEFAULT_MESSAGE_COUNTER_MAX_DAY_HISTORY.
long	getMessageCounterSamplePeriod()	Returns the sample period (in milliseconds) to take message counter snapshot; default is ActiveMQDefaultConfiguration.DEFAULT_MESSAGE_COUNTER_SAMPLE_PERIOD.
long	getMessageExpiryScanPeriod()	Returns the frequency (in milliseconds) to scan messages to detect which messages have expired; default is ActiveMQDefaultConfiguration.DEFAULT_MESSAGE_EXPIRY_SCAN_PERIOD.
int	getMessageExpiryThreadPriority()	Returns the priority of the thread used to scan message expiration; default is ActiveMQDefaultConfiguration.DEFAULT_MESSAGE_EXPIRY_THREAD_PRIORITY.
MetricsConfiguration	getMetricsConfiguration()
ActiveMQMetricsPlugin	getMetricsPlugin()	Deprecated.
long	getMinDiskFree()
int	getMirrorAckManagerPageAttempts()	This configures the Mirror Ack Manager number of attempts on page acks.
int	getMirrorAckManagerQueueAttempts()	This configures the Mirror Ack Manager number of attempts on queues before trying page acks.
int	getMirrorAckManagerRetryDelay()	This configures the interval in which the Mirror AckManager will retry acks when It is not intended to be configured through the XML.
long	getMqttSessionScanInterval()	Get the MQTT session scan interval
long	getMqttSessionStatePersistenceTimeout()
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()
String	getNodeManagerLockDirectory()	Returns the directory that contains the lock file.
File	getNodeManagerLockLocation()	Returns the location of the node manager lock file related to artemis.instance.
List<String>	getOutgoingInterceptorClassNames()	Returns the list of interceptors classes used by this server for outgoing messages (i.e. those being delivered to clients from the server).
int	getPageMaxConcurrentIO()	Returns the max number of concurrent reads allowed on paging; default is ActiveMQDefaultConfiguration.DEFAULT_MAX_CONCURRENT_PAGE_IO.
int	getPageSyncTimeout()	Returns the timeout (in nanoseconds) used to sync pages; default is ArtemisConstants.DEFAULT_JOURNAL_BUFFER_TIMEOUT_NIO.
String	getPagingDirectory()	Returns the file system directory used to store paging files; default is ActiveMQDefaultConfiguration.DEFAULT_PAGING_DIR.
File	getPagingLocation()	The paging location related to artemis.instance
String	getPasswordCodec()	Gets the default password decoder
List<QueueConfiguration>	getQueueConfigs()	Returns the queues configured for this server; modifying the returned List will not impact the underlying List.
List<CoreQueueConfiguration>	getQueueConfigurations()	Deprecated.
Map<String,ResourceLimitSettings>	getResourceLimitSettings()	Returns usernames mapped to ResourceLimitSettings.
int	getScheduledThreadPoolMaxSize()	Returns the maximum number of threads in the scheduled thread pool of this server; default is ActiveMQDefaultConfiguration.DEFAULT_SCHEDULED_THREAD_POOL_MAX_SIZE.
long	getSecurityInvalidationInterval()	Returns the interval time (in milliseconds) to invalidate security credentials; default is ActiveMQDefaultConfiguration.DEFAULT_SECURITY_INVALIDATION_INTERVAL.
Map<String,Set<String>>	getSecurityRoleNameMappings()
Map<String,Set<Role>>	getSecurityRoles()	Returns a collection of roles indexed by matched.
List<SecuritySettingPlugin>	getSecuritySettingPlugins()
long	getServerDumpInterval()
String	getStatus()
StoreConfiguration	getStoreConfiguration()
String	getSystemPropertyPrefix()	See doc at Configuration.setSystemPropertyPrefix(String)}
String	getTemporaryQueueNamespace()
int	getThreadPoolMaxSize()	Returns the maximum number of threads in the thread pool of this server; default is ActiveMQDefaultConfiguration.DEFAULT_THREAD_POOL_MAX_SIZE.
long	getTransactionTimeout()	Returns the timeout (in milliseconds) after which transactions is removed from the resource manager after it was created; default is ActiveMQDefaultConfiguration.DEFAULT_TRANSACTION_TIMEOUT.
long	getTransactionTimeoutScanPeriod()	Returns the frequency (in milliseconds) to scan transactions to detect which transactions have timed out; default is ActiveMQDefaultConfiguration.DEFAULT_TRANSACTION_TIMEOUT_SCAN_PERIOD.
TransportConfiguration[]	getTransportConfigurations(String... connectorNames)
TransportConfiguration[]	getTransportConfigurations(List<String> connectorNames)
String	getViewPermissionMethodMatchPattern()
WildcardConfiguration	getWildcardConfiguration()
int	hashCode()
boolean	isAmqpUseCoreSubscriptionNaming()	Returns if to use Core subscription naming for AMQP.
boolean	isAsyncConnectionExecutionEnabled()	Returns whether code coming from connection is executed asynchronously or not; default is ActiveMQDefaultConfiguration.DEFAULT_ASYNC_CONNECTION_EXECUTION_ENABLED.
boolean	isCheckForPrimaryServer()
protected static boolean	isClassProperty(String property)
boolean	isClustered()	Returns whether this server is clustered. true if Configuration.getClusterConfigurations() is not empty.
boolean	isCreateBindingsDir()	Returns whether the bindings directory is created on this server startup; default is ActiveMQDefaultConfiguration.DEFAULT_CREATE_BINDINGS_DIR.
boolean	isCreateJournalDir()	Returns whether the journal directory is created on this server startup; default is ActiveMQDefaultConfiguration.DEFAULT_CREATE_JOURNAL_DIR.
boolean	isCriticalAnalyzer()
boolean	isFailoverOnServerShutdown()
boolean	isGracefulShutdownEnabled()	Returns whether graceful shutdown is enabled for this server; default is ActiveMQDefaultConfiguration.DEFAULT_GRACEFUL_SHUTDOWN_ENABLED.
boolean	isJMXManagementEnabled()	Returns whether this server is manageable using JMX or not; default is ActiveMQDefaultConfiguration.DEFAULT_JMX_MANAGEMENT_ENABLED.
boolean	isJMXUseBrokerName()	whether 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; default is ActiveMQDefaultConfiguration.DEFAULT_JOURNAL_SYNC_NON_TRANSACTIONAL.
boolean	isJournalSyncTransactional()	Returns whether the journal is synchronized when receiving transactional data; default is ActiveMQDefaultConfiguration.DEFAULT_JOURNAL_SYNC_TRANSACTIONAL.
boolean	isLargeMessageSync()
boolean	isLogJournalWriteRate()
boolean	isManagementMessageRbac()
Boolean	isMaskPassword()	If passwords are masked.
boolean	isMessageCounterEnabled()	Returns whether message counter is enabled for this server; default is ActiveMQDefaultConfiguration.DEFAULT_MESSAGE_COUNTER_ENABLED.
boolean	isMirrorAckManagerWarnUnacked()
boolean	isMirrorPageTransaction()	Should Mirror use Page Transactions When target destinations is paging?
boolean	isMqttSubscriptionPersistenceEnabled()
boolean	isPersistDeliveryCountBeforeDelivery()	Returns whether delivery count is persisted before messages are delivered to the consumers; default is ActiveMQDefaultConfiguration.DEFAULT_PERSIST_DELIVERY_COUNT_BEFORE_DELIVERY.
boolean	isPersistenceEnabled()	Returns whether this server is using persistence and store data; default is ActiveMQDefaultConfiguration.DEFAULT_PERSISTENCE_ENABLED.
boolean	isPersistIDCache()	Returns whether message ID cache is persisted; default is ActiveMQDefaultConfiguration.DEFAULT_PERSIST_ID_CACHE.
boolean	isPopulateValidatedUser()
boolean	isReadWholePage()	Returns whether the whole page is read while getting message after page cache is evicted; default is ActiveMQDefaultConfiguration.DEFAULT_READ_WHOLE_PAGE.
boolean	isRejectEmptyValidatedUser()
boolean	isResolveProtocols()	Returns whether to resolve and use any Protocols available on the classpath; default is ActiveMQDefaultConfiguration.DEFAULT_RESOLVE_PROTOCOLS.
boolean	isSecurityEnabled()	Returns whether security is enabled for this server; default is ActiveMQDefaultConfiguration.DEFAULT_SECURITY_ENABLED.
boolean	isSuppressSessionNotifications()	Returns whether suppression of session-notifications is enabled for this server; default is ActiveMQDefaultConfiguration.DEFAULT_SUPPRESS_SESSION_NOTIFICATIONS.
boolean	isWildcardRoutingEnabled()	Deprecated.
void	parseFileProperties(File file)
void	parsePrefixedProperties(Object target, String name, Properties properties, String prefix)
void	parsePrefixedProperties(Properties properties, String prefix)
Configuration	parseProperties(String fileUrlToProperties)
void	populateWithProperties(Object target, String propsId, Map<String,Object> beanProperties)
ConfigurationImpl	putSecurityRoles(String match, Set<Role> roles)
static String	quote(String s)
void	registerBrokerPlugin(ActiveMQServerBasePlugin plugin)
void	registerBrokerPlugins(List<ActiveMQServerBasePlugin> plugins)
ConfigurationImpl	setAcceptorConfigurations(Set<TransportConfiguration> infos)	Sets the acceptors configured for this server.
Configuration	setAddressConfigurations(List<CoreAddressConfiguration> configs)	Sets the addresses configured for this server.
ConfigurationImpl	setAddressesSettings(Map<String,AddressSettings> addressesSettings)	Deprecated.
ConfigurationImpl	setAddressQueueScanPeriod(long addressQueueScanPeriod)	Sets the frequency (in milliseconds) to scan addresses and queues to detect which ones should be deleted.
ConfigurationImpl	setAddressSettings(Map<String,AddressSettings> addressesSettings)	Set the collection of AddressSettings indexed by address match.
Configuration	setAMQPConnectionConfigurations(List<AMQPBrokerConnectConfiguration> amqpConnectionConfiugrations)	Quick set of all AMQP connection configurations in one call which will clear all previously set or added broker configurations.
Configuration	setAmqpUseCoreSubscriptionNaming(boolean amqpUseCoreSubscriptionNaming)	Sets if to use Core subscription naming for AMQP.
ConfigurationImpl	setAuthenticationCacheSize(long size)	Sets the size of the authentication cache.
ConfigurationImpl	setAuthorizationCacheSize(long size)	Sets the size of the authorization cache.
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.
void	setBrokerPropertiesKeySurround(String brokerPropertiesKeySurround)
ConfigurationImpl	setCheckForPrimaryServer(boolean checkForPrimaryServer)
ConfigurationImpl	setClusterConfigurations(List<ClusterConnectionConfiguration> configs)	Sets the cluster connections configured for this server.
ConfigurationImpl	setClusterPassword(String theclusterPassword)	Sets the cluster password for this server.
ConfigurationImpl	setClusterUser(String user)	Sets the cluster user for this server.
ConfigurationImpl	setConfigurationFileRefreshPeriod(long configurationFileRefreshPeriod)
ConfigurationImpl	setConfigurationUrl(URL configurationUrl)
ConfigurationImpl	setConnectionRouters(List<ConnectionRouterConfiguration> configs)	Sets the redirects configured for this server.
ConfigurationImpl	setConnectionTtlCheckInterval(long connectionTtlCheckInterval)
ConfigurationImpl	setConnectionTTLOverride(long ttl)	Sets the connection time to live.
ConfigurationImpl	setConnectorConfigurations(Map<String,TransportConfiguration> infos)	Sets the connectors configured for this server.
ConfigurationImpl	setConnectorServiceConfigurations(List<ConnectorServiceConfiguration> configs)
ConfigurationImpl	setCreateBindingsDir(boolean create)	Sets whether the bindings directory is created on this server startup.
ConfigurationImpl	setCreateJournalDir(boolean create)	Sets whether the journal directory is created on this server startup.
Configuration	setCriticalAnalyzer(boolean CriticalAnalyzer)
Configuration	setCriticalAnalyzerCheckPeriod(long checkPeriod)
Configuration	setCriticalAnalyzerPolicy(CriticalAnalyzerPolicy policy)
Configuration	setCriticalAnalyzerTimeout(long timeout)
ConfigurationImpl	setDiscoveryGroupConfigurations(Map<String,DiscoveryGroupConfiguration> discoveryGroupConfigurations)	Sets the discovery groups configured for this server.
ConfigurationImpl	setDiskScanPeriod(int diskScanPeriod)
ConfigurationImpl	setDivertConfigurations(List<DivertConfiguration> configs)	Sets the diverts configured for this server.
ConfigurationImpl	setEnabledAsyncConnectionExecution(boolean enabled)	Sets whether code coming from connection is executed asynchronously or not.
ConfigurationImpl	setFailoverOnServerShutdown(boolean failoverOnServerShutdown)
ConfigurationImpl	setFileDeployerScanPeriod(long period)	Sets the period to scan configuration files used by deployment.
ConfigurationImpl	setGlobalMaxMessages(long maxMessages)
ConfigurationImpl	setGlobalMaxSize(long maxSize)
ConfigurationImpl	setGlobalMaxSizePercentOfJvmMaxMemory(int percentOfJvmMaxMemory)
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. those being delivered to the server from clients).
ConfigurationImpl	setInternalNamingPrefix(String internalNamingPrefix)
ConfigurationImpl	setJMXDomain(String domain)	Sets the domain used by JMX MBeans (provided JMX management is enabled).
ConfigurationImpl	setJMXManagementEnabled(boolean enabled)	Sets whether this server is manageable using JMX or not; default is ActiveMQDefaultConfiguration.DEFAULT_JMX_MANAGEMENT_ENABLED}
ConfigurationImpl	setJMXUseBrokerName(boolean jmxUseBrokerName)	whether to use the broker name in the JMX tree
ConfigurationImpl	setJournalBufferSize_AIO(int journalBufferSize)	Sets the buffer size (in bytes) for AIO.
ConfigurationImpl	setJournalBufferSize_NIO(int journalBufferSize)	Sets the buffer size (in bytes) for NIO.
ConfigurationImpl	setJournalBufferTimeout_AIO(int journalBufferTimeout)	Sets the timeout (in nanoseconds) used to flush buffers in the AIO queue.
ConfigurationImpl	setJournalBufferTimeout_NIO(int journalBufferTimeout)	Sets the timeout (in nanoseconds) used to flush buffers in the NIO.
ConfigurationImpl	setJournalCompactMinFiles(int minFiles)	Sets the minimal number of journal files before compacting.
ConfigurationImpl	setJournalCompactPercentage(int percentage)	Sets the percentage of live data before compacting the journal.
ConfigurationImpl	setJournalDatasync(boolean enable)	documented at Configuration.isJournalDatasync()
ConfigurationImpl	setJournalDeviceBlockSize(Integer deviceBlockSize)	Set the journal device block size.
ConfigurationImpl	setJournalDirectory(String dir)	Sets the file system directory used to store journal log.
Configuration	setJournalFileOpenTimeout(int journalFileOpenTimeout)	Sets the journal file open timeout
ConfigurationImpl	setJournalFileSize(int size)	Sets the size (in bytes) of each journal files.
ConfigurationImpl	setJournalLockAcquisitionTimeout(long journalLockAcquisitionTimeout)
Configuration	setJournalMaxAtticFiles(int maxAtticFiles)	Sets the maximal number of data files before we can start deleting corrupted files instead of moving them to attic.
ConfigurationImpl	setJournalMaxIO_AIO(int journalMaxIO)	Sets the maximum number of write requests that can be in the AIO queue at any given time.
ConfigurationImpl	setJournalMaxIO_NIO(int journalMaxIO)	Sets the maximum number of write requests for NIO journal.
ConfigurationImpl	setJournalMinFiles(int files)	Sets the number of journal files to pre-create.
Configuration	setJournalPoolFiles(int poolSize)	Number of files that would be acceptable to keep on a pool; default is ActiveMQDefaultConfiguration.DEFAULT_JOURNAL_POOL_FILES}
ConfigurationImpl	setJournalRetentionDirectory(String dir)	Sets the file system directory used to store historical backup journal.
ConfigurationImpl	setJournalRetentionMaxBytes(long bytes)
void	setJournalRetentionPeriod(long periodMillis)
Configuration	setJournalRetentionPeriod(TimeUnit unit, long period)
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.
Configuration	setLargeMessageSync(boolean largeMessageSync)
Configuration	setLiteralMatchMarkers(String literalMatchMarkers)
ConfigurationImpl	setLogJournalWriteRate(boolean logJournalWriteRate)
ConfigurationImpl	setManagementAddress(SimpleString address)	Sets the management address of this server.
void	setManagementMessageRbac(boolean val)
ConfigurationImpl	setManagementNotificationAddress(SimpleString address)	Sets the management notification address of this server.
void	setManagementRbacPrefix(String prefix)
ConfigurationImpl	setMaskPassword(Boolean maskPassword)	Sets if passwords should be masked or not.
ConfigurationImpl	setMaxDiskUsage(int maxDiskUsage)
Configuration	setMaxRedeliveryRecords(int max)	Maximum number of redelivery records stored on the journal per message reference.
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	setMetricsConfiguration(MetricsConfiguration metricsConfiguration)
ConfigurationImpl	setMetricsPlugin(ActiveMQMetricsPlugin plugin)	Deprecated.
ConfigurationImpl	setMinDiskFree(long minDiskFree)
ConfigurationImpl	setMirrorAckManagerPageAttempts(int maxPageAttempts)
ConfigurationImpl	setMirrorAckManagerQueueAttempts(int minQueueAttempts)
ConfigurationImpl	setMirrorAckManagerRetryDelay(int delay)
ConfigurationImpl	setMirrorAckManagerWarnUnacked(boolean warnUnacked)	should log.warn when ack retries failed.
Configuration	setMirrorPageTransaction(boolean ignorePageTransactions)
Configuration	setMqttSessionScanInterval(long mqttSessionScanInterval)	This is necessary because the MQTT session scan interval is a broker-wide setting and can't be set on a per-connector basis like most of the other MQTT-specific settings.
Configuration	setMqttSessionStatePersistenceTimeout(long mqttSessionStatePersistenceTimeout)
Configuration	setMqttSubscriptionPersistenceEnabled(boolean mqttSubscriptionPersistenceEnabled)	This is necessary because MQTT subsriptions are handled on a broker-wide basis so this can't be set on a per-connector basis like most of the other MQTT-specific settings.
ConfigurationImpl	setName(String name)	To be used on dependency management on the application server
Configuration	setNetworCheckNIC(String nic)	The NIC name to be used on network checks
ConfigurationImpl	setNetworkCheckList(String list)	A comma separated list of IPs we could use to validate if the network is UP.
Configuration	setNetworkCheckNIC(String nic)	The NIC name to be used on network checks
ConfigurationImpl	setNetworkCheckPeriod(long period)	The interval on which we will perform network checks.
Configuration	setNetworkCheckPing6Command(String command)
ConfigurationImpl	setNetworkCheckPingCommand(String command)
ConfigurationImpl	setNetworkCheckTimeout(int timeout)	Time in ms for how long we should wait for a ping to finish.
ConfigurationImpl	setNetworkCheckURLList(String urls)	A comma separated list of URIs we could use to validate if the network is UP.
Configuration	setNodeManagerLockDirectory(String dir)	Sets the file system directory used to store the node manager lock file.
ConfigurationImpl	setOutgoingInterceptorClassNames(List<String> interceptors)	Sets the list of interceptors classes used by this server for outgoing messages (i.e. those being delivered to clients from the server).
ConfigurationImpl	setPageMaxConcurrentIO(int maxIO)	The max number of concurrent reads allowed on paging.
ConfigurationImpl	setPageSyncTimeout(int pageSyncTimeout)	Sets the timeout (in nanoseconds) used to sync pages.
ConfigurationImpl	setPagingDirectory(String dir)	Sets the file system directory used to store paging files.
ConfigurationImpl	setPasswordCodec(String codec)	The default password decoder
ConfigurationImpl	setPersistDeliveryCountBeforeDelivery(boolean persistDeliveryCountBeforeDelivery)	Sets whether delivery count is persisted before messages are delivered to consumers.
ConfigurationImpl	setPersistenceEnabled(boolean enable)	Sets whether this server is using persistence and store data.
ConfigurationImpl	setPersistIDCache(boolean persist)	Sets whether message ID cache is persisted.
ConfigurationImpl	setPopulateValidatedUser(boolean populateValidatedUser)
ConfigurationImpl	setQueueConfigs(List<QueueConfiguration> configs)	Sets the queues configured for this server.
ConfigurationImpl	setQueueConfigurations(List<CoreQueueConfiguration> coreQueueConfigurations)	Deprecated.
ConfigurationImpl	setReadWholePage(boolean read)	Sets whether the whole page is read while getting message after page cache is evicted.
Configuration	setRejectEmptyValidatedUser(boolean rejectEmptyValidatedUser)
ConfigurationImpl	setResolveProtocols(boolean resolveProtocols)	Whether to use all protocols available on the classpath.
ConfigurationImpl	setResourceLimitSettings(Map<String,ResourceLimitSettings> resourceLimitSettings)	Set the collection of resource limits indexed by username.
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)	Set the collection of Role objects indexed by match (i.e. address name).
ConfigurationImpl	setSecuritySettingPlugins(List<SecuritySettingPlugin> plugins)
ConfigurationImpl	setServerDumpInterval(long intervalInMilliseconds)
void	setStatus(String status)	This value can reflect a desired state (revision) of config.
ConfigurationImpl	setStoreConfiguration(StoreConfiguration storeConfiguration)
Configuration	setSuppressSessionNotifications(boolean suppressSessionNotifications)
Configuration	setSystemPropertyPrefix(String systemPropertyPrefix)	We use Bean-utils to pass in System.properties that start with Configuration.setSystemPropertyPrefix(String)} The default should be brokerconfig. (Including the ".").
ConfigurationImpl	setTemporaryQueueNamespace(String temporaryQueueNamespace)
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.
void	setViewPermissionMethodMatchPattern(String permissionMatchPattern)
Configuration	setWildCardConfiguration(WildcardConfiguration wildcardConfiguration)
ConfigurationImpl	setWildcardRoutingEnabled(boolean enabled)	Deprecated.
File	subFolder(String subFolder)	It will find the right location of a subFolder, related to artemisInstance
String	toString()
void	unRegisterBrokerPlugin(ActiveMQServerBasePlugin plugin)

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.activemq.artemis.core.config.Configuration

isJDBC, resolvePropertiesSources

Field Details

DEFAULT_JOURNAL_TYPE

public static final JournalType DEFAULT_JOURNAL_TYPE

PROPERTY_CLASS_SUFFIX

public static final String PROPERTY_CLASS_SUFFIX

See Also:

• Constant Field Values

REDACTED

public static final String REDACTED

See Also:

• Constant Field Values

fileDeploymentScanPeriod

protected long fileDeploymentScanPeriod

jmxManagementEnabled

protected boolean jmxManagementEnabled

jmxDomain

protected String jmxDomain

jmxUseBrokerName

protected boolean jmxUseBrokerName

connectionTTLOverride

protected long connectionTTLOverride

asyncConnectionExecutionEnabled

protected boolean asyncConnectionExecutionEnabled

idCacheSize

protected int idCacheSize

connectorConfigs

protected Map<String,TransportConfiguration> connectorConfigs

bridgeConfigurations

protected List<BridgeConfiguration> bridgeConfigurations

divertConfigurations

protected List<DivertConfiguration> divertConfigurations

connectionRouters

protected List<ConnectionRouterConfiguration> connectionRouters

clusterConfigurations

protected List<ClusterConnectionConfiguration> clusterConfigurations

amqpBrokerConnectConfigurations

protected List<AMQPBrokerConnectConfiguration> amqpBrokerConnectConfigurations

federationConfigurations

protected List<FederationConfiguration> federationConfigurations

broadcastGroupConfigurations

protected transient List<BroadcastGroupConfiguration> broadcastGroupConfigurations

discoveryGroupConfigurations

protected transient Map<String,DiscoveryGroupConfiguration> discoveryGroupConfigurations

largeMessagesDirectory

protected String largeMessagesDirectory

bindingsDirectory

protected String bindingsDirectory

createBindingsDir

protected boolean createBindingsDir

journalDirectory

protected String journalDirectory

journalRetentionDirectory

protected String journalRetentionDirectory

journalRetentionMaxBytes

protected long journalRetentionMaxBytes

journalRetentionPeriod

protected long journalRetentionPeriod

nodeManagerLockDirectory

protected String nodeManagerLockDirectory

createJournalDir

protected boolean createJournalDir

journalType

public JournalType journalType

largeMessageSync

protected boolean largeMessageSync

journalSyncTransactional

protected boolean journalSyncTransactional

journalSyncNonTransactional

protected boolean journalSyncNonTransactional

journalCompactMinFiles

protected int journalCompactMinFiles

journalCompactPercentage

protected int journalCompactPercentage

journalFileOpenTimeout

protected int journalFileOpenTimeout

journalFileSize

protected int journalFileSize

journalPoolFiles

protected int journalPoolFiles

journalMinFiles

protected int journalMinFiles

journalMaxAtticFilesFiles

protected int journalMaxAtticFilesFiles

journalMaxIO_AIO

protected int journalMaxIO_AIO

journalBufferTimeout_AIO

protected int journalBufferTimeout_AIO

deviceBlockSize

protected Integer deviceBlockSize

journalBufferSize_AIO

protected int journalBufferSize_AIO

journalMaxIO_NIO

protected int journalMaxIO_NIO

journalBufferTimeout_NIO

protected int journalBufferTimeout_NIO

journalBufferSize_NIO

protected int journalBufferSize_NIO

logJournalWriteRate

protected boolean logJournalWriteRate

clusterUser

protected String clusterUser

clusterPassword

protected String clusterPassword

failoverOnServerShutdown

protected boolean failoverOnServerShutdown

groupingHandlerConfiguration

protected GroupingHandlerConfiguration groupingHandlerConfiguration

connectorServiceConfigurations

protected List<ConnectorServiceConfiguration> connectorServiceConfigurations

populateValidatedUser

protected boolean populateValidatedUser

rejectEmptyValidatedUser

protected boolean rejectEmptyValidatedUser

Constructor Details

ConfigurationImpl

public ConfigurationImpl()

Method Details

getJournalRetentionDirectory

public String getJournalRetentionDirectory()

Specified by:

getJournalRetentionDirectory in interface Configuration

setJournalRetentionDirectory

public ConfigurationImpl setJournalRetentionDirectory(String dir)

Description copied from interface: Configuration

Sets the file system directory used to store historical backup journal.

Specified by:

setJournalRetentionDirectory in interface Configuration

getJournalRetentionLocation

public File getJournalRetentionLocation()

Specified by:

getJournalRetentionLocation in interface Configuration

getJournalRetentionPeriod

public long getJournalRetentionPeriod()

Description copied from interface: Configuration

Returns the retention period for the journal in milliseconds (always in milliseconds, a conversion is performed on set).

Specified by:

getJournalRetentionPeriod in interface Configuration

Returns:

the retention period for the journal in milliseconds (always in milliseconds, a conversion is performed on set)

setJournalRetentionPeriod

public Configuration setJournalRetentionPeriod(TimeUnit unit,
 long period)

Specified by:

setJournalRetentionPeriod in interface Configuration

setJournalRetentionPeriod

public void setJournalRetentionPeriod(long periodMillis)

getJournalRetentionMaxBytes

public long getJournalRetentionMaxBytes()

Specified by:

getJournalRetentionMaxBytes in interface Configuration

setJournalRetentionMaxBytes

public ConfigurationImpl setJournalRetentionMaxBytes(long bytes)

Specified by:

setJournalRetentionMaxBytes in interface Configuration

setSystemPropertyPrefix

public Configuration setSystemPropertyPrefix(String systemPropertyPrefix)

Description copied from interface: Configuration

We use Bean-utils to pass in System.properties that start with Configuration.setSystemPropertyPrefix(String)} The default should be brokerconfig. (Including the "."). For example if you want to set clustered through a system property you must do: -Dbrokerconfig.clustered=true}

The prefix is configured here.

Specified by:

setSystemPropertyPrefix in interface Configuration

getSystemPropertyPrefix

public String getSystemPropertyPrefix()

Description copied from interface: Configuration

See doc at Configuration.setSystemPropertyPrefix(String)}

Specified by:

getSystemPropertyPrefix in interface Configuration

getBrokerPropertiesKeySurround

public String getBrokerPropertiesKeySurround()

setBrokerPropertiesKeySurround

public void setBrokerPropertiesKeySurround(String brokerPropertiesKeySurround)

getBrokerPropertiesRemoveValue

public String getBrokerPropertiesRemoveValue()

parseProperties

public Configuration parseProperties(String fileUrlToProperties)
                              throws Exception

Specified by:

parseProperties in interface Configuration

Throws:

Exception

parseFileProperties

public void parseFileProperties(File file)
                         throws Exception

Throws:

Exception

parsePrefixedProperties

public void parsePrefixedProperties(Properties properties,
 String prefix)
                             throws Exception

Throws:

Exception

parsePrefixedProperties

public void parsePrefixedProperties(Object target,
 String name,
 Properties properties,
 String prefix)
                             throws Exception

Specified by:

parsePrefixedProperties in interface Configuration

Throws:

Exception

populateWithProperties

public void populateWithProperties(Object target,
 String propsId,
 Map<String,Object> beanProperties)
                            throws InvocationTargetException,
IllegalAccessException

Throws:

InvocationTargetException

IllegalAccessException

exportAsProperties

public void exportAsProperties(File file)
                        throws Exception

Specified by:

exportAsProperties in interface Configuration

Throws:

Exception

quote

public static String quote(String s)

isClassProperty

protected static boolean isClassProperty(String property)

extractPropertyClassName

protected static String extractPropertyClassName(String property)

isClustered

public boolean isClustered()

Description copied from interface: Configuration

Returns whether this server is clustered. true if Configuration.getClusterConfigurations() is not empty.

Specified by:

isClustered in interface Configuration

Returns:

whether this server is clustered. true if Configuration.getClusterConfigurations() is not empty

isPersistenceEnabled

public boolean isPersistenceEnabled()

Description copied from interface: Configuration

Returns whether this server is using persistence and store data; default is ActiveMQDefaultConfiguration.DEFAULT_PERSISTENCE_ENABLED.

Specified by:

isPersistenceEnabled in interface Configuration

Returns:

whether this server is using persistence and store data; default is ActiveMQDefaultConfiguration.DEFAULT_PERSISTENCE_ENABLED

getMaxDiskUsage

public int getMaxDiskUsage()

Specified by:

getMaxDiskUsage in interface Configuration

setMaxDiskUsage

public ConfigurationImpl setMaxDiskUsage(int maxDiskUsage)

Specified by:

setMaxDiskUsage in interface Configuration

getMinDiskFree

public long getMinDiskFree()

Specified by:

getMinDiskFree in interface Configuration

setMinDiskFree

public ConfigurationImpl setMinDiskFree(long minDiskFree)

Specified by:

setMinDiskFree in interface Configuration

setGlobalMaxSize

public ConfigurationImpl setGlobalMaxSize(long maxSize)

Specified by:

setGlobalMaxSize in interface Configuration

getGlobalMaxSize

public long getGlobalMaxSize()

Specified by:

getGlobalMaxSize in interface Configuration

getGlobalMaxSizePercentOfJvmMaxMemory

public int getGlobalMaxSizePercentOfJvmMaxMemory()

Specified by:

getGlobalMaxSizePercentOfJvmMaxMemory in interface Configuration

setGlobalMaxSizePercentOfJvmMaxMemory

public ConfigurationImpl setGlobalMaxSizePercentOfJvmMaxMemory(int percentOfJvmMaxMemory)

Specified by:

setGlobalMaxSizePercentOfJvmMaxMemory in interface Configuration

setGlobalMaxMessages

public ConfigurationImpl setGlobalMaxMessages(long maxMessages)

Specified by:

setGlobalMaxMessages in interface Configuration

getGlobalMaxMessages

public long getGlobalMaxMessages()

Specified by:

getGlobalMaxMessages in interface Configuration

setPersistenceEnabled

public ConfigurationImpl setPersistenceEnabled(boolean enable)

Description copied from interface: Configuration

Sets whether this server is using persistence and store data.

Specified by:

setPersistenceEnabled in interface Configuration

setMaxRedeliveryRecords

public Configuration setMaxRedeliveryRecords(int max)

Description copied from interface: Configuration

Maximum number of redelivery records stored on the journal per message reference.

Specified by:

setMaxRedeliveryRecords in interface Configuration

getMaxRedeliveryRecords

public int getMaxRedeliveryRecords()

Specified by:

getMaxRedeliveryRecords in interface Configuration

isJournalDatasync

public boolean isJournalDatasync()

Description copied from interface: Configuration

Should use fdatasync on journal files.

Specified by:

isJournalDatasync in interface Configuration

Returns:

a boolean

See Also:

• fdatasync

setJournalDatasync

public ConfigurationImpl setJournalDatasync(boolean enable)

Description copied from interface: Configuration

documented at Configuration.isJournalDatasync()

Specified by:

setJournalDatasync in interface Configuration

Returns:

this

getFileDeployerScanPeriod

public long getFileDeployerScanPeriod()

Description copied from interface: Configuration

Returns the period (in milliseconds) to scan configuration files used by deployment; default is ActiveMQDefaultConfiguration.DEFAULT_FILE_DEPLOYER_SCAN_PERIOD.

Specified by:

getFileDeployerScanPeriod in interface Configuration

Returns:

the period (in milliseconds) to scan configuration files used by deployment; default is ActiveMQDefaultConfiguration.DEFAULT_FILE_DEPLOYER_SCAN_PERIOD

setFileDeployerScanPeriod

public ConfigurationImpl setFileDeployerScanPeriod(long period)

Description copied from interface: Configuration

Sets the period to scan configuration files used by deployment.

Specified by:

setFileDeployerScanPeriod in interface Configuration

isPersistDeliveryCountBeforeDelivery

public boolean isPersistDeliveryCountBeforeDelivery()

Description copied from interface: Configuration

Returns whether delivery count is persisted before messages are delivered to the consumers; default is ActiveMQDefaultConfiguration.DEFAULT_PERSIST_DELIVERY_COUNT_BEFORE_DELIVERY.

Specified by:

isPersistDeliveryCountBeforeDelivery in interface Configuration

Returns:

whether delivery count is persisted before messages are delivered to the consumers; default is ActiveMQDefaultConfiguration.DEFAULT_PERSIST_DELIVERY_COUNT_BEFORE_DELIVERY

setPersistDeliveryCountBeforeDelivery

public ConfigurationImpl setPersistDeliveryCountBeforeDelivery(boolean persistDeliveryCountBeforeDelivery)

Description copied from interface: Configuration

Sets whether delivery count is persisted before messages are delivered to consumers.

Specified by:

setPersistDeliveryCountBeforeDelivery in interface Configuration

getScheduledThreadPoolMaxSize

public int getScheduledThreadPoolMaxSize()

Description copied from interface: Configuration

Returns the maximum number of threads in the scheduled thread pool of this server; default is ActiveMQDefaultConfiguration.DEFAULT_SCHEDULED_THREAD_POOL_MAX_SIZE.

Specified by:

getScheduledThreadPoolMaxSize in interface Configuration

Returns:

the maximum number of threads in the scheduled thread pool of this server; default is ActiveMQDefaultConfiguration.DEFAULT_SCHEDULED_THREAD_POOL_MAX_SIZE

setScheduledThreadPoolMaxSize

public ConfigurationImpl setScheduledThreadPoolMaxSize(int maxSize)

Description copied from interface: Configuration

Sets the maximum number of threads in the scheduled thread pool of this server.

Specified by:

setScheduledThreadPoolMaxSize in interface Configuration

getThreadPoolMaxSize

public int getThreadPoolMaxSize()

Description copied from interface: Configuration

Returns the maximum number of threads in the thread pool of this server; default is ActiveMQDefaultConfiguration.DEFAULT_THREAD_POOL_MAX_SIZE.

Specified by:

getThreadPoolMaxSize in interface Configuration

Returns:

the maximum number of threads in the thread pool of this server; default is ActiveMQDefaultConfiguration.DEFAULT_THREAD_POOL_MAX_SIZE

setThreadPoolMaxSize

public ConfigurationImpl setThreadPoolMaxSize(int maxSize)

Description copied from interface: Configuration

Sets the maximum number of threads in the thread pool of this server.

Specified by:

setThreadPoolMaxSize in interface Configuration

getSecurityInvalidationInterval

public long getSecurityInvalidationInterval()

Description copied from interface: Configuration

Returns the interval time (in milliseconds) to invalidate security credentials; default is ActiveMQDefaultConfiguration.DEFAULT_SECURITY_INVALIDATION_INTERVAL.

Specified by:

getSecurityInvalidationInterval in interface Configuration

Returns:

the interval time (in milliseconds) to invalidate security credentials; default is ActiveMQDefaultConfiguration.DEFAULT_SECURITY_INVALIDATION_INTERVAL

setSecurityInvalidationInterval

public ConfigurationImpl setSecurityInvalidationInterval(long interval)

Description copied from interface: Configuration

Sets the interval time (in milliseconds) to invalidate security credentials.

Specified by:

setSecurityInvalidationInterval in interface Configuration

getAuthenticationCacheSize

public long getAuthenticationCacheSize()

Description copied from interface: Configuration

Returns the configured size of the authentication cache; default is ActiveMQDefaultConfiguration.DEFAULT_AUTHENTICATION_CACHE_SIZE.

Specified by:

getAuthenticationCacheSize in interface Configuration

Returns:

the configured size of the authentication cache; default is ActiveMQDefaultConfiguration.DEFAULT_AUTHENTICATION_CACHE_SIZE

setAuthenticationCacheSize

public ConfigurationImpl setAuthenticationCacheSize(long size)

Description copied from interface: Configuration

Sets the size of the authentication cache.

Specified by:

setAuthenticationCacheSize in interface Configuration

getAuthorizationCacheSize

public long getAuthorizationCacheSize()

Description copied from interface: Configuration

Returns the configured size of the authorization cache; default is ActiveMQDefaultConfiguration.DEFAULT_AUTHORIZATION_CACHE_SIZE.

Specified by:

getAuthorizationCacheSize in interface Configuration

Returns:

the configured size of the authorization cache; default is ActiveMQDefaultConfiguration.DEFAULT_AUTHORIZATION_CACHE_SIZE

setAuthorizationCacheSize

public ConfigurationImpl setAuthorizationCacheSize(long size)

Description copied from interface: Configuration

Sets the size of the authorization cache.

Specified by:

setAuthorizationCacheSize in interface Configuration

getConnectionTTLOverride

public long getConnectionTTLOverride()

Description copied from interface: Configuration

Returns the connection time to live; This value overrides the connection time-to-live sent by the client; default is ActiveMQDefaultConfiguration.DEFAULT_CONNECTION_TTL_OVERRIDE.

Specified by:

getConnectionTTLOverride in interface Configuration

Returns:

the connection time to live; This value overrides the connection time-to-live sent by the client; default is ActiveMQDefaultConfiguration.DEFAULT_CONNECTION_TTL_OVERRIDE

setConnectionTTLOverride

public ConfigurationImpl setConnectionTTLOverride(long ttl)

Description copied from interface: Configuration

Sets the connection time to live.

Specified by:

setConnectionTTLOverride in interface Configuration

isAmqpUseCoreSubscriptionNaming

public boolean isAmqpUseCoreSubscriptionNaming()

Description copied from interface: Configuration

Returns if to use Core subscription naming for AMQP.

Specified by:

isAmqpUseCoreSubscriptionNaming in interface Configuration

Returns:

if to use Core subscription naming for AMQP

setAmqpUseCoreSubscriptionNaming

public Configuration setAmqpUseCoreSubscriptionNaming(boolean amqpUseCoreSubscriptionNaming)

Description copied from interface: Configuration

Sets if to use Core subscription naming for AMQP.

Specified by:

setAmqpUseCoreSubscriptionNaming in interface Configuration

isAsyncConnectionExecutionEnabled

public boolean isAsyncConnectionExecutionEnabled()

Description copied from interface: Configuration

Returns whether code coming from connection is executed asynchronously or not; default is ActiveMQDefaultConfiguration.DEFAULT_ASYNC_CONNECTION_EXECUTION_ENABLED.

Specified by:

isAsyncConnectionExecutionEnabled in interface Configuration

Returns:

whether code coming from connection is executed asynchronously or not; default is ActiveMQDefaultConfiguration.DEFAULT_ASYNC_CONNECTION_EXECUTION_ENABLED

setEnabledAsyncConnectionExecution

public ConfigurationImpl setEnabledAsyncConnectionExecution(boolean enabled)

Description copied from interface: Configuration

Sets whether code coming from connection is executed asynchronously or not.

Specified by:

setEnabledAsyncConnectionExecution in interface Configuration

getIncomingInterceptorClassNames

public List<String> getIncomingInterceptorClassNames()

Description copied from interface: Configuration

Returns the list of interceptors classes used by this server for incoming messages (i.e. those being delivered to the server from clients).

Specified by:

getIncomingInterceptorClassNames in interface Configuration

Returns:

the list of interceptors classes used by this server for incoming messages (i.e. those being delivered to the server from clients)

setIncomingInterceptorClassNames

public ConfigurationImpl setIncomingInterceptorClassNames(List<String> interceptors)

Description copied from interface: Configuration

Sets the list of interceptors classes used by this server for incoming messages (i.e. those being delivered to the server from clients).

Classes must implement Interceptor}

Specified by:

setIncomingInterceptorClassNames in interface Configuration

getOutgoingInterceptorClassNames

public List<String> getOutgoingInterceptorClassNames()

Description copied from interface: Configuration

Returns the list of interceptors classes used by this server for outgoing messages (i.e. those being delivered to clients from the server).

Specified by:

getOutgoingInterceptorClassNames in interface Configuration

Returns:

the list of interceptors classes used by this server for outgoing messages (i.e. those being delivered to clients from the server)

setOutgoingInterceptorClassNames

public ConfigurationImpl setOutgoingInterceptorClassNames(List<String> interceptors)

Description copied from interface: Configuration

Sets the list of interceptors classes used by this server for outgoing messages (i.e. those being delivered to clients from the server).

Classes must implement Interceptor}

Specified by:

setOutgoingInterceptorClassNames in interface Configuration

getAcceptorConfigurations

public Set<TransportConfiguration> getAcceptorConfigurations()

Description copied from interface: Configuration

Returns the acceptors configured for this server.

Specified by:

getAcceptorConfigurations in interface Configuration

Returns:

the acceptors configured for this server

setAcceptorConfigurations

public ConfigurationImpl setAcceptorConfigurations(Set<TransportConfiguration> infos)

Description copied from interface: Configuration

Sets the acceptors configured for this server.

Specified by:

setAcceptorConfigurations in interface Configuration

addAcceptorConfiguration

public ConfigurationImpl addAcceptorConfiguration(TransportConfiguration infos)

Specified by:

addAcceptorConfiguration in interface Configuration

addAcceptorConfiguration

public ConfigurationImpl addAcceptorConfiguration(String name,
 String uri)
                                           throws Exception

Description copied from interface: Configuration

Add an acceptor to the config

Specified by:

addAcceptorConfiguration in interface Configuration

Parameters:

name - the name of the acceptor

uri - the URI of the acceptor

Returns:

this

Throws:

Exception - in case of Parsing errors on the URI

See Also:

• Configuring the Transport

clearAcceptorConfigurations

public ConfigurationImpl clearAcceptorConfigurations()

Specified by:

clearAcceptorConfigurations in interface Configuration

getConnectorConfigurations

public Map<String,TransportConfiguration> getConnectorConfigurations()

Description copied from interface: Configuration

Returns the connectors configured for this server.

Specified by:

getConnectorConfigurations in interface Configuration

Returns:

the connectors configured for this server

setConnectorConfigurations

public ConfigurationImpl setConnectorConfigurations(Map<String,TransportConfiguration> infos)

Description copied from interface: Configuration

Sets the connectors configured for this server.

Specified by:

setConnectorConfigurations in interface Configuration

addConnectorConfiguration

public ConfigurationImpl addConnectorConfiguration(String key,
 TransportConfiguration info)

Specified by:

addConnectorConfiguration in interface Configuration

addConnectorConfiguration

public ConfigurationImpl addConnectorConfiguration(TransportConfiguration info)

addConnectorConfiguration

public ConfigurationImpl addConnectorConfiguration(String name,
 String uri)
                                            throws Exception

Specified by:

addConnectorConfiguration in interface Configuration

Throws:

Exception

clearConnectorConfigurations

public ConfigurationImpl clearConnectorConfigurations()

Specified by:

clearConnectorConfigurations in interface Configuration

getGroupingHandlerConfiguration

public GroupingHandlerConfiguration getGroupingHandlerConfiguration()

Description copied from interface: Configuration

Returns the grouping handler configured for this server.

Specified by:

getGroupingHandlerConfiguration in interface Configuration

Returns:

the grouping handler configured for this server

setGroupingHandlerConfiguration

public ConfigurationImpl setGroupingHandlerConfiguration(GroupingHandlerConfiguration groupingHandlerConfiguration)

Description copied from interface: Configuration

Sets the grouping handler configured for this server.

Specified by:

setGroupingHandlerConfiguration in interface Configuration

getBridgeConfigurations

public List<BridgeConfiguration> getBridgeConfigurations()

Description copied from interface: Configuration

Returns the bridges configured for this server.

Specified by:

getBridgeConfigurations in interface Configuration

Returns:

the bridges configured for this server

setBridgeConfigurations

public ConfigurationImpl setBridgeConfigurations(List<BridgeConfiguration> configs)

Description copied from interface: Configuration

Sets the bridges configured for this server.

Specified by:

setBridgeConfigurations in interface Configuration

addBridgeConfiguration

public ConfigurationImpl addBridgeConfiguration(BridgeConfiguration config)

getBroadcastGroupConfigurations

public List<BroadcastGroupConfiguration> getBroadcastGroupConfigurations()

Description copied from interface: Configuration

Returns the broadcast groups configured for this server.

Specified by:

getBroadcastGroupConfigurations in interface Configuration

Returns:

the broadcast groups configured for this server

setBroadcastGroupConfigurations

public ConfigurationImpl setBroadcastGroupConfigurations(List<BroadcastGroupConfiguration> configs)

Description copied from interface: Configuration

Sets the broadcast groups configured for this server}

Specified by:

setBroadcastGroupConfigurations in interface Configuration

addBroadcastGroupConfiguration

public ConfigurationImpl addBroadcastGroupConfiguration(BroadcastGroupConfiguration config)

Specified by:

addBroadcastGroupConfiguration in interface Configuration

getClusterConfigurations

public List<ClusterConnectionConfiguration> getClusterConfigurations()

Description copied from interface: Configuration

Returns the cluster connections configured for this server; modifying the returned list will modify the list of ClusterConnectionConfiguration used by this configuration.

Specified by:

getClusterConfigurations in interface Configuration

Returns:

the cluster connections configured for this server; modifying the returned list will modify the list of ClusterConnectionConfiguration used by this configuration

setClusterConfigurations

public ConfigurationImpl setClusterConfigurations(List<ClusterConnectionConfiguration> configs)

Description copied from interface: Configuration

Sets the cluster connections configured for this server.

Specified by:

setClusterConfigurations in interface Configuration

addClusterConfiguration

public ConfigurationImpl addClusterConfiguration(ClusterConnectionConfiguration config)

Specified by:

addClusterConfiguration in interface Configuration

addClusterConfiguration

public ClusterConnectionConfiguration addClusterConfiguration(String name,
 String uri)
                                                       throws Exception

Specified by:

addClusterConfiguration in interface Configuration

Throws:

Exception

addAMQPConnection

public ConfigurationImpl addAMQPConnection(AMQPBrokerConnectConfiguration amqpBrokerConnectConfiguration)

Specified by:

addAMQPConnection in interface Configuration

getAMQPConnection

public List<AMQPBrokerConnectConfiguration> getAMQPConnection()

Specified by:

getAMQPConnection in interface Configuration

getAMQPConnections

public List<AMQPBrokerConnectConfiguration> getAMQPConnections()

setAMQPConnectionConfigurations

public Configuration setAMQPConnectionConfigurations(List<AMQPBrokerConnectConfiguration> amqpConnectionConfiugrations)

Description copied from interface: Configuration

Quick set of all AMQP connection configurations in one call which will clear all previously set or added broker configurations.

Specified by:

setAMQPConnectionConfigurations in interface Configuration

Parameters:

amqpConnectionConfiugrations - A list of AMQP broker connection configurations to assign to the broker.

Returns:

this configuration object

clearAMQPConnectionConfigurations

public Configuration clearAMQPConnectionConfigurations()

Description copied from interface: Configuration

Clears the current configuration object of all set or added AMQP connection configuration elements.

Specified by:

clearAMQPConnectionConfigurations in interface Configuration

Returns:

this configuration object

clearClusterConfigurations

public ConfigurationImpl clearClusterConfigurations()

Specified by:

clearClusterConfigurations in interface Configuration

getDivertConfigurations

public List<DivertConfiguration> getDivertConfigurations()

Description copied from interface: Configuration

Returns the diverts configured for this server.

Specified by:

getDivertConfigurations in interface Configuration

Returns:

the diverts configured for this server

setDivertConfigurations

public ConfigurationImpl setDivertConfigurations(List<DivertConfiguration> configs)

Description copied from interface: Configuration

Sets the diverts configured for this server.

Specified by:

setDivertConfigurations in interface Configuration

addDivertConfiguration

public ConfigurationImpl addDivertConfiguration(DivertConfiguration config)

Specified by:

addDivertConfiguration in interface Configuration

getConnectionRouters

public List<ConnectionRouterConfiguration> getConnectionRouters()

Description copied from interface: Configuration

Returns the redirects configured for this server.

Specified by:

getConnectionRouters in interface Configuration

Returns:

the redirects configured for this server

setConnectionRouters

public ConfigurationImpl setConnectionRouters(List<ConnectionRouterConfiguration> configs)

Description copied from interface: Configuration

Sets the redirects configured for this server.

Specified by:

setConnectionRouters in interface Configuration

addConnectionRouter

public ConfigurationImpl addConnectionRouter(ConnectionRouterConfiguration config)

Specified by:

addConnectionRouter in interface Configuration

getQueueConfigurations

@Deprecated
public List<CoreQueueConfiguration> getQueueConfigurations()

Deprecated.

Description copied from interface: Configuration

Returns the queues configured for this server.

Specified by:

getQueueConfigurations in interface Configuration

Returns:

the queues configured for this server

getQueueConfigs

public List<QueueConfiguration> getQueueConfigs()

Description copied from interface: Configuration

Returns the queues configured for this server; modifying the returned List will not impact the underlying List.

Specified by:

getQueueConfigs in interface Configuration

Returns:

the queues configured for this server; modifying the returned List will not impact the underlying List

setQueueConfigurations

@Deprecated
public ConfigurationImpl setQueueConfigurations(List<CoreQueueConfiguration> coreQueueConfigurations)

Deprecated.

Description copied from interface: Configuration

Sets the queues configured for this server.

Specified by:

setQueueConfigurations in interface Configuration

setQueueConfigs

public ConfigurationImpl setQueueConfigs(List<QueueConfiguration> configs)

Description copied from interface: Configuration

Sets the queues configured for this server.

Specified by:

setQueueConfigs in interface Configuration

addQueueConfiguration

@Deprecated
public ConfigurationImpl addQueueConfiguration(CoreQueueConfiguration config)

Deprecated.

Specified by:

addQueueConfiguration in interface Configuration

addQueueConfiguration

public ConfigurationImpl addQueueConfiguration(QueueConfiguration config)

Specified by:

addQueueConfiguration in interface Configuration

getAddressConfigurations

public List<CoreAddressConfiguration> getAddressConfigurations()

Description copied from interface: Configuration

Returns the addresses configured for this server.

Specified by:

getAddressConfigurations in interface Configuration

Returns:

the addresses configured for this server

setAddressConfigurations

public Configuration setAddressConfigurations(List<CoreAddressConfiguration> configs)

Description copied from interface: Configuration

Sets the addresses configured for this server.

Specified by:

setAddressConfigurations in interface Configuration

addAddressConfiguration

public Configuration addAddressConfiguration(CoreAddressConfiguration config)

Description copied from interface: Configuration

Adds an addresses configuration

Specified by:

addAddressConfiguration in interface Configuration

getDiscoveryGroupConfigurations

public Map<String,DiscoveryGroupConfiguration> getDiscoveryGroupConfigurations()

Description copied from interface: Configuration

Returns the discovery groups configured for this server.

Specified by:

getDiscoveryGroupConfigurations in interface Configuration

Returns:

the discovery groups configured for this server

setDiscoveryGroupConfigurations

public ConfigurationImpl setDiscoveryGroupConfigurations(Map<String,DiscoveryGroupConfiguration> discoveryGroupConfigurations)

Description copied from interface: Configuration

Sets the discovery groups configured for this server.

Specified by:

setDiscoveryGroupConfigurations in interface Configuration

addDiscoveryGroupConfiguration

public ConfigurationImpl addDiscoveryGroupConfiguration(String key,
 DiscoveryGroupConfiguration discoveryGroupConfiguration)

Specified by:

addDiscoveryGroupConfiguration in interface Configuration

getIDCacheSize

public int getIDCacheSize()

Description copied from interface: Configuration

Returns the size of the cache for pre-creating message IDs; default is ActiveMQDefaultConfiguration.DEFAULT_ID_CACHE_SIZE.

Specified by:

getIDCacheSize in interface Configuration

Returns:

the size of the cache for pre-creating message IDs; default is ActiveMQDefaultConfiguration.DEFAULT_ID_CACHE_SIZE

setIDCacheSize

public ConfigurationImpl setIDCacheSize(int idCacheSize)

Description copied from interface: Configuration

Sets the size of the cache for pre-creating message IDs.

Specified by:

setIDCacheSize in interface Configuration

isPersistIDCache

public boolean isPersistIDCache()

Description copied from interface: Configuration

Returns whether message ID cache is persisted; default is ActiveMQDefaultConfiguration.DEFAULT_PERSIST_ID_CACHE.

Specified by:

isPersistIDCache in interface Configuration

Returns:

whether message ID cache is persisted; default is ActiveMQDefaultConfiguration.DEFAULT_PERSIST_ID_CACHE

setPersistIDCache

public ConfigurationImpl setPersistIDCache(boolean persist)

Description copied from interface: Configuration

Sets whether message ID cache is persisted.

Specified by:

setPersistIDCache in interface Configuration

getBindingsLocation

public File getBindingsLocation()

Description copied from interface: Configuration

The binding location related to artemis.instance.

Specified by:

getBindingsLocation in interface Configuration

getBindingsDirectory

public String getBindingsDirectory()

Description copied from interface: Configuration

Returns the file system directory used to store bindings; default is ActiveMQDefaultConfiguration.DEFAULT_BINDINGS_DIRECTORY.

Specified by:

getBindingsDirectory in interface Configuration

Returns:

the file system directory used to store bindings; default is ActiveMQDefaultConfiguration.DEFAULT_BINDINGS_DIRECTORY

setBindingsDirectory

public ConfigurationImpl setBindingsDirectory(String dir)

Description copied from interface: Configuration

Sets the file system directory used to store bindings.

Specified by:

setBindingsDirectory in interface Configuration

getPageMaxConcurrentIO

public int getPageMaxConcurrentIO()

Description copied from interface: Configuration

Returns the max number of concurrent reads allowed on paging; default is ActiveMQDefaultConfiguration.DEFAULT_MAX_CONCURRENT_PAGE_IO.

Specified by:

getPageMaxConcurrentIO in interface Configuration

Returns:

the max number of concurrent reads allowed on paging; default is ActiveMQDefaultConfiguration.DEFAULT_MAX_CONCURRENT_PAGE_IO

setPageMaxConcurrentIO

public ConfigurationImpl setPageMaxConcurrentIO(int maxIO)

Description copied from interface: Configuration

The max number of concurrent reads allowed on paging.

Default = 5

Specified by:

setPageMaxConcurrentIO in interface Configuration

isReadWholePage

public boolean isReadWholePage()

Description copied from interface: Configuration

Returns whether the whole page is read while getting message after page cache is evicted; default is ActiveMQDefaultConfiguration.DEFAULT_READ_WHOLE_PAGE.

Specified by:

isReadWholePage in interface Configuration

Returns:

whether the whole page is read while getting message after page cache is evicted; default is ActiveMQDefaultConfiguration.DEFAULT_READ_WHOLE_PAGE

setReadWholePage

public ConfigurationImpl setReadWholePage(boolean read)

Description copied from interface: Configuration

Sets whether the whole page is read while getting message after page cache is evicted.

Specified by:

setReadWholePage in interface Configuration

getJournalLocation

public File getJournalLocation()

Description copied from interface: Configuration

Returns the location of the journal related to artemis.instance.

Specified by:

getJournalLocation in interface Configuration

Returns:

the location of the journal related to artemis.instance

getJournalDirectory

public String getJournalDirectory()

Description copied from interface: Configuration

Returns the file system directory used to store journal log; default is ActiveMQDefaultConfiguration.DEFAULT_JOURNAL_DIR.

Specified by:

getJournalDirectory in interface Configuration

Returns:

the file system directory used to store journal log; default is ActiveMQDefaultConfiguration.DEFAULT_JOURNAL_DIR

setJournalDirectory

public ConfigurationImpl setJournalDirectory(String dir)

Description copied from interface: Configuration

Sets the file system directory used to store journal log.

Specified by:

setJournalDirectory in interface Configuration

getNodeManagerLockLocation

public File getNodeManagerLockLocation()

Description copied from interface: Configuration

Returns the location of the node manager lock file related to artemis.instance.

Specified by:

getNodeManagerLockLocation in interface Configuration

Returns:

the location of the node manager lock file related to artemis.instance

setNodeManagerLockDirectory

public Configuration setNodeManagerLockDirectory(String dir)

Description copied from interface: Configuration

Sets the file system directory used to store the node manager lock file.

Specified by:

setNodeManagerLockDirectory in interface Configuration

getNodeManagerLockDirectory

public String getNodeManagerLockDirectory()

Description copied from interface: Configuration

Returns the directory that contains the lock file.

Specified by:

getNodeManagerLockDirectory in interface Configuration

Returns:

the directory that contains the lock file

getJournalType

public JournalType getJournalType()

Description copied from interface: Configuration

Returns the type of journal used by this server (NIO, ASYNCIO or MAPPED); default is ASYNCIO.

Specified by:

getJournalType in interface Configuration

Returns:

the type of journal used by this server (NIO, ASYNCIO or MAPPED); default is ASYNCIO

setPagingDirectory

public ConfigurationImpl setPagingDirectory(String dir)

Description copied from interface: Configuration

Sets the file system directory used to store paging files.

Specified by:

setPagingDirectory in interface Configuration

getPagingLocation

public File getPagingLocation()

Description copied from interface: Configuration

The paging location related to artemis.instance

Specified by:

getPagingLocation in interface Configuration

getPagingDirectory

public String getPagingDirectory()

Description copied from interface: Configuration

Returns the file system directory used to store paging files; default is ActiveMQDefaultConfiguration.DEFAULT_PAGING_DIR.

Specified by:

getPagingDirectory in interface Configuration

Returns:

the file system directory used to store paging files; default is ActiveMQDefaultConfiguration.DEFAULT_PAGING_DIR

setJournalType

public ConfigurationImpl setJournalType(JournalType type)

Description copied from interface: Configuration

Sets the type of journal used by this server (either NIO or ASYNCIO).

Specified by:

setJournalType in interface Configuration

isJournalSyncTransactional

public boolean isJournalSyncTransactional()

Description copied from interface: Configuration

Returns whether the journal is synchronized when receiving transactional data; default is ActiveMQDefaultConfiguration.DEFAULT_JOURNAL_SYNC_TRANSACTIONAL.

Specified by:

isJournalSyncTransactional in interface Configuration

Returns:

whether the journal is synchronized when receiving transactional data; default is ActiveMQDefaultConfiguration.DEFAULT_JOURNAL_SYNC_TRANSACTIONAL

setJournalSyncTransactional

public ConfigurationImpl setJournalSyncTransactional(boolean sync)

Description copied from interface: Configuration

Sets whether the journal is synchronized when receiving transactional data.

Specified by:

setJournalSyncTransactional in interface Configuration

isJournalSyncNonTransactional

public boolean isJournalSyncNonTransactional()

Description copied from interface: Configuration

Returns whether the journal is synchronized when receiving non-transactional data; default is ActiveMQDefaultConfiguration.DEFAULT_JOURNAL_SYNC_NON_TRANSACTIONAL.

Specified by:

isJournalSyncNonTransactional in interface Configuration

Returns:

whether the journal is synchronized when receiving non-transactional data; default is ActiveMQDefaultConfiguration.DEFAULT_JOURNAL_SYNC_NON_TRANSACTIONAL

setJournalSyncNonTransactional

public ConfigurationImpl setJournalSyncNonTransactional(boolean sync)

Description copied from interface: Configuration

Sets whether the journal is synchronized when receiving non-transactional data.

Specified by:

setJournalSyncNonTransactional in interface Configuration

getJournalFileSize

public int getJournalFileSize()

Description copied from interface: Configuration

Returns the size (in bytes) of each journal files; default is ActiveMQDefaultConfiguration.DEFAULT_JOURNAL_FILE_SIZE.

Specified by:

getJournalFileSize in interface Configuration

Returns:

the size (in bytes) of each journal files; default is ActiveMQDefaultConfiguration.DEFAULT_JOURNAL_FILE_SIZE

setJournalFileSize

public ConfigurationImpl setJournalFileSize(int size)

Description copied from interface: Configuration

Sets the size (in bytes) of each journal files.

Specified by:

setJournalFileSize in interface Configuration

getJournalPoolFiles

public int getJournalPoolFiles()

Description copied from interface: Configuration

Number of files that would be acceptable to keep on a pool; default is ActiveMQDefaultConfiguration.DEFAULT_JOURNAL_POOL_FILES}

Specified by:

getJournalPoolFiles in interface Configuration

setJournalPoolFiles

public Configuration setJournalPoolFiles(int poolSize)

Description copied from interface: Configuration

Number of files that would be acceptable to keep on a pool; default is ActiveMQDefaultConfiguration.DEFAULT_JOURNAL_POOL_FILES}

Specified by:

setJournalPoolFiles in interface Configuration

getJournalMinFiles

public int getJournalMinFiles()

Description copied from interface: Configuration

Returns the number of journal files to pre-create; default is ActiveMQDefaultConfiguration.DEFAULT_JOURNAL_MIN_FILES.

Specified by:

getJournalMinFiles in interface Configuration

Returns:

the number of journal files to pre-create; default is ActiveMQDefaultConfiguration.DEFAULT_JOURNAL_MIN_FILES

setJournalMinFiles

public ConfigurationImpl setJournalMinFiles(int files)

Description copied from interface: Configuration

Sets the number of journal files to pre-create.

Specified by:

setJournalMinFiles in interface Configuration

isLogJournalWriteRate

public boolean isLogJournalWriteRate()

Specified by:

isLogJournalWriteRate in interface Configuration

setLogJournalWriteRate

public ConfigurationImpl setLogJournalWriteRate(boolean logJournalWriteRate)

Specified by:

setLogJournalWriteRate in interface Configuration

isCreateBindingsDir

public boolean isCreateBindingsDir()

Description copied from interface: Configuration

Returns whether the bindings directory is created on this server startup; default is ActiveMQDefaultConfiguration.DEFAULT_CREATE_BINDINGS_DIR.

Specified by:

isCreateBindingsDir in interface Configuration

Returns:

whether the bindings directory is created on this server startup; default is ActiveMQDefaultConfiguration.DEFAULT_CREATE_BINDINGS_DIR

setCreateBindingsDir

public ConfigurationImpl setCreateBindingsDir(boolean create)

Description copied from interface: Configuration

Sets whether the bindings directory is created on this server startup.

Specified by:

setCreateBindingsDir in interface Configuration

isCreateJournalDir

public boolean isCreateJournalDir()

Description copied from interface: Configuration

Returns whether the journal directory is created on this server startup; default is ActiveMQDefaultConfiguration.DEFAULT_CREATE_JOURNAL_DIR.

Specified by:

isCreateJournalDir in interface Configuration

Returns:

whether the journal directory is created on this server startup; default is ActiveMQDefaultConfiguration.DEFAULT_CREATE_JOURNAL_DIR

setCreateJournalDir

public ConfigurationImpl setCreateJournalDir(boolean create)

Description copied from interface: Configuration

Sets whether the journal directory is created on this server startup.

Specified by:

setCreateJournalDir in interface Configuration

isWildcardRoutingEnabled

@Deprecated
public boolean isWildcardRoutingEnabled()

Deprecated.

Description copied from interface: Configuration

Returns whether wildcard routing is supported by this server; default is ActiveMQDefaultConfiguration.DEFAULT_WILDCARD_ROUTING_ENABLED.

Specified by:

isWildcardRoutingEnabled in interface Configuration

Returns:

whether wildcard routing is supported by this server; default is ActiveMQDefaultConfiguration.DEFAULT_WILDCARD_ROUTING_ENABLED

setWildcardRoutingEnabled

@Deprecated
public ConfigurationImpl setWildcardRoutingEnabled(boolean enabled)

Deprecated.

Description copied from interface: Configuration

Sets whether wildcard routing is supported by this server.

Specified by:

setWildcardRoutingEnabled in interface Configuration

getWildcardConfiguration

public WildcardConfiguration getWildcardConfiguration()

Specified by:

getWildcardConfiguration in interface Configuration

setWildCardConfiguration

public Configuration setWildCardConfiguration(WildcardConfiguration wildcardConfiguration)

Specified by:

setWildCardConfiguration in interface Configuration

getTransactionTimeout

public long getTransactionTimeout()

Description copied from interface: Configuration

Returns the timeout (in milliseconds) after which transactions is removed from the resource manager after it was created; default is ActiveMQDefaultConfiguration.DEFAULT_TRANSACTION_TIMEOUT.

Specified by:

getTransactionTimeout in interface Configuration

Returns:

the timeout (in milliseconds) after which transactions is removed from the resource manager after it was created; default is ActiveMQDefaultConfiguration.DEFAULT_TRANSACTION_TIMEOUT

setTransactionTimeout

public ConfigurationImpl setTransactionTimeout(long timeout)

Description copied from interface: Configuration

Sets the timeout (in milliseconds) after which transactions is removed from the resource manager after it was created.

Specified by:

setTransactionTimeout in interface Configuration

getTransactionTimeoutScanPeriod

public long getTransactionTimeoutScanPeriod()

Description copied from interface: Configuration

Returns the frequency (in milliseconds) to scan transactions to detect which transactions have timed out; default is ActiveMQDefaultConfiguration.DEFAULT_TRANSACTION_TIMEOUT_SCAN_PERIOD.

Specified by:

getTransactionTimeoutScanPeriod in interface Configuration

Returns:

the frequency (in milliseconds) to scan transactions to detect which transactions have timed out; default is ActiveMQDefaultConfiguration.DEFAULT_TRANSACTION_TIMEOUT_SCAN_PERIOD

setTransactionTimeoutScanPeriod

public ConfigurationImpl setTransactionTimeoutScanPeriod(long period)

Description copied from interface: Configuration

Sets the frequency (in milliseconds) to scan transactions to detect which transactions have timed out.

Specified by:

setTransactionTimeoutScanPeriod in interface Configuration

getMessageExpiryScanPeriod

public long getMessageExpiryScanPeriod()

Description copied from interface: Configuration

Returns the frequency (in milliseconds) to scan messages to detect which messages have expired; default is ActiveMQDefaultConfiguration.DEFAULT_MESSAGE_EXPIRY_SCAN_PERIOD.

Specified by:

getMessageExpiryScanPeriod in interface Configuration

Returns:

the frequency (in milliseconds) to scan messages to detect which messages have expired; default is ActiveMQDefaultConfiguration.DEFAULT_MESSAGE_EXPIRY_SCAN_PERIOD

setMessageExpiryScanPeriod

public ConfigurationImpl setMessageExpiryScanPeriod(long messageExpiryScanPeriod)

Description copied from interface: Configuration

Sets the frequency (in milliseconds) to scan messages to detect which messages have expired.

Specified by:

setMessageExpiryScanPeriod in interface Configuration

getMessageExpiryThreadPriority

public int getMessageExpiryThreadPriority()

Description copied from interface: Configuration

Returns the priority of the thread used to scan message expiration; default is ActiveMQDefaultConfiguration.DEFAULT_MESSAGE_EXPIRY_THREAD_PRIORITY.

Specified by:

getMessageExpiryThreadPriority in interface Configuration

Returns:

the priority of the thread used to scan message expiration; default is ActiveMQDefaultConfiguration.DEFAULT_MESSAGE_EXPIRY_THREAD_PRIORITY

setMessageExpiryThreadPriority

public ConfigurationImpl setMessageExpiryThreadPriority(int messageExpiryThreadPriority)

Description copied from interface: Configuration

Sets the priority of the thread used to scan message expiration.

Specified by:

setMessageExpiryThreadPriority in interface Configuration

getAddressQueueScanPeriod

public long getAddressQueueScanPeriod()

Description copied from interface: Configuration

Returns the frequency (in milliseconds) to scan addresses and queues to detect which ones should be deleted; default is ActiveMQDefaultConfiguration.DEFAULT_MESSAGE_EXPIRY_SCAN_PERIOD.

Specified by:

getAddressQueueScanPeriod in interface Configuration

Returns:

the frequency (in milliseconds) to scan addresses and queues to detect which ones should be deleted; default is ActiveMQDefaultConfiguration.DEFAULT_MESSAGE_EXPIRY_SCAN_PERIOD

setAddressQueueScanPeriod

public ConfigurationImpl setAddressQueueScanPeriod(long addressQueueScanPeriod)

Description copied from interface: Configuration

Sets the frequency (in milliseconds) to scan addresses and queues to detect which ones should be deleted.

Specified by:

setAddressQueueScanPeriod in interface Configuration

isSecurityEnabled

public boolean isSecurityEnabled()

Description copied from interface: Configuration

Returns whether security is enabled for this server; default is ActiveMQDefaultConfiguration.DEFAULT_SECURITY_ENABLED.

Specified by:

isSecurityEnabled in interface Configuration

Returns:

whether security is enabled for this server; default is ActiveMQDefaultConfiguration.DEFAULT_SECURITY_ENABLED

setSecurityEnabled

public ConfigurationImpl setSecurityEnabled(boolean enabled)

Description copied from interface: Configuration

Sets whether security is enabled for this server.

Specified by:

setSecurityEnabled in interface Configuration

isGracefulShutdownEnabled

public boolean isGracefulShutdownEnabled()

Description copied from interface: Configuration

Returns whether graceful shutdown is enabled for this server; default is ActiveMQDefaultConfiguration.DEFAULT_GRACEFUL_SHUTDOWN_ENABLED.

Specified by:

isGracefulShutdownEnabled in interface Configuration

Returns:

whether graceful shutdown is enabled for this server; default is ActiveMQDefaultConfiguration.DEFAULT_GRACEFUL_SHUTDOWN_ENABLED

setGracefulShutdownEnabled

public ConfigurationImpl setGracefulShutdownEnabled(boolean enabled)

Description copied from interface: Configuration

Sets whether security is enabled for this server.

Specified by:

setGracefulShutdownEnabled in interface Configuration

getGracefulShutdownTimeout

public long getGracefulShutdownTimeout()

Description copied from interface: Configuration

Returns the graceful shutdown timeout for this server; default is ActiveMQDefaultConfiguration.DEFAULT_GRACEFUL_SHUTDOWN_TIMEOUT.

Specified by:

getGracefulShutdownTimeout in interface Configuration

Returns:

the graceful shutdown timeout for this server; default is ActiveMQDefaultConfiguration.DEFAULT_GRACEFUL_SHUTDOWN_TIMEOUT

setGracefulShutdownTimeout

public ConfigurationImpl setGracefulShutdownTimeout(long timeout)

Description copied from interface: Configuration

Sets the graceful shutdown timeout

Specified by:

setGracefulShutdownTimeout in interface Configuration

isJMXManagementEnabled

public boolean isJMXManagementEnabled()

Description copied from interface: Configuration

Returns whether this server is manageable using JMX or not; default is ActiveMQDefaultConfiguration.DEFAULT_JMX_MANAGEMENT_ENABLED.

Specified by:

isJMXManagementEnabled in interface Configuration

Returns:

whether this server is manageable using JMX or not; default is ActiveMQDefaultConfiguration.DEFAULT_JMX_MANAGEMENT_ENABLED

setJMXManagementEnabled

public ConfigurationImpl setJMXManagementEnabled(boolean enabled)

Description copied from interface: Configuration

Sets whether this server is manageable using JMX or not; default is ActiveMQDefaultConfiguration.DEFAULT_JMX_MANAGEMENT_ENABLED}

Specified by:

setJMXManagementEnabled in interface Configuration

getJMXDomain

public String getJMXDomain()

Description copied from interface: Configuration

Returns the domain used by JMX MBeans (provided JMX management is enabled); default is ActiveMQDefaultConfiguration.DEFAULT_JMX_DOMAIN.

Specified by:

getJMXDomain in interface Configuration

Returns:

the domain used by JMX MBeans (provided JMX management is enabled); default is ActiveMQDefaultConfiguration.DEFAULT_JMX_DOMAIN

setJMXDomain

public ConfigurationImpl setJMXDomain(String domain)

Description copied from interface: Configuration

Sets the domain used by JMX MBeans (provided JMX management is enabled).

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.

Specified by:

setJMXDomain in interface Configuration

isJMXUseBrokerName

public boolean isJMXUseBrokerName()

Description copied from interface: Configuration

whether to use the broker name in the JMX tree

Specified by:

isJMXUseBrokerName in interface Configuration

setJMXUseBrokerName

public ConfigurationImpl setJMXUseBrokerName(boolean jmxUseBrokerName)

Description copied from interface: Configuration

whether to use the broker name in the JMX tree

Specified by:

setJMXUseBrokerName in interface Configuration

getLargeMessagesDirectory

public String getLargeMessagesDirectory()

Description copied from interface: Configuration

Returns the file system directory used to store large messages; default is ActiveMQDefaultConfiguration.DEFAULT_LARGE_MESSAGES_DIR.

Specified by:

getLargeMessagesDirectory in interface Configuration

Returns:

the file system directory used to store large messages; default is ActiveMQDefaultConfiguration.DEFAULT_LARGE_MESSAGES_DIR

getLargeMessagesLocation

public File getLargeMessagesLocation()

Description copied from interface: Configuration

The large message location related to artemis.instance

Specified by:

getLargeMessagesLocation in interface Configuration

setLargeMessagesDirectory

public ConfigurationImpl setLargeMessagesDirectory(String directory)

Description copied from interface: Configuration

Sets the file system directory used to store large messages.

Specified by:

setLargeMessagesDirectory in interface Configuration

isMessageCounterEnabled

public boolean isMessageCounterEnabled()

Description copied from interface: Configuration

Returns whether message counter is enabled for this server; default is ActiveMQDefaultConfiguration.DEFAULT_MESSAGE_COUNTER_ENABLED.

Specified by:

isMessageCounterEnabled in interface Configuration

Returns:

whether message counter is enabled for this server; default is ActiveMQDefaultConfiguration.DEFAULT_MESSAGE_COUNTER_ENABLED

setMessageCounterEnabled

public ConfigurationImpl setMessageCounterEnabled(boolean enabled)

Description copied from interface: Configuration

Sets whether message counter is enabled for this server.

Specified by:

setMessageCounterEnabled in interface Configuration

getMessageCounterSamplePeriod

public long getMessageCounterSamplePeriod()

Description copied from interface: Configuration

Returns the sample period (in milliseconds) to take message counter snapshot; default is ActiveMQDefaultConfiguration.DEFAULT_MESSAGE_COUNTER_SAMPLE_PERIOD.

Specified by:

getMessageCounterSamplePeriod in interface Configuration

Returns:

the sample period (in milliseconds) to take message counter snapshot; default is ActiveMQDefaultConfiguration.DEFAULT_MESSAGE_COUNTER_SAMPLE_PERIOD

setMessageCounterSamplePeriod

public ConfigurationImpl setMessageCounterSamplePeriod(long period)

Description copied from interface: Configuration

Sets the sample period to take message counter snapshot.

Specified by:

setMessageCounterSamplePeriod in interface Configuration

Parameters:

period - value must be greater than 1000ms

getMessageCounterMaxDayHistory

public int getMessageCounterMaxDayHistory()

Description copied from interface: Configuration

Returns the maximum number of days kept in memory for message counter; default is ActiveMQDefaultConfiguration.DEFAULT_MESSAGE_COUNTER_MAX_DAY_HISTORY.

Specified by:

getMessageCounterMaxDayHistory in interface Configuration

Returns:

the maximum number of days kept in memory for message counter; default is ActiveMQDefaultConfiguration.DEFAULT_MESSAGE_COUNTER_MAX_DAY_HISTORY

setMessageCounterMaxDayHistory

public ConfigurationImpl setMessageCounterMaxDayHistory(int maxDayHistory)

Description copied from interface: Configuration

Sets the maximum number of days kept in memory for message counter.

Specified by:

setMessageCounterMaxDayHistory in interface Configuration

Parameters:

maxDayHistory - value must be greater than 0

getManagementAddress

public SimpleString getManagementAddress()

Description copied from interface: Configuration

Returns the management address of this server; Clients can send management messages to this address to manage this server; default is ActiveMQDefaultConfiguration.DEFAULT_MANAGEMENT_ADDRESS.

Specified by:

getManagementAddress in interface Configuration

Returns:

the management address of this server; Clients can send management messages to this address to manage this server; default is ActiveMQDefaultConfiguration.DEFAULT_MANAGEMENT_ADDRESS

setManagementAddress

public ConfigurationImpl setManagementAddress(SimpleString address)

Description copied from interface: Configuration

Sets the management address of this server.

Specified by:

setManagementAddress in interface Configuration

getManagementNotificationAddress

public SimpleString getManagementNotificationAddress()

Description copied from interface: Configuration

Returns the management notification address of this server; Clients can bind queues to this address to receive management notifications emitted by this server; default is ActiveMQDefaultConfiguration.DEFAULT_MANAGEMENT_NOTIFICATION_ADDRESS.

Specified by:

getManagementNotificationAddress in interface Configuration

Returns:

the management notification address of this server; Clients can bind queues to this address to receive management notifications emitted by this server; default is ActiveMQDefaultConfiguration.DEFAULT_MANAGEMENT_NOTIFICATION_ADDRESS

setManagementNotificationAddress

public ConfigurationImpl setManagementNotificationAddress(SimpleString address)

Description copied from interface: Configuration

Sets the management notification address of this server.

Specified by:

setManagementNotificationAddress in interface Configuration

getClusterUser

public String getClusterUser()

Description copied from interface: Configuration

Returns the cluster user for this server; default is ActiveMQDefaultConfiguration.DEFAULT_CLUSTER_USER.

Specified by:

getClusterUser in interface Configuration

Returns:

the cluster user for this server; default is ActiveMQDefaultConfiguration.DEFAULT_CLUSTER_USER

setClusterUser

public ConfigurationImpl setClusterUser(String user)

Description copied from interface: Configuration

Sets the cluster user for this server.

Specified by:

setClusterUser in interface Configuration

getClusterPassword

public String getClusterPassword()

Description copied from interface: Configuration

Returns the cluster password for this server; default is ActiveMQDefaultConfiguration.DEFAULT_CLUSTER_PASSWORD.

Specified by:

getClusterPassword in interface Configuration

Returns:

the cluster password for this server; default is ActiveMQDefaultConfiguration.DEFAULT_CLUSTER_PASSWORD

isFailoverOnServerShutdown

public boolean isFailoverOnServerShutdown()

setFailoverOnServerShutdown

public ConfigurationImpl setFailoverOnServerShutdown(boolean failoverOnServerShutdown)

setClusterPassword

public ConfigurationImpl setClusterPassword(String theclusterPassword)

Description copied from interface: Configuration

Sets the cluster password for this server.

Specified by:

setClusterPassword in interface Configuration

getJournalCompactMinFiles

public int getJournalCompactMinFiles()

Description copied from interface: Configuration

Returns the minimal number of journal files before compacting; default is ActiveMQDefaultConfiguration.DEFAULT_JOURNAL_COMPACT_MIN_FILES.

Specified by:

getJournalCompactMinFiles in interface Configuration

Returns:

the minimal number of journal files before compacting; default is ActiveMQDefaultConfiguration.DEFAULT_JOURNAL_COMPACT_MIN_FILES

getJournalCompactPercentage

public int getJournalCompactPercentage()

Description copied from interface: Configuration

Returns the percentage of live data before compacting the journal; default is ActiveMQDefaultConfiguration.DEFAULT_JOURNAL_COMPACT_PERCENTAGE.

Specified by:

getJournalCompactPercentage in interface Configuration

Returns:

the percentage of live data before compacting the journal; default is ActiveMQDefaultConfiguration.DEFAULT_JOURNAL_COMPACT_PERCENTAGE

setJournalCompactMinFiles

public ConfigurationImpl setJournalCompactMinFiles(int minFiles)

Description copied from interface: Configuration

Sets the minimal number of journal files before compacting.

Specified by:

setJournalCompactMinFiles in interface Configuration

getJournalFileOpenTimeout

public int getJournalFileOpenTimeout()

Description copied from interface: Configuration

Returns How long to wait when opening a new Journal file before failing.

Specified by:

getJournalFileOpenTimeout in interface Configuration

Returns:

How long to wait when opening a new Journal file before failing

setJournalFileOpenTimeout

public Configuration setJournalFileOpenTimeout(int journalFileOpenTimeout)

Description copied from interface: Configuration

Sets the journal file open timeout

Specified by:

setJournalFileOpenTimeout in interface Configuration

setJournalCompactPercentage

public ConfigurationImpl setJournalCompactPercentage(int percentage)

Description copied from interface: Configuration

Sets the percentage of live data before compacting the journal.

Specified by:

setJournalCompactPercentage in interface Configuration

getServerDumpInterval

public long getServerDumpInterval()

Specified by:

getServerDumpInterval in interface Configuration

setServerDumpInterval

public ConfigurationImpl setServerDumpInterval(long intervalInMilliseconds)

Specified by:

setServerDumpInterval in interface Configuration

getMemoryWarningThreshold

public int getMemoryWarningThreshold()

Specified by:

getMemoryWarningThreshold in interface Configuration

setMemoryWarningThreshold

public ConfigurationImpl setMemoryWarningThreshold(int memoryWarningThreshold)

Specified by:

setMemoryWarningThreshold in interface Configuration

getMemoryMeasureInterval

public long getMemoryMeasureInterval()

Specified by:

getMemoryMeasureInterval in interface Configuration

setMemoryMeasureInterval

public ConfigurationImpl setMemoryMeasureInterval(long memoryMeasureInterval)

Specified by:

setMemoryMeasureInterval in interface Configuration

getJournalMaxIO_AIO

public int getJournalMaxIO_AIO()

Description copied from interface: Configuration

Returns the maximum number of write requests that can be in the AIO queue at any given time; default is ActiveMQDefaultConfiguration.DEFAULT_JOURNAL_MAX_IO_AIO.

Specified by:

getJournalMaxIO_AIO in interface Configuration

Returns:

the maximum number of write requests that can be in the AIO queue at any given time; default is ActiveMQDefaultConfiguration.DEFAULT_JOURNAL_MAX_IO_AIO

setJournalMaxIO_AIO

public ConfigurationImpl setJournalMaxIO_AIO(int journalMaxIO)

Description copied from interface: Configuration

Sets the maximum number of write requests that can be in the AIO queue at any given time.

Specified by:

setJournalMaxIO_AIO in interface Configuration

getJournalBufferTimeout_AIO

public int getJournalBufferTimeout_AIO()

Description copied from interface: Configuration

Returns the timeout (in nanoseconds) used to flush buffers in the AIO queue; default is ArtemisConstants.DEFAULT_JOURNAL_BUFFER_TIMEOUT_AIO.

Specified by:

getJournalBufferTimeout_AIO in interface Configuration

Returns:

the timeout (in nanoseconds) used to flush buffers in the AIO queue; default is ArtemisConstants.DEFAULT_JOURNAL_BUFFER_TIMEOUT_AIO

getJournalDeviceBlockSize

public Integer getJournalDeviceBlockSize()

Description copied from interface: Configuration

This is the device block size used on writing. This is usually translated as st_blksize from fstat. Returning null means the system should instead make a call on fstat and use st_blksize. The intention of this setting was to bypass the value in certain devices that will return a huge number as their block size (e.g. CephFS)

Specified by:

getJournalDeviceBlockSize in interface Configuration

setJournalDeviceBlockSize

public ConfigurationImpl setJournalDeviceBlockSize(Integer deviceBlockSize)

Description copied from interface: Configuration

Set the journal device block size.

Specified by:

setJournalDeviceBlockSize in interface Configuration

See Also:

• Configuration.getJournalDeviceBlockSize()

setJournalBufferTimeout_AIO

public ConfigurationImpl setJournalBufferTimeout_AIO(int journalBufferTimeout)

Description copied from interface: Configuration

Sets the timeout (in nanoseconds) used to flush buffers in the AIO queue.

Specified by:

setJournalBufferTimeout_AIO in interface Configuration

getJournalBufferSize_AIO

public int getJournalBufferSize_AIO()

Description copied from interface: Configuration

Returns the buffer size (in bytes) for AIO; default is ArtemisConstants.DEFAULT_JOURNAL_BUFFER_SIZE_AIO.

Specified by:

getJournalBufferSize_AIO in interface Configuration

Returns:

the buffer size (in bytes) for AIO; default is ArtemisConstants.DEFAULT_JOURNAL_BUFFER_SIZE_AIO

setJournalBufferSize_AIO

public ConfigurationImpl setJournalBufferSize_AIO(int journalBufferSize)

Description copied from interface: Configuration

Sets the buffer size (in bytes) for AIO.

Specified by:

setJournalBufferSize_AIO in interface Configuration

getJournalMaxIO_NIO

public int getJournalMaxIO_NIO()

Description copied from interface: Configuration

Returns the maximum number of write requests for NIO journal; default is ActiveMQDefaultConfiguration.DEFAULT_JOURNAL_MAX_IO_NIO.

Specified by:

getJournalMaxIO_NIO in interface Configuration

Returns:

the maximum number of write requests for NIO journal; default is ActiveMQDefaultConfiguration.DEFAULT_JOURNAL_MAX_IO_NIO

setJournalMaxIO_NIO

public ConfigurationImpl setJournalMaxIO_NIO(int journalMaxIO)

Description copied from interface: Configuration

Sets the maximum number of write requests for NIO journal.

Specified by:

setJournalMaxIO_NIO in interface Configuration

getJournalBufferTimeout_NIO

public int getJournalBufferTimeout_NIO()

Description copied from interface: Configuration

Returns the timeout (in nanoseconds) used to flush buffers in the NIO; default is ArtemisConstants.DEFAULT_JOURNAL_BUFFER_TIMEOUT_NIO.

Specified by:

getJournalBufferTimeout_NIO in interface Configuration

Returns:

the timeout (in nanoseconds) used to flush buffers in the NIO; default is ArtemisConstants.DEFAULT_JOURNAL_BUFFER_TIMEOUT_NIO

setJournalBufferTimeout_NIO

public ConfigurationImpl setJournalBufferTimeout_NIO(int journalBufferTimeout)

Description copied from interface: Configuration

Sets the timeout (in nanoseconds) used to flush buffers in the NIO.

Specified by:

setJournalBufferTimeout_NIO in interface Configuration

getJournalBufferSize_NIO

public int getJournalBufferSize_NIO()

Description copied from interface: Configuration

Returns the buffer size (in bytes) for NIO; default is ArtemisConstants.DEFAULT_JOURNAL_BUFFER_SIZE_NIO.

Specified by:

getJournalBufferSize_NIO in interface Configuration

Returns:

the buffer size (in bytes) for NIO; default is ArtemisConstants.DEFAULT_JOURNAL_BUFFER_SIZE_NIO

setJournalBufferSize_NIO

public ConfigurationImpl setJournalBufferSize_NIO(int journalBufferSize)

Description copied from interface: Configuration

Sets the buffer size (in bytes) for NIO.

Specified by:

setJournalBufferSize_NIO in interface Configuration

getAddressSettings

public Map<String,AddressSettings> getAddressSettings()

Description copied from interface: Configuration

Returns A list of AddressSettings per matching to be deployed to the address settings repository.

Specified by:

getAddressSettings in interface Configuration

Returns:

A list of AddressSettings per matching to be deployed to the address settings repository

setAddressSettings

public ConfigurationImpl setAddressSettings(Map<String,AddressSettings> addressesSettings)

Description copied from interface: Configuration

Set the collection of AddressSettings indexed by address match.

Specified by:

setAddressSettings in interface Configuration

Parameters:

addressesSettings - list of AddressSettings per matching to be deployed to the address settings repository

addAddressSetting

public ConfigurationImpl addAddressSetting(String key,
 AddressSettings addressesSetting)

Description copied from interface: Configuration

Add an AddressSettings to the underlying collection.

Specified by:

addAddressSetting in interface Configuration

Parameters:

key - the address match

addressesSetting - the AddressSettings to add

clearAddressSettings

public ConfigurationImpl clearAddressSettings()

Specified by:

clearAddressSettings in interface Configuration

getAddressesSettings

@Deprecated
public Map<String,AddressSettings> getAddressesSettings()

Deprecated.

Specified by:

getAddressesSettings in interface Configuration

setAddressesSettings

@Deprecated
public ConfigurationImpl setAddressesSettings(Map<String,AddressSettings> addressesSettings)

Deprecated.

Specified by:

setAddressesSettings in interface Configuration

addAddressesSetting

@Deprecated
public ConfigurationImpl addAddressesSetting(String key,
 AddressSettings addressesSetting)

Deprecated.

Specified by:

addAddressesSetting in interface Configuration

clearAddressesSettings

@Deprecated
public ConfigurationImpl clearAddressesSettings()

Deprecated.

Specified by:

clearAddressesSettings in interface Configuration

getResourceLimitSettings

public Map<String,ResourceLimitSettings> getResourceLimitSettings()

Description copied from interface: Configuration

Returns usernames mapped to ResourceLimitSettings.

Specified by:

getResourceLimitSettings in interface Configuration

Returns:

usernames mapped to ResourceLimitSettings

setResourceLimitSettings

public ConfigurationImpl setResourceLimitSettings(Map<String,ResourceLimitSettings> resourceLimitSettings)

Description copied from interface: Configuration

Set the collection of resource limits indexed by username.

Specified by:

setResourceLimitSettings in interface Configuration

Parameters:

resourceLimitSettings - usernames mapped to ResourceLimitSettings

addResourceLimitSettings

public ConfigurationImpl addResourceLimitSettings(ResourceLimitSettings resourceLimitSettings)

Description copied from interface: Configuration

Add a resource limit to the underlying collection.

Specified by:

addResourceLimitSettings in interface Configuration

Parameters:

resourceLimitSettings - the ResourceLimitSettings to add

addResourceLimitSetting

public ConfigurationImpl addResourceLimitSetting(ResourceLimitSettings resourceLimitSettings)

getSecurityRoles

public Map<String,Set<Role>> getSecurityRoles()

Description copied from interface: Configuration

Returns a collection of roles indexed by matched.

Specified by:

getSecurityRoles in interface Configuration

Returns:

a collection of roles indexed by matched

putSecurityRoles

public ConfigurationImpl putSecurityRoles(String match,
 Set<Role> roles)

Specified by:

putSecurityRoles in interface Configuration

addSecurityRole

public ConfigurationImpl addSecurityRole(String match,
 RoleSet roles)

setSecurityRoles

public ConfigurationImpl setSecurityRoles(Map<String,Set<Role>> securitySettings)

Description copied from interface: Configuration

Set the collection of Role objects indexed by match (i.e. address name).

Specified by:

setSecurityRoles in interface Configuration

Parameters:

securitySettings - a list of roles per matching

addSecurityRoleNameMapping

public Configuration addSecurityRoleNameMapping(String internalRole,
 Set<String> externalRoles)

Specified by:

addSecurityRoleNameMapping in interface Configuration

getSecurityRoleNameMappings

public Map<String,Set<String>> getSecurityRoleNameMappings()

Specified by:

getSecurityRoleNameMappings in interface Configuration

getConnectorServiceConfigurations

public List<ConnectorServiceConfiguration> getConnectorServiceConfigurations()

Description copied from interface: Configuration

Returns list of ConnectorServiceConfiguration.

Specified by:

getConnectorServiceConfigurations in interface Configuration

Returns:

list of ConnectorServiceConfiguration

getSecuritySettingPlugins

public List<SecuritySettingPlugin> getSecuritySettingPlugins()

Specified by:

getSecuritySettingPlugins in interface Configuration

getMetricsPlugin

@Deprecated
public ActiveMQMetricsPlugin getMetricsPlugin()

Deprecated.

Specified by:

getMetricsPlugin in interface Configuration

getMetricsConfiguration

public MetricsConfiguration getMetricsConfiguration()

Specified by:

getMetricsConfiguration in interface Configuration

registerBrokerPlugins

public void registerBrokerPlugins(List<ActiveMQServerBasePlugin> plugins)

Specified by:

registerBrokerPlugins in interface Configuration

registerBrokerPlugin

public void registerBrokerPlugin(ActiveMQServerBasePlugin plugin)

Specified by:

registerBrokerPlugin in interface Configuration

unRegisterBrokerPlugin

public void unRegisterBrokerPlugin(ActiveMQServerBasePlugin plugin)

Specified by:

unRegisterBrokerPlugin in interface Configuration

getBrokerPlugins

public List<ActiveMQServerBasePlugin> getBrokerPlugins()

Specified by:

getBrokerPlugins in interface Configuration

addBrokerPlugin

public void addBrokerPlugin(ActiveMQServerBasePlugin type)

getBrokerConnectionPlugins

public List<ActiveMQServerConnectionPlugin> getBrokerConnectionPlugins()

Specified by:

getBrokerConnectionPlugins in interface Configuration

getBrokerSessionPlugins

public List<ActiveMQServerSessionPlugin> getBrokerSessionPlugins()

Specified by:

getBrokerSessionPlugins in interface Configuration

getBrokerConsumerPlugins

public List<ActiveMQServerConsumerPlugin> getBrokerConsumerPlugins()

Specified by:

getBrokerConsumerPlugins in interface Configuration

getBrokerAddressPlugins

public List<ActiveMQServerAddressPlugin> getBrokerAddressPlugins()

Specified by:

getBrokerAddressPlugins in interface Configuration

getBrokerQueuePlugins

public List<ActiveMQServerQueuePlugin> getBrokerQueuePlugins()

Specified by:

getBrokerQueuePlugins in interface Configuration

getBrokerBindingPlugins

public List<ActiveMQServerBindingPlugin> getBrokerBindingPlugins()

Specified by:

getBrokerBindingPlugins in interface Configuration

getBrokerMessagePlugins

public List<ActiveMQServerMessagePlugin> getBrokerMessagePlugins()

Specified by:

getBrokerMessagePlugins in interface Configuration

getBrokerBridgePlugins

public List<ActiveMQServerBridgePlugin> getBrokerBridgePlugins()

Specified by:

getBrokerBridgePlugins in interface Configuration

getBrokerCriticalPlugins

public List<ActiveMQServerCriticalPlugin> getBrokerCriticalPlugins()

Specified by:

getBrokerCriticalPlugins in interface Configuration

getBrokerFederationPlugins

public List<ActiveMQServerFederationPlugin> getBrokerFederationPlugins()

Specified by:

getBrokerFederationPlugins in interface Configuration

getBrokerAMQPFederationPlugins

public List<AMQPFederationBrokerPlugin> getBrokerAMQPFederationPlugins()

Specified by:

getBrokerAMQPFederationPlugins in interface Configuration

getFederationConfigurations

public List<FederationConfiguration> getFederationConfigurations()

Specified by:

getFederationConfigurations in interface Configuration

addFederationConfiguration

public void addFederationConfiguration(FederationConfiguration federationConfiguration)

getBrokerResourcePlugins

public List<ActiveMQServerResourcePlugin> getBrokerResourcePlugins()

Specified by:

getBrokerResourcePlugins in interface Configuration

getBrokerInstance

public File getBrokerInstance()

Description copied from interface: Configuration

Set the Artemis instance relative folder for data and stuff.

Specified by:

getBrokerInstance in interface Configuration

setBrokerInstance

public void setBrokerInstance(File directory)

Description copied from interface: Configuration

Set the Artemis instance relative folder for data and stuff.

Specified by:

setBrokerInstance in interface Configuration

isCheckForPrimaryServer

public boolean isCheckForPrimaryServer()

setCheckForPrimaryServer

public ConfigurationImpl setCheckForPrimaryServer(boolean checkForPrimaryServer)

toString

public String toString()

Overrides:

toString in class Object

setConnectorServiceConfigurations

public ConfigurationImpl setConnectorServiceConfigurations(List<ConnectorServiceConfiguration> configs)

Specified by:

setConnectorServiceConfigurations in interface Configuration

addConnectorServiceConfiguration

public ConfigurationImpl addConnectorServiceConfiguration(ConnectorServiceConfiguration config)

Specified by:

addConnectorServiceConfiguration in interface Configuration

setSecuritySettingPlugins

public ConfigurationImpl setSecuritySettingPlugins(List<SecuritySettingPlugin> plugins)

Specified by:

setSecuritySettingPlugins in interface Configuration

addSecuritySettingPlugin

public ConfigurationImpl addSecuritySettingPlugin(SecuritySettingPlugin plugin)

Specified by:

addSecuritySettingPlugin in interface Configuration

setMetricsPlugin

@Deprecated
public ConfigurationImpl setMetricsPlugin(ActiveMQMetricsPlugin plugin)

Deprecated.

Specified by:

setMetricsPlugin in interface Configuration

setMetricsConfiguration

public ConfigurationImpl setMetricsConfiguration(MetricsConfiguration metricsConfiguration)

Specified by:

setMetricsConfiguration in interface Configuration

isMaskPassword

public Boolean isMaskPassword()

Description copied from interface: Configuration

If passwords are masked. True means the passwords are masked.

Specified by:

isMaskPassword in interface Configuration

setMaskPassword

public ConfigurationImpl setMaskPassword(Boolean maskPassword)

Description copied from interface: Configuration

Sets if passwords should be masked or not. True means the passwords should be masked.

Specified by:

setMaskPassword in interface Configuration

setPasswordCodec

public ConfigurationImpl setPasswordCodec(String codec)

Description copied from interface: Configuration

The default password decoder

Specified by:

setPasswordCodec in interface Configuration

getPasswordCodec

public String getPasswordCodec()

Description copied from interface: Configuration

Gets the default password decoder

Specified by:

getPasswordCodec in interface Configuration

getName

public String getName()

Description copied from interface: Configuration

To be used on dependency management on the application server

Specified by:

getName in interface Configuration

setName

public ConfigurationImpl setName(String name)

Description copied from interface: Configuration

To be used on dependency management on the application server

Specified by:

setName in interface Configuration

setResolveProtocols

public ConfigurationImpl setResolveProtocols(boolean resolveProtocols)

Description copied from interface: Configuration

Whether to use all protocols available on the classpath. If false only the core protocol will be set, any other protocols will need to be set directly on the ActiveMQServer

Specified by:

setResolveProtocols in interface Configuration

getTransportConfigurations

public TransportConfiguration[] getTransportConfigurations(String... connectorNames)

Specified by:

getTransportConfigurations in interface Configuration

getTransportConfigurations

public TransportConfiguration[] getTransportConfigurations(List<String> connectorNames)

Specified by:

getTransportConfigurations in interface Configuration

debugConnectors

public String debugConnectors()

Description copied from interface: Configuration

It will return all the connectors in a toString manner for debug purposes.

Specified by:

debugConnectors in interface Configuration

isResolveProtocols

public boolean isResolveProtocols()

Description copied from interface: Configuration

Returns whether to resolve and use any Protocols available on the classpath; default is ActiveMQDefaultConfiguration.DEFAULT_RESOLVE_PROTOCOLS.

Specified by:

isResolveProtocols in interface Configuration

Returns:

whether to resolve and use any Protocols available on the classpath; default is ActiveMQDefaultConfiguration.DEFAULT_RESOLVE_PROTOCOLS

getStoreConfiguration

public StoreConfiguration getStoreConfiguration()

Specified by:

getStoreConfiguration in interface Configuration

setStoreConfiguration

public ConfigurationImpl setStoreConfiguration(StoreConfiguration storeConfiguration)

Specified by:

setStoreConfiguration in interface Configuration

isPopulateValidatedUser

public boolean isPopulateValidatedUser()

Specified by:

isPopulateValidatedUser in interface Configuration

setPopulateValidatedUser

public ConfigurationImpl setPopulateValidatedUser(boolean populateValidatedUser)

Specified by:

setPopulateValidatedUser in interface Configuration

isRejectEmptyValidatedUser

public boolean isRejectEmptyValidatedUser()

Specified by:

isRejectEmptyValidatedUser in interface Configuration

setRejectEmptyValidatedUser

public Configuration setRejectEmptyValidatedUser(boolean rejectEmptyValidatedUser)

Specified by:

setRejectEmptyValidatedUser in interface Configuration

getConnectionTtlCheckInterval

public long getConnectionTtlCheckInterval()

Specified by:

getConnectionTtlCheckInterval in interface Configuration

setConnectionTtlCheckInterval

public ConfigurationImpl setConnectionTtlCheckInterval(long connectionTtlCheckInterval)

Specified by:

setConnectionTtlCheckInterval in interface Configuration

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

copy

public Configuration copy()
                   throws Exception

Specified by:

copy in interface Configuration

Throws:

Exception

setJournalLockAcquisitionTimeout

public ConfigurationImpl setJournalLockAcquisitionTimeout(long journalLockAcquisitionTimeout)

Specified by:

setJournalLockAcquisitionTimeout in interface Configuration

getJournalLockAcquisitionTimeout

public long getJournalLockAcquisitionTimeout()

Specified by:

getJournalLockAcquisitionTimeout in interface Configuration

getHAPolicyConfiguration

public HAPolicyConfiguration getHAPolicyConfiguration()

Specified by:

getHAPolicyConfiguration in interface Configuration

setHAPolicyConfiguration

public ConfigurationImpl setHAPolicyConfiguration(HAPolicyConfiguration haPolicyConfiguration)

Specified by:

setHAPolicyConfiguration in interface Configuration

getConfigurationUrl

public URL getConfigurationUrl()

Specified by:

getConfigurationUrl in interface Configuration

setConfigurationUrl

public ConfigurationImpl setConfigurationUrl(URL configurationUrl)

Specified by:

setConfigurationUrl in interface Configuration

getConfigurationFileRefreshPeriod

public long getConfigurationFileRefreshPeriod()

Specified by:

getConfigurationFileRefreshPeriod in interface Configuration

setConfigurationFileRefreshPeriod

public ConfigurationImpl setConfigurationFileRefreshPeriod(long configurationFileRefreshPeriod)

Specified by:

setConfigurationFileRefreshPeriod in interface Configuration

getDiskScanPeriod

public int getDiskScanPeriod()

Specified by:

getDiskScanPeriod in interface Configuration

getInternalNamingPrefix

public String getInternalNamingPrefix()

Specified by:

getInternalNamingPrefix in interface Configuration

setInternalNamingPrefix

public ConfigurationImpl setInternalNamingPrefix(String internalNamingPrefix)

Specified by:

setInternalNamingPrefix in interface Configuration

setDiskScanPeriod

public ConfigurationImpl setDiskScanPeriod(int diskScanPeriod)

Specified by:

setDiskScanPeriod in interface Configuration

setNetworkCheckList

public ConfigurationImpl setNetworkCheckList(String list)

Description copied from interface: Configuration

A comma separated list of IPs we could use to validate if the network is UP. In case of none of these Ips are reached (if configured) the server will be shutdown.

Specified by:

setNetworkCheckList in interface Configuration

getNetworkCheckList

public String getNetworkCheckList()

Specified by:

getNetworkCheckList in interface Configuration

setNetworkCheckURLList

public ConfigurationImpl setNetworkCheckURLList(String urls)

Description copied from interface: Configuration

A comma separated list of URIs we could use to validate if the network is UP. In case of none of these Ips are reached (if configured) the server will be shutdown. The difference from networkCheckList is that we will use HTTP to make this validation.

Specified by:

setNetworkCheckURLList in interface Configuration

getNetworkCheckURLList

public String getNetworkCheckURLList()

Specified by:

getNetworkCheckURLList in interface Configuration

setNetworkCheckPeriod

public ConfigurationImpl setNetworkCheckPeriod(long period)

The interval on which we will perform network checks.

Specified by:

setNetworkCheckPeriod in interface Configuration

getNetworkCheckPeriod

public long getNetworkCheckPeriod()

Specified by:

getNetworkCheckPeriod in interface Configuration

setNetworkCheckTimeout

public ConfigurationImpl setNetworkCheckTimeout(int timeout)

Time in ms for how long we should wait for a ping to finish.

Specified by:

setNetworkCheckTimeout in interface Configuration

getNetworkCheckTimeout

public int getNetworkCheckTimeout()

Specified by:

getNetworkCheckTimeout in interface Configuration

setNetworCheckNIC

public Configuration setNetworCheckNIC(String nic)

Description copied from interface: Configuration

The NIC name to be used on network checks

Specified by:

setNetworCheckNIC in interface Configuration

setNetworkCheckNIC

public Configuration setNetworkCheckNIC(String nic)

Description copied from interface: Configuration

The NIC name to be used on network checks

Specified by:

setNetworkCheckNIC in interface Configuration

getNetworkCheckNIC

public String getNetworkCheckNIC()

Specified by:

getNetworkCheckNIC in interface Configuration

getNetworkCheckPingCommand

public String getNetworkCheckPingCommand()

Specified by:

getNetworkCheckPingCommand in interface Configuration

setNetworkCheckPingCommand

public ConfigurationImpl setNetworkCheckPingCommand(String command)

Specified by:

setNetworkCheckPingCommand in interface Configuration

getNetworkCheckPing6Command

public String getNetworkCheckPing6Command()

Specified by:

getNetworkCheckPing6Command in interface Configuration

setNetworkCheckPing6Command

public Configuration setNetworkCheckPing6Command(String command)

Specified by:

setNetworkCheckPing6Command in interface Configuration

isCriticalAnalyzer

public boolean isCriticalAnalyzer()

Specified by:

isCriticalAnalyzer in interface Configuration

setCriticalAnalyzer

public Configuration setCriticalAnalyzer(boolean CriticalAnalyzer)

Specified by:

setCriticalAnalyzer in interface Configuration

getCriticalAnalyzerTimeout

public long getCriticalAnalyzerTimeout()

Specified by:

getCriticalAnalyzerTimeout in interface Configuration

setCriticalAnalyzerTimeout

public Configuration setCriticalAnalyzerTimeout(long timeout)

Specified by:

setCriticalAnalyzerTimeout in interface Configuration

getCriticalAnalyzerCheckPeriod

public long getCriticalAnalyzerCheckPeriod()

Specified by:

getCriticalAnalyzerCheckPeriod in interface Configuration

setCriticalAnalyzerCheckPeriod

public Configuration setCriticalAnalyzerCheckPeriod(long checkPeriod)

Specified by:

setCriticalAnalyzerCheckPeriod in interface Configuration

getCriticalAnalyzerPolicy

public CriticalAnalyzerPolicy getCriticalAnalyzerPolicy()

Specified by:

getCriticalAnalyzerPolicy in interface Configuration

setCriticalAnalyzerPolicy

public Configuration setCriticalAnalyzerPolicy(CriticalAnalyzerPolicy policy)

Specified by:

setCriticalAnalyzerPolicy in interface Configuration

getPageSyncTimeout

public int getPageSyncTimeout()

Description copied from interface: Configuration

Returns the timeout (in nanoseconds) used to sync pages; default is ArtemisConstants.DEFAULT_JOURNAL_BUFFER_TIMEOUT_NIO.

Specified by:

getPageSyncTimeout in interface Configuration

Returns:

the timeout (in nanoseconds) used to sync pages; default is ArtemisConstants.DEFAULT_JOURNAL_BUFFER_TIMEOUT_NIO

setPageSyncTimeout

public ConfigurationImpl setPageSyncTimeout(int pageSyncTimeout)

Description copied from interface: Configuration

Sets the timeout (in nanoseconds) used to sync pages.

Specified by:

setPageSyncTimeout in interface Configuration

subFolder

public File subFolder(String subFolder)

It will find the right location of a subFolder, related to artemisInstance

getTemporaryQueueNamespace

public String getTemporaryQueueNamespace()

Specified by:

getTemporaryQueueNamespace in interface Configuration

setTemporaryQueueNamespace

public ConfigurationImpl setTemporaryQueueNamespace(String temporaryQueueNamespace)

Specified by:

setTemporaryQueueNamespace in interface Configuration

getJournalMaxAtticFiles

public int getJournalMaxAtticFiles()

Description copied from interface: Configuration

Returns the maximal number of data files before we can start deleting corrupted files instead of moving them to attic; default value is ActiveMQDefaultConfiguration.DEFAULT_JOURNAL_MAX_ATTIC_FILES.

Specified by:

getJournalMaxAtticFiles in interface Configuration

Returns:

the maximal number of data files before we can start deleting corrupted files instead of moving them to attic; default value is ActiveMQDefaultConfiguration.DEFAULT_JOURNAL_MAX_ATTIC_FILES

setJournalMaxAtticFiles

public Configuration setJournalMaxAtticFiles(int maxAtticFiles)

Description copied from interface: Configuration

Sets the maximal number of data files before we can start deleting corrupted files instead of moving them to attic.

Specified by:

setJournalMaxAtticFiles in interface Configuration

getMqttSessionScanInterval

public long getMqttSessionScanInterval()

Description copied from interface: Configuration

Get the MQTT session scan interval

Specified by:

getMqttSessionScanInterval in interface Configuration

See Also:

• Configuration.setMqttSessionScanInterval(long)

setMqttSessionScanInterval

public Configuration setMqttSessionScanInterval(long mqttSessionScanInterval)

Description copied from interface: Configuration

This is necessary because the MQTT session scan interval is a broker-wide setting and can't be set on a per-connector basis like most of the other MQTT-specific settings.

Specified by:

setMqttSessionScanInterval in interface Configuration

getMqttSessionStatePersistenceTimeout

public long getMqttSessionStatePersistenceTimeout()

Specified by:

getMqttSessionStatePersistenceTimeout in interface Configuration

setMqttSessionStatePersistenceTimeout

public Configuration setMqttSessionStatePersistenceTimeout(long mqttSessionStatePersistenceTimeout)

Specified by:

setMqttSessionStatePersistenceTimeout in interface Configuration

isMqttSubscriptionPersistenceEnabled

public boolean isMqttSubscriptionPersistenceEnabled()

Specified by:

isMqttSubscriptionPersistenceEnabled in interface Configuration

See Also:

• Configuration.setMqttSubscriptionPersistenceEnabled(boolean)

setMqttSubscriptionPersistenceEnabled

public Configuration setMqttSubscriptionPersistenceEnabled(boolean mqttSubscriptionPersistenceEnabled)

Description copied from interface: Configuration

This is necessary because MQTT subsriptions are handled on a broker-wide basis so this can't be set on a per-connector basis like most of the other MQTT-specific settings.

Specified by:

setMqttSubscriptionPersistenceEnabled in interface Configuration

isSuppressSessionNotifications

public boolean isSuppressSessionNotifications()

Description copied from interface: Configuration

Returns whether suppression of session-notifications is enabled for this server; default is ActiveMQDefaultConfiguration.DEFAULT_SUPPRESS_SESSION_NOTIFICATIONS.

Specified by:

isSuppressSessionNotifications in interface Configuration

Returns:

whether suppression of session-notifications is enabled for this server; default is ActiveMQDefaultConfiguration.DEFAULT_SUPPRESS_SESSION_NOTIFICATIONS

setSuppressSessionNotifications

public Configuration setSuppressSessionNotifications(boolean suppressSessionNotifications)

Specified by:

setSuppressSessionNotifications in interface Configuration

getStatus

public String getStatus()

Specified by:

getStatus in interface Configuration

setStatus

public void setStatus(String status)

Description copied from interface: Configuration

This value can reflect a desired state (revision) of config. Useful when configurationFileRefreshPeriod > 0. Eventually with some coordination we can update it from various server components.

Specified by:

setStatus in interface Configuration

getLiteralMatchMarkers

public String getLiteralMatchMarkers()

Specified by:

getLiteralMatchMarkers in interface Configuration

setLiteralMatchMarkers

public Configuration setLiteralMatchMarkers(String literalMatchMarkers)

Specified by:

setLiteralMatchMarkers in interface Configuration

setLargeMessageSync

public Configuration setLargeMessageSync(boolean largeMessageSync)

Specified by:

setLargeMessageSync in interface Configuration

isLargeMessageSync

public boolean isLargeMessageSync()

Specified by:

isLargeMessageSync in interface Configuration

getViewPermissionMethodMatchPattern

public String getViewPermissionMethodMatchPattern()

Specified by:

getViewPermissionMethodMatchPattern in interface Configuration

setViewPermissionMethodMatchPattern

public void setViewPermissionMethodMatchPattern(String permissionMatchPattern)

Specified by:

setViewPermissionMethodMatchPattern in interface Configuration

isManagementMessageRbac

public boolean isManagementMessageRbac()

Specified by:

isManagementMessageRbac in interface Configuration

setManagementMessageRbac

public void setManagementMessageRbac(boolean val)

Specified by:

setManagementMessageRbac in interface Configuration

getManagementRbacPrefix

public String getManagementRbacPrefix()

Specified by:

getManagementRbacPrefix in interface Configuration

setManagementRbacPrefix

public void setManagementRbacPrefix(String prefix)

Specified by:

setManagementRbacPrefix in interface Configuration

getMirrorAckManagerQueueAttempts

public int getMirrorAckManagerQueueAttempts()

Description copied from interface: Configuration

This configures the Mirror Ack Manager number of attempts on queues before trying page acks. The default value here is 5.

Specified by:

getMirrorAckManagerQueueAttempts in interface Configuration

isMirrorAckManagerWarnUnacked

public boolean isMirrorAckManagerWarnUnacked()

Specified by:

isMirrorAckManagerWarnUnacked in interface Configuration

setMirrorAckManagerWarnUnacked

public ConfigurationImpl setMirrorAckManagerWarnUnacked(boolean warnUnacked)

Description copied from interface: Configuration

should log.warn when ack retries failed.

Specified by:

setMirrorAckManagerWarnUnacked in interface Configuration

setMirrorAckManagerQueueAttempts

public ConfigurationImpl setMirrorAckManagerQueueAttempts(int minQueueAttempts)

Specified by:

setMirrorAckManagerQueueAttempts in interface Configuration

getMirrorAckManagerPageAttempts

public int getMirrorAckManagerPageAttempts()

Description copied from interface: Configuration

This configures the Mirror Ack Manager number of attempts on page acks. The default value here is 2.

Specified by:

getMirrorAckManagerPageAttempts in interface Configuration

setMirrorAckManagerPageAttempts

public ConfigurationImpl setMirrorAckManagerPageAttempts(int maxPageAttempts)

Specified by:

setMirrorAckManagerPageAttempts in interface Configuration

getMirrorAckManagerRetryDelay

public int getMirrorAckManagerRetryDelay()

Description copied from interface: Configuration

This configures the interval in which the Mirror AckManager will retry acks when It is not intended to be configured through the XML. The default value here is 100, and this is in milliseconds.

Specified by:

getMirrorAckManagerRetryDelay in interface Configuration

setMirrorAckManagerRetryDelay

public ConfigurationImpl setMirrorAckManagerRetryDelay(int delay)

Specified by:

setMirrorAckManagerRetryDelay in interface Configuration

isMirrorPageTransaction

public boolean isMirrorPageTransaction()

Description copied from interface: Configuration

Should Mirror use Page Transactions When target destinations is paging? When a target queue on the mirror is paged, the mirror will not record a page transaction for every message. The default is false, and the overhead of paged messages will be smaller, but there is a possibility of eventual duplicates in case of interrupted communication between the mirror source and target. If you set this to true there will be a record stored on the journal for the page-transaction additionally to the record in the page store.

Specified by:

isMirrorPageTransaction in interface Configuration

setMirrorPageTransaction

public Configuration setMirrorPageTransaction(boolean ignorePageTransactions)

Specified by:

setMirrorPageTransaction in interface Configuration