org.jboss.messaging.core.config.impl
Class ConfigurationImpl

java.lang.Object
  extended by org.jboss.messaging.core.config.impl.ConfigurationImpl
All Implemented Interfaces:
java.io.Serializable, Configuration, MessagingComponent
Direct Known Subclasses:
FileConfiguration

public class ConfigurationImpl
extends java.lang.Object
implements Configuration

Author:
Tim Fox
See Also:
Serialized Form

Field Summary
protected  java.util.Set<TransportConfiguration> acceptorConfigs
           
protected  boolean backup
           
protected  java.lang.String backupConnectorName
           
protected  java.lang.String bindingsDirectory
           
protected  java.util.List<BridgeConfiguration> bridgeConfigurations
           
protected  java.util.List<BroadcastGroupConfiguration> broadcastGroupConfigurations
           
protected  java.util.List<ClusterConnectionConfiguration> clusterConfigurations
           
protected  boolean clustered
           
protected  long connectionTTLOverride
           
protected  java.util.Map<java.lang.String,TransportConfiguration> connectorConfigs
           
protected  boolean createBindingsDir
           
protected  boolean createJournalDir
           
static boolean DEFAULT_BACKUP
           
static java.lang.String DEFAULT_BINDINGS_DIRECTORY
           
static boolean DEFAULT_BRIDGE_DUPLICATE_DETECTION
           
static int DEFAULT_BRIDGE_RECONNECT_ATTEMPTS
           
static long DEFAULT_BROADCAST_PERIOD
           
static long DEFAULT_BROADCAST_REFRESH_TIMEOUT
           
static boolean DEFAULT_CLUSTER_DUPLICATE_DETECTION
           
static boolean DEFAULT_CLUSTER_FORWARD_WHEN_NO_CONSUMERS
           
static int DEFAULT_CLUSTER_MAX_HOPS
           
static int DEFAULT_CLUSTER_RETRY_INTERVAL
           
static boolean DEFAULT_CLUSTERED
           
static long DEFAULT_CONNECTION_TTL_OVERRIDE
           
static boolean DEFAULT_CREATE_BINDINGS_DIR
           
static boolean DEFAULT_CREATE_JOURNAL_DIR
           
static boolean DEFAULT_DIVERT_EXCLUSIVE
           
static long DEFAULT_FILE_DEPLOYER_SCAN_PERIOD
           
static boolean DEFAULT_FILE_DEPLOYMENT_ENABLED
           
static int DEFAULT_GLOBAL_PAGE_SIZE
           
static int DEFAULT_ID_CACHE_SIZE
           
static boolean DEFAULT_JMX_MANAGEMENT_ENABLED
           
static int DEFAULT_JOURNAL_AIO_BUFFER_SIZE
           
static int DEFAULT_JOURNAL_AIO_BUFFER_TIMEOUT
           
static boolean DEFAULT_JOURNAL_AIO_FLUSH_SYNC
           
static java.lang.String DEFAULT_JOURNAL_DIR
           
static int DEFAULT_JOURNAL_FILE_SIZE
           
static boolean DEFAULT_JOURNAL_LOG_WRITE_RATE
           
static int DEFAULT_JOURNAL_MAX_AIO
           
static int DEFAULT_JOURNAL_MIN_FILES
           
static int DEFAULT_JOURNAL_PERF_BLAST_PAGES
           
static boolean DEFAULT_JOURNAL_SYNC_NON_TRANSACTIONAL
           
static boolean DEFAULT_JOURNAL_SYNC_TRANSACTIONAL
           
static JournalType DEFAULT_JOURNAL_TYPE
           
static java.lang.String DEFAULT_LARGE_MESSAGES_DIR
           
static SimpleString DEFAULT_MANAGEMENT_ADDRESS
           
static java.lang.String DEFAULT_MANAGEMENT_CLUSTER_PASSWORD
           
static java.lang.String DEFAULT_MANAGEMENT_CLUSTER_USER
           
static SimpleString DEFAULT_MANAGEMENT_NOTIFICATION_ADDRESS
           
static long DEFAULT_MANAGEMENT_REQUEST_TIMEOUT
           
static boolean DEFAULT_MESSAGE_COUNTER_ENABLED
           
static int DEFAULT_MESSAGE_COUNTER_MAX_DAY_HISTORY
           
static long DEFAULT_MESSAGE_COUNTER_SAMPLE_PERIOD
           
static long DEFAULT_MESSAGE_EXPIRY_SCAN_PERIOD
           
static int DEFAULT_MESSAGE_EXPIRY_THREAD_PRIORITY
           
static long DEFAULT_PAGE_MAX_GLOBAL_SIZE
           
static java.lang.String DEFAULT_PAGING_DIR
           
static boolean DEFAULT_PERSIST_DELIVERY_COUNT_BEFORE_DELIVERY
           
static boolean DEFAULT_PERSIST_ID_CACHE
           
static boolean DEFAULT_PERSISTENCE_ENABLED
           
static long DEFAULT_QUEUE_ACTIVATION_TIMEOUT
           
static int DEFAULT_SCHEDULED_THREAD_POOL_MAX_SIZE
           
static boolean DEFAULT_SECURITY_ENABLED
           
static long DEFAULT_SECURITY_INVALIDATION_INTERVAL
           
static int DEFAULT_THREAD_POOL_MAX_SIZE
           
static long DEFAULT_TRANSACTION_TIMEOUT
           
static long DEFAULT_TRANSACTION_TIMEOUT_SCAN_PERIOD
           
static boolean DEFAULT_WILDCARD_ROUTING_ENABLED
           
