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

java.lang.Object
  org.jboss.messaging.core.config.impl.ConfigurationImpl

All Implemented Interfaces:

java.io.Serializable, Configuration

Direct Known Subclasses:

FileConfiguration

public class ConfigurationImpl
extends java.lang.Object
implements Configuration, java.io.Serializable

Author:

Tim Fox

See Also:

Serialized Form

Field Summary

protected java.lang.String	bindingsDirectory
protected boolean	clustered
protected boolean	createBindingsDir
protected boolean	createJournalDir
static long	DEFAULT_AIO_TIMEOUT
static boolean	DEFAULT_INVM_DISABLED
static int	DEFAULT_MAX_AIO
static int	DEFAULT_REMOTING_PORT
static boolean	DEFAULT_SSL_ENABLED
protected java.util.List<java.lang.String>	defaultInterceptors
protected java.lang.String	host
protected boolean	invmDisabled
protected boolean	invmDisabledModified
protected long	journalAIOTimeout
protected java.lang.String	journalDirectory
protected int	journalFileSize
protected int	journalMaxAIO
protected int	journalMinFiles
protected boolean	journalSyncNonTransactional
protected boolean	journalSyncTransactional
protected long	journalTaskPeriod
JournalType	journalType
protected long	keepAliveInterval
protected long	keepAliveTimeout
protected java.lang.String	keyStorePassword
protected java.lang.String	keyStorePath
protected int	port
static java.lang.String	REMOTING_DISABLE_INVM_SYSPROP_KEY
static java.lang.String	REMOTING_ENABLE_SSL_SYSPROP_KEY
protected boolean	requireDestinations
protected int	scheduledThreadPoolMaxSize
protected boolean	securityEnabled
protected long	securityInvalidationInterval
protected int	serverID
protected boolean	sslEnabled
protected boolean	sslEnabledModified
protected boolean	tcpNoDelay
protected int	tcpReceiveBufferSize
protected int	tcpSendBufferSize
protected long	timeout
protected TransportType	transport
protected java.lang.String	trustStorePassword
protected java.lang.String	trustStorePath
protected long	writeQueueBlockTimeout
protected long	writeQueueMaxBytes
protected long	writeQueueMinBytes

Constructor Summary

ConfigurationImpl()

Method Summary

java.lang.String	getBindingsDirectory()
ConnectionParams	getConnectionParams()
java.util.List<java.lang.String>	getDefaultInterceptors()
java.lang.String	getHost()
long	getJournalAIOTimeout()
java.lang.String	getJournalDirectory()
int	getJournalFileSize()
int	getJournalMaxAIO()
int	getJournalMinFiles()
long	getJournalTaskPeriod()
JournalType	getJournalType()
long	getKeepAliveInterval()
long	getKeepAliveTimeout()
java.lang.String	getKeyStorePassword()
java.lang.String	getKeyStorePath()
Location	getLocation()
int	getPort()
java.lang.Integer	getScheduledThreadPoolMaxSize()
long	getSecurityInvalidationInterval()
int	getServerID() The server ID is used only when the messaging server is started in INVM transport.
int	getTcpReceiveBufferSize()
int	getTcpSendBufferSize()
long	getTimeout()
TransportType	getTransport()
java.lang.String	getTrustStorePassword()
java.lang.String	getTrustStorePath()
java.lang.String	getURI()
long	getWriteQueueBlockTimeout()
long	getWriteQueueMaxBytes()
long	getWriteQueueMinBytes()
java.lang.Boolean	isClustered()
boolean	isCreateBindingsDir()
boolean	isCreateJournalDir()
boolean	isInvmDisabled()
boolean	isJournalSyncNonTransactional()
boolean	isJournalSyncTransactional()
boolean	isRequireDestinations()
boolean	isSecurityEnabled()
boolean	isSSLEnabled()
boolean	isTcpNoDelay()
void	setHost(java.lang.String host)
void	setInvmDisabled(boolean invmDisabled)
void	setJournalMaxAIO(int max)
void	setJournalType(JournalType type)
void	setKeepAliveInterval(long keepAliveInterval)
void	setKeepAliveTimeout(long keepAliveTimeout)
void	setKeyStorePassword(java.lang.String keyStorePassword)
void	setKeyStorePath(java.lang.String keyStorePath)
void	setPort(int port)
void	setSecurityEnabled(boolean enabled)
void	setServerID(int serverID)
void	setSSLEnabled(boolean sslEnabled)
void	setTcpNoDelay(boolean tcpNoDelay)
void	setTcpReceiveBufferSize(int size)
void	setTcpSendBufferSize(int size)
void	setTransport(TransportType transport)
void	setTrustStorePassword(java.lang.String trustStorePassword)
void	setTrustStorePath(java.lang.String trustStorePath)
void	setWriteQueueBlockTimeout(long timeout)
void	setWriteQueueMaxBytes(long bytes)
void	setWriteQueueMinBytes(long bytes)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