protected  java.util.Map<java.lang.String,DiscoveryGroupConfiguration> discoveryGroupConfigurations
           
protected  java.util.List<DivertConfiguration> divertConfigurations
           
protected  boolean fileDeploymentEnabled
           
protected  long fileDeploymentScanPeriod
           
protected  int globalPageSize
           
protected  int idCacheSize
           
protected  java.util.List<java.lang.String> interceptorClassNames
           
protected  boolean jmxManagementEnabled
           
protected  int journalAIOBufferSize
           
protected  int journalAIOBufferTimeout
           
protected  boolean journalAIOFlushSync
           
protected  java.lang.String journalDirectory
           
protected  int journalFileSize
           
protected  int journalMaxAIO
           
protected  int journalMinFiles
           
protected  int journalPerfBlastPages
           
protected  boolean journalSyncNonTransactional
           
protected  boolean journalSyncTransactional
           
 JournalType journalType
           
protected  java.lang.String largeMessagesDirectory
           
protected  boolean logJournalWriteRate
           
protected  SimpleString managementAddress
           
protected  java.lang.String managementClusterPassword
           
protected  java.lang.String managementClusterUser
           
protected  SimpleString managementNotificationAddress
           
protected  long managementRequestTimeout
           
protected  boolean messageCounterEnabled
           
protected  int messageCounterMaxDayHistory
           
protected  long messageCounterSamplePeriod
           
protected  long messageExpiryScanPeriod
           
protected  int messageExpiryThreadPriority
           
protected  java.lang.String pagingDirectory
           
protected  long pagingMaxGlobalSize
           
protected  boolean persistDeliveryCountBeforeDelivery
           
protected  boolean persistenceEnabled
           
protected  boolean persistIDCache
           
protected  long queueActivationTimeout
           
protected  java.util.List<QueueConfiguration> queueConfigurations
           
protected  int scheduledThreadPoolMaxSize
           
protected  boolean securityEnabled
           
protected  long securityInvalidationInterval
           
protected  int threadPoolMaxSize
           
protected  long transactionTimeout
           
protected  long transactionTimeoutScanPeriod
           
protected  boolean wildcardRoutingEnabled
           
 
Constructor Summary
ConfigurationImpl()
           
 
Method Summary
 boolean equals(java.lang.Object other)
           
 java.util.Set<TransportConfiguration> getAcceptorConfigurations()
           
 int getAIOBufferSize()
           
 int getAIOBufferTimeout()
           
 java.lang.String getBackupConnectorName()
           
 java.lang.String getBindingsDirectory()
           
 java.util.List<BridgeConfiguration> getBridgeConfigurations()
           
 java.util.List<BroadcastGroupConfiguration> getBroadcastGroupConfigurations()
           
 java.util.List<ClusterConnectionConfiguration> getClusterConfigurations()
           
 long getConnectionTTLOverride()
           
 java.util.Map<java.lang.String,TransportConfiguration> getConnectorConfigurations()
           
 java.util.Map<java.lang.String,DiscoveryGroupConfiguration> getDiscoveryGroupConfigurations()
           
 java.util.List<DivertConfiguration> getDivertConfigurations()
           
 long getFileDeployerScanPeriod()
           
 int getGlobalPagingSize()
           
 int getIDCacheSize()
           
 java.util.List<java.lang.String> getInterceptorClassNames()
           
 java.lang.String getJournalDirectory()
           
 int getJournalFileSize()
           
 int getJournalMaxAIO()
           
 int getJournalMinFiles()
           
 int getJournalPerfBlastPages()
           
 JournalType getJournalType()
           
 java.lang.String getLargeMessagesDirectory()
           
 SimpleString getManagementAddress()
           
 java.lang.String getManagementClusterPassword()
           
 java.lang.String getManagementClusterUser()
           
 SimpleString getManagementNotificationAddress()
           
 long getManagementRequestTimeout()
           
 int getMessageCounterMaxDayHistory()
           
 long getMessageCounterSamplePeriod()
           
 long getMessageExpiryScanPeriod()
           
 int getMessageExpiryThreadPriority()
           
 java.lang.String getPagingDirectory()
           
 long getPagingMaxGlobalSizeBytes()
           
 long getQueueActivationTimeout()
           
 java.util.List<QueueConfiguration> getQueueConfigurations()
           
 int getScheduledThreadPoolMaxSize()
           
 long getSecurityInvalidationInterval()
           
 int getThreadPoolMaxSize()
           
 long getTransactionTimeout()
           
 long getTransactionTimeoutScanPeriod()
           
 boolean isAIOFlushOnSync()
           
 boolean isBackup()
           
 boolean isClustered()
           
 boolean isCreateBindingsDir()
           
 boolean isCreateJournalDir()
           
 boolean isFileDeploymentEnabled()
           
 boolean isJMXManagementEnabled()
           
 boolean isJournalSyncNonTransactional()
           
 boolean isJournalSyncTransactional()
           
 boolean isLogJournalWriteRate()
           
 boolean isMessageCounterEnabled()
           
 boolean isPersistDeliveryCountBeforeDelivery()
           
 boolean isPersistenceEnabled()
           
 boolean isPersistIDCache()
           
 boolean isSecurityEnabled()
           
 boolean isStarted()
           
 boolean isWildcardRoutingEnabled()
           
 void setAcceptorConfigurations(java.util.Set<TransportConfiguration> infos)
           
 void setAIOBufferSize(int size)
           
 void setAIOBufferTimeout(int timeout)
           
 void setAIOFlushOnSync(boolean flush)
           
 void setBackup(boolean backup)
           
 void setBackupConnectorName(java.lang.String backupConnectorName)
           
 void setBindingsDirectory(java.lang.String dir)
           
 void setBridgeConfigurations(java.util.List<BridgeConfiguration> configs)
           
 void setBroadcastGroupConfigurations(java.util.List<BroadcastGroupConfiguration> configs)
           
 void setClusterConfigurations(java.util.List<ClusterConnectionConfiguration> configs)
           
 void setClustered(boolean clustered)
           
 void setConnectionTTLOverride(long ttl)
           
 void setConnectorConfigurations(java.util.Map<java.lang.String,TransportConfiguration> infos)
           
 void setCreateBindingsDir(boolean create)
           
 void setCreateJournalDir(boolean create)
           
 void setDiscoveryGroupConfigurations(java.util.Map<java.lang.String,DiscoveryGroupConfiguration> discoveryGroupConfigurations)
           
 void setDivertConfigurations(java.util.List<DivertConfiguration> configs)
           
 void setFileDeployerScanPeriod(long period)
           
 void setFileDeploymentEnabled(boolean enable)
           
 void setGlobalPagingSize(int pageSize)
           
 void setIDCacheSize(int idCacheSize)
           
 void setInterceptorClassNames(java.util.List<java.lang.String> interceptors)
           
 void setJMXManagementEnabled(boolean enabled)
           
 void setJournalDirectory(java.lang.String dir)
           
 void setJournalFileSize(int size)
           
 void setJournalMaxAIO(int maxAIO)
           
 void setJournalMinFiles(int files)
           
 void setJournalPerfBlastPages(int journalPerfBlastPages)
           
 void setJournalSyncNonTransactional(boolean sync)
           
 void setJournalSyncTransactional(boolean sync)
           
 void setJournalType(JournalType type)
           
 void setLargeMessagesDirectory(java.lang.String directory)
           
 void setLogJournalWriteRate(boolean logJournalWriteRate)
           
 void setManagementAddress(SimpleString address)
           
 void setManagementClusterPassword(java.lang.String clusterPassword)
           
 void setManagementNotificationAddress(SimpleString address)
           
 void setManagementRequestTimeout(long managementRequestTimeout)
           
 void setMessageExpiryScanPeriod(long messageExpiryScanPeriod)
           
 void setMessageExpiryThreadPriority(int messageExpiryThreadPriority)
           
 void setPagingDirectory(java.lang.String dir)
           
 void setPagingMaxGlobalSizeBytes(long maxGlobalSize)
           
 void setPersistDeliveryCountBeforeDelivery(boolean persistDeliveryCountBeforeDelivery)
           
 void setPersistenceEnabled(boolean enable)
           
 void setPersistIDCache(boolean persist)
           
 void setQueueActivationTimeout(long timeout)
           
 void setQueueConfigurations(java.util.List<QueueConfiguration> configs)
           
 void setScheduledThreadPoolMaxSize(int maxSize)
           
 void setSecurityEnabled(boolean enabled)
           
 void setSecurityInvalidationInterval(long interval)
           
 void setThreadPoolMaxSize(int maxSize)
           
 void setTransactionTimeout(long timeout)
           
 void setTransactionTimeoutScanPeriod(long period)
           
 void setWildcardRoutingEnabled(boolean enabled)
           
 void start()
           
 void stop()
           
 
Methods inherited from class java.lang.Object
clone, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

DEFAULT_CLUSTERED

public static final boolean DEFAULT_CLUSTERED
See Also:
Constant Field Values

DEFAULT_PERSIST_DELIVERY_COUNT_BEFORE_DELIVERY

public static final boolean DEFAULT_PERSIST_DELIVERY_COUNT_BEFORE_DELIVERY
See Also:
Constant Field Values

DEFAULT_BACKUP

public static final boolean DEFAULT_BACKUP
See Also:
Constant Field Values

DEFAULT_FILE_DEPLOYMENT_ENABLED

public static final boolean DEFAULT_FILE_DEPLOYMENT_ENABLED
See Also:
Constant Field Values

DEFAULT_PERSISTENCE_ENABLED

public static final boolean DEFAULT_PERSISTENCE_ENABLED
See Also:
Constant Field Values

DEFAULT_FILE_DEPLOYER_SCAN_PERIOD

public static final long DEFAULT_FILE_DEPLOYER_SCAN_PERIOD
See Also:
Constant Field Values

DEFAULT_QUEUE_ACTIVATION_TIMEOUT

public static final long DEFAULT_QUEUE_ACTIVATION_TIMEOUT
See Also:
Constant Field Values

DEFAULT_SCHEDULED_THREAD_POOL_MAX_SIZE

public static final int DEFAULT_SCHEDULED_THREAD_POOL_MAX_SIZE
See Also:
Constant Field Values

DEFAULT_THREAD_POOL_MAX_SIZE

public static final int DEFAULT_THREAD_POOL_MAX_SIZE
See Also:
Constant Field Values

DEFAULT_SECURITY_INVALIDATION_INTERVAL

public static final long DEFAULT_SECURITY_INVALIDATION_INTERVAL
See Also:
Constant Field Values

DEFAULT_SECURITY_ENABLED

public static final boolean DEFAULT_SECURITY_ENABLED
See Also:
Constant Field Values

DEFAULT_JMX_MANAGEMENT_ENABLED

public static final boolean DEFAULT_JMX_MANAGEMENT_ENABLED
See Also:
Constant Field Values

DEFAULT_CONNECTION_TTL_OVERRIDE

public static final long DEFAULT_CONNECTION_TTL_OVERRIDE
See Also:
Constant Field Values