REMOTING_DISABLE_INVM_SYSPROP_KEY

public static final java.lang.String REMOTING_DISABLE_INVM_SYSPROP_KEY

See Also:

Constant Field Values

REMOTING_ENABLE_SSL_SYSPROP_KEY

public static final java.lang.String REMOTING_ENABLE_SSL_SYSPROP_KEY

See Also:

Constant Field Values

DEFAULT_REMOTING_PORT

public static final int DEFAULT_REMOTING_PORT

See Also:

Constant Field Values

DEFAULT_INVM_DISABLED

public static final boolean DEFAULT_INVM_DISABLED

See Also:

Constant Field Values

DEFAULT_SSL_ENABLED

public static final boolean DEFAULT_SSL_ENABLED

See Also:

Constant Field Values

DEFAULT_MAX_AIO

public static final int DEFAULT_MAX_AIO

See Also:

Constant Field Values

DEFAULT_AIO_TIMEOUT

public static final long DEFAULT_AIO_TIMEOUT

See Also:

Constant Field Values

defaultInterceptors

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

clustered

protected boolean clustered

scheduledThreadPoolMaxSize

protected int scheduledThreadPoolMaxSize

securityInvalidationInterval

protected long securityInvalidationInterval

requireDestinations

protected boolean requireDestinations

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

journalAIOTimeout

protected long journalAIOTimeout

journalTaskPeriod

protected long journalTaskPeriod

securityEnabled

protected boolean securityEnabled

transport

protected TransportType transport

host

protected java.lang.String host

port

protected int port

serverID

protected int serverID

timeout

protected long timeout

keepAliveInterval

protected long keepAliveInterval

keepAliveTimeout

protected long keepAliveTimeout

invmDisabled

protected boolean invmDisabled

invmDisabledModified

protected boolean invmDisabledModified

tcpNoDelay

protected boolean tcpNoDelay

writeQueueBlockTimeout

protected long writeQueueBlockTimeout

writeQueueMinBytes

protected long writeQueueMinBytes

writeQueueMaxBytes

protected long writeQueueMaxBytes

tcpReceiveBufferSize

protected int tcpReceiveBufferSize

tcpSendBufferSize

protected int tcpSendBufferSize

sslEnabled

protected boolean sslEnabled

sslEnabledModified

protected boolean sslEnabledModified

keyStorePath

protected java.lang.String keyStorePath

keyStorePassword

protected java.lang.String keyStorePassword

trustStorePath

protected java.lang.String trustStorePath

trustStorePassword

protected java.lang.String trustStorePassword

Constructor Detail

ConfigurationImpl

public ConfigurationImpl()

Method Detail

getDefaultInterceptors

public java.util.List<java.lang.String> getDefaultInterceptors()

Specified by:

getDefaultInterceptors in interface Configuration

isClustered

public java.lang.Boolean isClustered()

Specified by:

isClustered in interface Configuration

getScheduledThreadPoolMaxSize

public java.lang.Integer getScheduledThreadPoolMaxSize()

Specified by:

getScheduledThreadPoolMaxSize in interface Configuration

getSecurityInvalidationInterval

public long getSecurityInvalidationInterval()

Specified by:

getSecurityInvalidationInterval in interface Configuration

getTransport

public TransportType getTransport()

Specified by:

getTransport in interface Configuration

setTransport

public void setTransport(TransportType transport)

getHost

public java.lang.String getHost()

Specified by:

getHost in interface Configuration

setHost

public void setHost(java.lang.String host)

getPort

public int getPort()

Specified by:

getPort in interface Configuration

setPort

public void setPort(int port)

getLocation

public Location getLocation()

Specified by:

getLocation in interface Configuration

getServerID

public int getServerID()

Description copied from interface: Configuration

The server ID is used only when the messaging server is started in INVM transport.

Specified by:

getServerID in interface Configuration

setServerID

public void setServerID(int serverID)

getKeepAliveInterval

public long getKeepAliveInterval()

Specified by:

getKeepAliveInterval in interface Configuration

setKeepAliveInterval

public void setKeepAliveInterval(long keepAliveInterval)

getKeepAliveTimeout

public long getKeepAliveTimeout()

Specified by:

getKeepAliveTimeout in interface Configuration

setKeepAliveTimeout

public void setKeepAliveTimeout(long keepAliveTimeout)

getTimeout

public long getTimeout()

Specified by:

getTimeout in interface Configuration

getKeyStorePath

public java.lang.String getKeyStorePath()