DEFAULT_BINDINGS_DIRECTORY

public static final java.lang.String DEFAULT_BINDINGS_DIRECTORY
See Also:
Constant Field Values

DEFAULT_CREATE_BINDINGS_DIR

public static final boolean DEFAULT_CREATE_BINDINGS_DIR
See Also:
Constant Field Values

DEFAULT_JOURNAL_DIR

public static final java.lang.String DEFAULT_JOURNAL_DIR
See Also:
Constant Field Values

DEFAULT_PAGING_DIR

public static final java.lang.String DEFAULT_PAGING_DIR
See Also:
Constant Field Values

DEFAULT_GLOBAL_PAGE_SIZE

public static final int DEFAULT_GLOBAL_PAGE_SIZE
See Also:
Constant Field Values

DEFAULT_PAGE_MAX_GLOBAL_SIZE

public static final long DEFAULT_PAGE_MAX_GLOBAL_SIZE
See Also:
Constant Field Values

DEFAULT_LARGE_MESSAGES_DIR

public static final java.lang.String DEFAULT_LARGE_MESSAGES_DIR
See Also:
Constant Field Values

DEFAULT_CREATE_JOURNAL_DIR

public static final boolean DEFAULT_CREATE_JOURNAL_DIR
See Also:
Constant Field Values

DEFAULT_JOURNAL_TYPE

public static final JournalType DEFAULT_JOURNAL_TYPE

DEFAULT_JOURNAL_SYNC_TRANSACTIONAL

public static final boolean DEFAULT_JOURNAL_SYNC_TRANSACTIONAL
See Also:
Constant Field Values

DEFAULT_JOURNAL_SYNC_NON_TRANSACTIONAL

public static final boolean DEFAULT_JOURNAL_SYNC_NON_TRANSACTIONAL
See Also:
Constant Field Values

DEFAULT_JOURNAL_FILE_SIZE

public static final int DEFAULT_JOURNAL_FILE_SIZE
See Also:
Constant Field Values

DEFAULT_JOURNAL_MIN_FILES

public static final int DEFAULT_JOURNAL_MIN_FILES
See Also:
Constant Field Values

DEFAULT_JOURNAL_MAX_AIO

public static final int DEFAULT_JOURNAL_MAX_AIO
See Also:
Constant Field Values

DEFAULT_JOURNAL_AIO_FLUSH_SYNC

public static final boolean DEFAULT_JOURNAL_AIO_FLUSH_SYNC
See Also:
Constant Field Values

DEFAULT_JOURNAL_AIO_BUFFER_TIMEOUT

public static final int DEFAULT_JOURNAL_AIO_BUFFER_TIMEOUT
See Also:
Constant Field Values

DEFAULT_JOURNAL_AIO_BUFFER_SIZE

public static final int DEFAULT_JOURNAL_AIO_BUFFER_SIZE
See Also:
Constant Field Values

DEFAULT_JOURNAL_LOG_WRITE_RATE

public static final boolean DEFAULT_JOURNAL_LOG_WRITE_RATE
See Also:
Constant Field Values

DEFAULT_JOURNAL_PERF_BLAST_PAGES

public static final int DEFAULT_JOURNAL_PERF_BLAST_PAGES
See Also:
Constant Field Values

DEFAULT_WILDCARD_ROUTING_ENABLED

public static final boolean DEFAULT_WILDCARD_ROUTING_ENABLED
See Also:
Constant Field Values

DEFAULT_MESSAGE_COUNTER_ENABLED

public static final boolean DEFAULT_MESSAGE_COUNTER_ENABLED
See Also:
Constant Field Values

DEFAULT_MESSAGE_COUNTER_SAMPLE_PERIOD

public static final long DEFAULT_MESSAGE_COUNTER_SAMPLE_PERIOD
See Also:
Constant Field Values

DEFAULT_MESSAGE_COUNTER_MAX_DAY_HISTORY

public static final int DEFAULT_MESSAGE_COUNTER_MAX_DAY_HISTORY
See Also:
Constant Field Values

DEFAULT_TRANSACTION_TIMEOUT

public static final long DEFAULT_TRANSACTION_TIMEOUT
See Also:
Constant Field Values

DEFAULT_TRANSACTION_TIMEOUT_SCAN_PERIOD

public static final long DEFAULT_TRANSACTION_TIMEOUT_SCAN_PERIOD
See Also:
Constant Field Values

DEFAULT_MANAGEMENT_ADDRESS

public static final SimpleString DEFAULT_MANAGEMENT_ADDRESS

DEFAULT_MANAGEMENT_NOTIFICATION_ADDRESS

public static final SimpleString DEFAULT_MANAGEMENT_NOTIFICATION_ADDRESS

DEFAULT_MANAGEMENT_CLUSTER_USER

public static final java.lang.String DEFAULT_MANAGEMENT_CLUSTER_USER
See Also:
Constant Field Values

DEFAULT_MANAGEMENT_CLUSTER_PASSWORD

public static final java.lang.String DEFAULT_MANAGEMENT_CLUSTER_PASSWORD
See Also:
Constant Field Values

DEFAULT_MANAGEMENT_REQUEST_TIMEOUT

public static final long DEFAULT_MANAGEMENT_REQUEST_TIMEOUT
See Also:
Constant Field Values

DEFAULT_BROADCAST_PERIOD

public static final long DEFAULT_BROADCAST_PERIOD
See Also:
Constant Field Values

DEFAULT_BROADCAST_REFRESH_TIMEOUT

public static final long DEFAULT_BROADCAST_REFRESH_TIMEOUT
See Also:
Constant Field Values

DEFAULT_MESSAGE_EXPIRY_SCAN_PERIOD

public static final long DEFAULT_MESSAGE_EXPIRY_SCAN_PERIOD
See Also:
Constant Field Values

DEFAULT_MESSAGE_EXPIRY_THREAD_PRIORITY

public static final int DEFAULT_MESSAGE_EXPIRY_THREAD_PRIORITY
See Also:
Constant Field Values

DEFAULT_ID_CACHE_SIZE

public static final int DEFAULT_ID_CACHE_SIZE
See Also:
Constant Field Values

DEFAULT_PERSIST_ID_CACHE

public static final boolean DEFAULT_PERSIST_ID_CACHE
See Also:
Constant Field Values

DEFAULT_CLUSTER_DUPLICATE_DETECTION

public static final boolean DEFAULT_CLUSTER_DUPLICATE_DETECTION
See Also:
Constant Field Values

DEFAULT_CLUSTER_FORWARD_WHEN_NO_CONSUMERS

public static final boolean DEFAULT_CLUSTER_FORWARD_WHEN_NO_CONSUMERS
See Also:
Constant Field Values

DEFAULT_CLUSTER_MAX_HOPS

public static final int DEFAULT_CLUSTER_MAX_HOPS
See Also:
Constant Field Values

DEFAULT_CLUSTER_RETRY_INTERVAL

public static final int DEFAULT_CLUSTER_RETRY_INTERVAL
See Also:
Constant Field Values

DEFAULT_DIVERT_EXCLUSIVE

public static final boolean DEFAULT_DIVERT_EXCLUSIVE
See Also:
Constant Field Values

DEFAULT_BRIDGE_DUPLICATE_DETECTION

public static final boolean DEFAULT_BRIDGE_DUPLICATE_DETECTION
See Also:
Constant Field Values

DEFAULT_BRIDGE_RECONNECT_ATTEMPTS

public static final int DEFAULT_BRIDGE_RECONNECT_ATTEMPTS
See Also:
Constant Field Values

clustered

protected boolean clustered

backup

protected boolean backup

fileDeploymentEnabled

protected boolean fileDeploymentEnabled

persistenceEnabled

protected boolean persistenceEnabled

fileDeploymentScanPeriod

protected long fileDeploymentScanPeriod

persistDeliveryCountBeforeDelivery

protected boolean persistDeliveryCountBeforeDelivery

queueActivationTimeout

protected long queueActivationTimeout

scheduledThreadPoolMaxSize

protected int scheduledThreadPoolMaxSize

threadPoolMaxSize

protected int threadPoolMaxSize

securityInvalidationInterval

protected long securityInvalidationInterval

securityEnabled

protected boolean securityEnabled

jmxManagementEnabled

protected boolean jmxManagementEnabled

connectionTTLOverride

protected long connectionTTLOverride

messageExpiryScanPeriod

protected long messageExpiryScanPeriod

messageExpiryThreadPriority

protected int messageExpiryThreadPriority

idCacheSize

protected int idCacheSize

persistIDCache

protected boolean persistIDCache

interceptorClassNames

protected java.util.List<java.lang.String> interceptorClassNames

connectorConfigs

protected java.util.Map<java.lang.String,TransportConfiguration> connectorConfigs

acceptorConfigs

protected java.util.Set<TransportConfiguration> acceptorConfigs

backupConnectorName

protected java.lang.String backupConnectorName

bridgeConfigurations

protected java.util.List<BridgeConfiguration> bridgeConfigurations

divertConfigurations

protected java.util.List<DivertConfiguration> divertConfigurations

clusterConfigurations

protected java.util.List<ClusterConnectionConfiguration> clusterConfigurations

queueConfigurations

protected java.util.List<QueueConfiguration> queueConfigurations

broadcastGroupConfigurations

protected java.util.List<BroadcastGroupConfiguration> broadcastGroupConfigurations

discoveryGroupConfigurations

protected java.util.Map<java.lang.String,DiscoveryGroupConfiguration> discoveryGroupConfigurations

pagingMaxGlobalSize

protected long pagingMaxGlobalSize

globalPageSize

protected int globalPageSize

pagingDirectory

protected java.lang.String pagingDirectory

largeMessagesDirectory

protected java.lang.String largeMessagesDirectory

bindingsDirectory

protected java.lang.String bindingsDirectory

createBindingsDir

protected boolean createBindingsDir

journalDirectory

protected java.lang.String journalDirectory

createJournalDir

protected boolean createJournalDir

journalType

public JournalType journalType

journalSyncTransactional

protected boolean journalSyncTransactional

journalSyncNonTransactional

protected boolean journalSyncNonTransactional

journalFileSize

protected int journalFileSize

journalMinFiles

protected int journalMinFiles

journalMaxAIO

protected int journalMaxAIO

journalAIOFlushSync

protected boolean journalAIOFlushSync

journalAIOBufferTimeout

protected int journalAIOBufferTimeout

journalAIOBufferSize

protected int journalAIOBufferSize

logJournalWriteRate

protected boolean logJournalWriteRate

journalPerfBlastPages

protected int journalPerfBlastPages

wildcardRoutingEnabled

protected boolean wildcardRoutingEnabled

messageCounterEnabled

protected boolean messageCounterEnabled

messageCounterSamplePeriod

protected long messageCounterSamplePeriod

messageCounterMaxDayHistory

protected int messageCounterMaxDayHistory

transactionTimeout

protected long transactionTimeout

transactionTimeoutScanPeriod

protected long transactionTimeoutScanPeriod

managementAddress

protected SimpleString managementAddress

managementNotificationAddress