Specified by:

getKeyStorePath in interface Configuration

setKeyStorePath

public void setKeyStorePath(java.lang.String keyStorePath)

getKeyStorePassword

public java.lang.String getKeyStorePassword()

Specified by:

getKeyStorePassword in interface Configuration

setKeyStorePassword

public void setKeyStorePassword(java.lang.String keyStorePassword)

getTrustStorePath

public java.lang.String getTrustStorePath()

Specified by:

getTrustStorePath in interface Configuration

setTrustStorePath

public void setTrustStorePath(java.lang.String trustStorePath)

getTrustStorePassword

public java.lang.String getTrustStorePassword()

Specified by:

getTrustStorePassword in interface Configuration

setTrustStorePassword

public void setTrustStorePassword(java.lang.String trustStorePassword)

isInvmDisabled

public boolean isInvmDisabled()

Specified by:

isInvmDisabled in interface Configuration

setInvmDisabled

public void setInvmDisabled(boolean invmDisabled)

setSecurityEnabled

public void setSecurityEnabled(boolean enabled)

isSSLEnabled

public boolean isSSLEnabled()

Specified by:

isSSLEnabled in interface Configuration

setSSLEnabled

public void setSSLEnabled(boolean sslEnabled)

isTcpNoDelay

public boolean isTcpNoDelay()

Specified by:

isTcpNoDelay in interface Configuration

setTcpNoDelay

public void setTcpNoDelay(boolean tcpNoDelay)

getTcpReceiveBufferSize

public int getTcpReceiveBufferSize()

Specified by:

getTcpReceiveBufferSize in interface Configuration

setTcpReceiveBufferSize

public void setTcpReceiveBufferSize(int size)

getTcpSendBufferSize

public int getTcpSendBufferSize()

Specified by:

getTcpSendBufferSize in interface Configuration

setTcpSendBufferSize

public void setTcpSendBufferSize(int size)

getWriteQueueBlockTimeout

public long getWriteQueueBlockTimeout()

Specified by:

getWriteQueueBlockTimeout in interface Configuration

getWriteQueueMaxBytes

public long getWriteQueueMaxBytes()

Specified by:

getWriteQueueMaxBytes in interface Configuration

getWriteQueueMinBytes

public long getWriteQueueMinBytes()

Specified by:

getWriteQueueMinBytes in interface Configuration

setWriteQueueBlockTimeout

public void setWriteQueueBlockTimeout(long timeout)

setWriteQueueMaxBytes

public void setWriteQueueMaxBytes(long bytes)

setWriteQueueMinBytes

public void setWriteQueueMinBytes(long bytes)

getURI

public java.lang.String getURI()

Specified by:

getURI in interface Configuration

getBindingsDirectory

public java.lang.String getBindingsDirectory()

Specified by:

getBindingsDirectory in interface Configuration

getJournalDirectory

public java.lang.String getJournalDirectory()

Specified by:

getJournalDirectory in interface Configuration

getJournalType

public JournalType getJournalType()

Specified by:

getJournalType in interface Configuration

setJournalType

public void setJournalType(JournalType type)

isJournalSyncTransactional

public boolean isJournalSyncTransactional()

Specified by:

isJournalSyncTransactional in interface Configuration

isJournalSyncNonTransactional

public boolean isJournalSyncNonTransactional()

Specified by:

isJournalSyncNonTransactional in interface Configuration

getJournalFileSize

public int getJournalFileSize()

Specified by:

getJournalFileSize in interface Configuration

getJournalMaxAIO

public int getJournalMaxAIO()

Specified by:

getJournalMaxAIO in interface Configuration

setJournalMaxAIO

public void setJournalMaxAIO(int max)

Specified by:

setJournalMaxAIO in interface Configuration

getJournalAIOTimeout

public long getJournalAIOTimeout()

Specified by:

getJournalAIOTimeout in interface Configuration

getJournalMinFiles

public int getJournalMinFiles()

Specified by:

getJournalMinFiles in interface Configuration

getJournalTaskPeriod

public long getJournalTaskPeriod()

Specified by:

getJournalTaskPeriod in interface Configuration

isCreateBindingsDir

public boolean isCreateBindingsDir()

Specified by:

isCreateBindingsDir in interface Configuration

isCreateJournalDir

public boolean isCreateJournalDir()

Specified by:

isCreateJournalDir in interface Configuration

isRequireDestinations

public boolean isRequireDestinations()

Specified by:

isRequireDestinations in interface Configuration

isSecurityEnabled

public boolean isSecurityEnabled()

Specified by:

isSecurityEnabled in interface Configuration

getConnectionParams

public ConnectionParams getConnectionParams()

Specified by:

getConnectionParams in interface Configuration