protected SimpleString managementNotificationAddress

managementClusterUser

protected java.lang.String managementClusterUser

managementClusterPassword

protected java.lang.String managementClusterPassword

managementRequestTimeout

protected long managementRequestTimeout
Constructor Detail

ConfigurationImpl

public ConfigurationImpl()
Method Detail

start

public void start()
           throws java.lang.Exception
Specified by:
start in interface MessagingComponent
Throws:
java.lang.Exception

stop

public void stop()
          throws java.lang.Exception
Specified by:
stop in interface MessagingComponent
Throws:
java.lang.Exception

isStarted

public boolean isStarted()
Specified by:
isStarted in interface MessagingComponent

isClustered

public boolean isClustered()
Specified by:
isClustered in interface Configuration

setClustered

public void setClustered(boolean clustered)
Specified by:
setClustered in interface Configuration

isBackup

public boolean isBackup()
Specified by:
isBackup in interface Configuration

isFileDeploymentEnabled

public boolean isFileDeploymentEnabled()
Specified by:
isFileDeploymentEnabled in interface Configuration

setFileDeploymentEnabled

public void setFileDeploymentEnabled(boolean enable)
Specified by:
setFileDeploymentEnabled in interface Configuration

isPersistenceEnabled

public boolean isPersistenceEnabled()
Specified by:
isPersistenceEnabled in interface Configuration

setPersistenceEnabled

public void setPersistenceEnabled(boolean enable)
Specified by:
setPersistenceEnabled in interface Configuration

getFileDeployerScanPeriod

public long getFileDeployerScanPeriod()
Specified by:
getFileDeployerScanPeriod in interface Configuration

setFileDeployerScanPeriod

public void setFileDeployerScanPeriod(long period)
Specified by:
setFileDeployerScanPeriod in interface Configuration

isPersistDeliveryCountBeforeDelivery

public boolean isPersistDeliveryCountBeforeDelivery()
Specified by:
isPersistDeliveryCountBeforeDelivery in interface Configuration
Returns:
the persistDeliveryCountBeforeDelivery

setPersistDeliveryCountBeforeDelivery

public void setPersistDeliveryCountBeforeDelivery(boolean persistDeliveryCountBeforeDelivery)
Specified by:
setPersistDeliveryCountBeforeDelivery in interface Configuration
Parameters:
strictJMS - the strictJMS to set

setBackup

public void setBackup(boolean backup)
Specified by:
setBackup in interface Configuration

getQueueActivationTimeout

public long getQueueActivationTimeout()
Specified by:
getQueueActivationTimeout in interface Configuration

setQueueActivationTimeout

public void setQueueActivationTimeout(long timeout)
Specified by:
setQueueActivationTimeout in interface Configuration

getScheduledThreadPoolMaxSize

public int getScheduledThreadPoolMaxSize()
Specified by:
getScheduledThreadPoolMaxSize in interface Configuration

setScheduledThreadPoolMaxSize

public void setScheduledThreadPoolMaxSize(int maxSize)
Specified by:
setScheduledThreadPoolMaxSize in interface Configuration

getThreadPoolMaxSize

public int getThreadPoolMaxSize()
Specified by:
getThreadPoolMaxSize in interface Configuration

setThreadPoolMaxSize

public void setThreadPoolMaxSize(int maxSize)
Specified by:
setThreadPoolMaxSize in interface Configuration

getSecurityInvalidationInterval

public long getSecurityInvalidationInterval()
Specified by:
getSecurityInvalidationInterval in interface Configuration

setSecurityInvalidationInterval

public void setSecurityInvalidationInterval(long interval)
Specified by:
setSecurityInvalidationInterval in interface Configuration

getConnectionTTLOverride

public long getConnectionTTLOverride()
Specified by:
getConnectionTTLOverride in interface Configuration

setConnectionTTLOverride

public void setConnectionTTLOverride(long ttl)
Specified by:
setConnectionTTLOverride in interface Configuration

getInterceptorClassNames

public java.util.List<java.lang.String> getInterceptorClassNames()
Specified by:
getInterceptorClassNames in interface Configuration

setInterceptorClassNames

public void setInterceptorClassNames(java.util.List<java.lang.String> interceptors)
Specified by:
setInterceptorClassNames in interface Configuration

getAcceptorConfigurations

public java.util.Set<TransportConfiguration> getAcceptorConfigurations()
Specified by:
getAcceptorConfigurations in interface Configuration

setAcceptorConfigurations

public void setAcceptorConfigurations(java.util.Set<TransportConfiguration> infos)
Specified by:
setAcceptorConfigurations in interface Configuration

getConnectorConfigurations

public java.util.Map<java.lang.String,TransportConfiguration> getConnectorConfigurations()
Specified by:
getConnectorConfigurations in interface Configuration

setConnectorConfigurations

public void setConnectorConfigurations(java.util.Map<java.lang.String,TransportConfiguration> infos)
Specified by:
setConnectorConfigurations in interface Configuration

getBackupConnectorName

public java.lang.String getBackupConnectorName()
Specified by:
getBackupConnectorName in interface Configuration

setBackupConnectorName

public void setBackupConnectorName(java.lang.String backupConnectorName)
Specified by:
setBackupConnectorName in interface Configuration

getBridgeConfigurations

public java.util.List<BridgeConfiguration> getBridgeConfigurations()
Specified by:
getBridgeConfigurations in interface Configuration

setBridgeConfigurations

public void setBridgeConfigurations(java.util.List<BridgeConfiguration> configs)
Specified by:
setBridgeConfigurations in interface Configuration

getBroadcastGroupConfigurations

public java.util.List<BroadcastGroupConfiguration> getBroadcastGroupConfigurations()
Specified by:
getBroadcastGroupConfigurations in interface Configuration

setBroadcastGroupConfigurations

public void setBroadcastGroupConfigurations(java.util.List<BroadcastGroupConfiguration> configs)
Specified by:
setBroadcastGroupConfigurations in interface Configuration

getClusterConfigurations

public java.util.List<ClusterConnectionConfiguration> getClusterConfigurations()
Specified by:
getClusterConfigurations in interface Configuration

setClusterConfigurations

public void setClusterConfigurations(java.util.List<ClusterConnectionConfiguration> configs)
Specified by:
setClusterConfigurations in interface Configuration

getDivertConfigurations

public java.util.List<DivertConfiguration> getDivertConfigurations()
Specified by:
getDivertConfigurations in interface Configuration

setDivertConfigurations

public void setDivertConfigurations(java.util.List<DivertConfiguration> configs)
Specified by:
setDivertConfigurations in interface Configuration

getQueueConfigurations

public java.util.List<QueueConfiguration> getQueueConfigurations()
Specified by:
getQueueConfigurations in interface Configuration

setQueueConfigurations

public void setQueueConfigurations(java.util.List<QueueConfiguration> configs)
Specified by:
setQueueConfigurations in interface Configuration

getDiscoveryGroupConfigurations

public java.util.Map<java.lang.String,DiscoveryGroupConfiguration> getDiscoveryGroupConfigurations()
Specified by:
getDiscoveryGroupConfigurations in interface Configuration

setDiscoveryGroupConfigurations

public void setDiscoveryGroupConfigurations(java.util.Map<java.lang.String,DiscoveryGroupConfiguration> discoveryGroupConfigurations)
Specified by:
setDiscoveryGroupConfigurations in interface Configuration

getIDCacheSize

public int getIDCacheSize()
Specified by:
getIDCacheSize in interface Configuration

setIDCacheSize

public void setIDCacheSize(int idCacheSize)
Specified by:
setIDCacheSize in interface Configuration

isPersistIDCache

public boolean isPersistIDCache()
Specified by:
isPersistIDCache in interface Configuration

setPersistIDCache

public void setPersistIDCache(boolean persist)
Specified by:
setPersistIDCache in interface Configuration

getBindingsDirectory

public java.lang.String getBindingsDirectory()
Specified by:
getBindingsDirectory in interface Configuration

setBindingsDirectory

public void setBindingsDirectory(java.lang.String dir)
Specified by:
setBindingsDirectory in interface Configuration

getJournalDirectory

public java.lang.String getJournalDirectory()
Specified by:
getJournalDirectory in interface Configuration

setJournalDirectory

public void setJournalDirectory(java.lang.String dir)
Specified by:
setJournalDirectory in interface Configuration

getJournalType

public JournalType getJournalType()
Specified by:
getJournalType in interface Configuration

setPagingDirectory

public void setPagingDirectory(java.lang.String dir)
Specified by:
setPagingDirectory in interface Configuration

getPagingDirectory

public java.lang.String getPagingDirectory()
Specified by:
getPagingDirectory in interface Configuration

setJournalType

public void setJournalType(JournalType type)
Specified by:
setJournalType in interface Configuration

isJournalSyncTransactional

public boolean isJournalSyncTransactional()
Specified by:
isJournalSyncTransactional in interface Configuration

setJournalSyncTransactional

public void setJournalSyncTransactional(boolean sync)
Specified by:
setJournalSyncTransactional in interface Configuration

isJournalSyncNonTransactional

public boolean isJournalSyncNonTransactional()
Specified by:
isJournalSyncNonTransactional in interface Configuration

setJournalSyncNonTransactional

public void setJournalSyncNonTransactional(boolean sync)
Specified by:
setJournalSyncNonTransactional in interface Configuration

getJournalFileSize

public int getJournalFileSize()
Specified by:
getJournalFileSize in interface Configuration

setJournalFileSize

public void setJournalFileSize(int size)
Specified by:
setJournalFileSize in interface Configuration

getJournalMaxAIO

public int getJournalMaxAIO()
Specified by:
getJournalMaxAIO in interface Configuration

setJournalMaxAIO

public void setJournalMaxAIO(int maxAIO)
Specified by:
setJournalMaxAIO in interface Configuration

getJournalMinFiles

public int getJournalMinFiles()
Specified by:
getJournalMinFiles in interface Configuration

setJournalMinFiles

public void setJournalMinFiles(int files)
Specified by:
setJournalMinFiles in interface Configuration

isLogJournalWriteRate

public boolean isLogJournalWriteRate()
Specified by:
isLogJournalWriteRate in interface Configuration

setLogJournalWriteRate

public void setLogJournalWriteRate(boolean logJournalWriteRate)
Specified by:
setLogJournalWriteRate in interface Configuration

getJournalPerfBlastPages

public int getJournalPerfBlastPages()
Specified by:
getJournalPerfBlastPages in interface Configuration

setJournalPerfBlastPages

public void setJournalPerfBlastPages(int journalPerfBlastPages)
Specified by:
setJournalPerfBlastPages in interface Configuration

isCreateBindingsDir

public boolean isCreateBindingsDir()
Specified by:
isCreateBindingsDir in interface Configuration

setCreateBindingsDir

public void setCreateBindingsDir(boolean create)
Specified by:
setCreateBindingsDir in interface Configuration

isCreateJournalDir

public boolean isCreateJournalDir()
Specified by:
isCreateJournalDir in interface Configuration

setCreateJournalDir

public void setCreateJournalDir(boolean create)
Specified by:
setCreateJournalDir in interface Configuration

isWildcardRoutingEnabled

public boolean isWildcardRoutingEnabled()
Specified by:
isWildcardRoutingEnabled in interface Configuration

setWildcardRoutingEnabled

public void setWildcardRoutingEnabled(boolean enabled)
Specified by:
setWildcardRoutingEnabled in interface Configuration

getTransactionTimeout

public long getTransactionTimeout()
Specified by:
getTransactionTimeout in interface Configuration

setTransactionTimeout

public void setTransactionTimeout(long timeout)
Specified by:
setTransactionTimeout in interface Configuration

getTransactionTimeoutScanPeriod

public long getTransactionTimeoutScanPeriod()
Specified by:
getTransactionTimeoutScanPeriod in interface Configuration

setTransactionTimeoutScanPeriod

public void setTransactionTimeoutScanPeriod(long period)
Specified by:
setTransactionTimeoutScanPeriod in interface Configuration

getMessageExpiryScanPeriod

public long getMessageExpiryScanPeriod()
Specified by:
getMessageExpiryScanPeriod in interface Configuration

setMessageExpiryScanPeriod

public void setMessageExpiryScanPeriod(long messageExpiryScanPeriod)
Specified by:
setMessageExpiryScanPeriod in interface Configuration

getMessageExpiryThreadPriority

public int getMessageExpiryThreadPriority()
Specified by:
getMessageExpiryThreadPriority in interface Configuration

setMessageExpiryThreadPriority

public void setMessageExpiryThreadPriority(int messageExpiryThreadPriority)
Specified by:
setMessageExpiryThreadPriority in interface Configuration

isSecurityEnabled

public boolean isSecurityEnabled()
Specified by:
isSecurityEnabled in interface Configuration

setSecurityEnabled

public void setSecurityEnabled(boolean enabled)
Specified by:
setSecurityEnabled in interface Configuration

isJMXManagementEnabled

public boolean isJMXManagementEnabled()
Specified by:
isJMXManagementEnabled in interface Configuration

setJMXManagementEnabled

public void setJMXManagementEnabled(boolean enabled)
Specified by:
setJMXManagementEnabled in interface Configuration

setAIOBufferTimeout

public void setAIOBufferTimeout(int timeout)
Specified by:
setAIOBufferTimeout in interface Configuration

getAIOBufferTimeout

public int getAIOBufferTimeout()
Specified by:
getAIOBufferTimeout in interface Configuration

setAIOFlushOnSync

public void setAIOFlushOnSync(boolean flush)
Specified by:
setAIOFlushOnSync in interface Configuration

isAIOFlushOnSync

public boolean isAIOFlushOnSync()
Specified by:
isAIOFlushOnSync in interface Configuration

getAIOBufferSize

public int getAIOBufferSize()
Specified by:
getAIOBufferSize in interface Configuration

setAIOBufferSize

public void setAIOBufferSize(int size)
Specified by:
setAIOBufferSize in interface Configuration

getPagingMaxGlobalSizeBytes

public long getPagingMaxGlobalSizeBytes()
Specified by:
getPagingMaxGlobalSizeBytes in interface Configuration

setPagingMaxGlobalSizeBytes

public void setPagingMaxGlobalSizeBytes(long maxGlobalSize)
Specified by:
setPagingMaxGlobalSizeBytes in interface Configuration

getGlobalPagingSize

public int getGlobalPagingSize()
Specified by:
getGlobalPagingSize in interface Configuration

setGlobalPagingSize

public void setGlobalPagingSize(int pageSize)
Specified by:
setGlobalPagingSize in interface Configuration

getLargeMessagesDirectory

public java.lang.String getLargeMessagesDirectory()
Specified by:
getLargeMessagesDirectory in interface Configuration

setLargeMessagesDirectory

public void setLargeMessagesDirectory(java.lang.String directory)
Specified by:
setLargeMessagesDirectory in interface Configuration

isMessageCounterEnabled

public boolean isMessageCounterEnabled()
Specified by:
isMessageCounterEnabled in interface Configuration

getMessageCounterSamplePeriod

public long getMessageCounterSamplePeriod()
Specified by:
getMessageCounterSamplePeriod in interface Configuration

getMessageCounterMaxDayHistory

public int getMessageCounterMaxDayHistory()
Specified by:
getMessageCounterMaxDayHistory in interface Configuration

getManagementAddress

public SimpleString getManagementAddress()
Specified by:
getManagementAddress in interface Configuration

setManagementAddress

public void setManagementAddress(SimpleString address)
Specified by:
setManagementAddress in interface Configuration

getManagementNotificationAddress

public SimpleString getManagementNotificationAddress()
Specified by:
getManagementNotificationAddress in interface Configuration

setManagementNotificationAddress

public void setManagementNotificationAddress(SimpleString address)

getManagementClusterUser

public java.lang.String getManagementClusterUser()
Specified by:
getManagementClusterUser in interface Configuration

getManagementClusterPassword

public java.lang.String getManagementClusterPassword()
Specified by:
getManagementClusterPassword in interface Configuration

setManagementClusterPassword

public void setManagementClusterPassword(java.lang.String clusterPassword)

getManagementRequestTimeout

public long getManagementRequestTimeout()
Specified by:
getManagementRequestTimeout in interface Configuration

setManagementRequestTimeout

public void setManagementRequestTimeout(long managementRequestTimeout)

equals

public boolean equals(java.lang.Object other)
Overrides:
equals in class java.lang.Object


Copyright © 2006 JBoss Inc. All Rights Reserved.