com.communote.plugins.mq.provider.activemq.settings

Class MQDatabaseSettingsDAO

java.lang.Object

com.communote.plugins.mq.provider.activemq.settings.MQDatabaseSettingsDAO

All Implemented Interfaces:

MQSettingsDAO

public class MQDatabaseSettingsDAO
extends Object
implements MQSettingsDAO

MQ Settings to get and change the settings of the Active MQ Broker. All settings are application specific.

Author:

Communote GmbH - http://www.communote.com/

Constructor Summary

Constructors

Constructor and Description
MQDatabaseSettingsDAO()

Method Summary

Modifier and Type	Method and Description
Set<String>	getBrokerConnectorURLs() Use this this method to list all urls that the broker should be started on, hence the vm url will not be included, since it will be available always.
Set<String>	getBrokerConnectorURLsWithVM() Use this method to list all urls that can be used to connect to the broker
String	getBrokerName()
String	getDataDirectory()
String	getJmxDomainName()
int	getJmxPort()
String	getQueueName()
String	getReplyQueueNamePrefix()
String	getSSLPort()
String	getTcpPort()
String	getUrlHostname()
String	getVMConnectorURL()
boolean	isBrokerStarted()
boolean	isEnableSSL()
boolean	isEnableTCP()
boolean	isEnableVM() This flag is only relevant for the adapter connecting to the broker, since the VM connection is always available once the broker is started.
boolean	isForceSSL()
boolean	isForceSSLClientAuthentication()
boolean	isJmxMonitoringEnabled()
boolean	isJmxRemoteEnabled()
void	setBrokerStarted(boolean isStarted) sets broker's state flag
void	setDataDirectory(String dataDirectoryPath) sets data directory path
void	setEnableJmxRemote(boolean enableJmx)
void	setEnableSSL(boolean enableSSL)
void	setEnableTCP(boolean enableTCP)
void	setEnableVM(boolean enableVM) VM = virtual machine connector
void	setForceSSL(boolean forceSSL)
void	setForceSSLClientAuthentication(boolean needClientAuth)

Methods inherited from class java.lang.Object

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

Constructor Detail

MQDatabaseSettingsDAO

public MQDatabaseSettingsDAO()

Method Detail

getBrokerConnectorURLs

public Set<String> getBrokerConnectorURLs()

Description copied from interface: MQSettingsDAO

Use this this method to list all urls that the broker should be started on, hence the vm url will not be included, since it will be available always.

Specified by:

getBrokerConnectorURLs in interface MQSettingsDAO

Returns:

broker connector urls

getBrokerConnectorURLsWithVM

public Set<String> getBrokerConnectorURLsWithVM()

Description copied from interface: MQSettingsDAO

Use this method to list all urls that can be used to connect to the broker

Specified by:

getBrokerConnectorURLsWithVM in interface MQSettingsDAO

Returns:

broker connector urls including the VM url (if MQSettingsDAO.isEnableVM() is true)

getBrokerName

public String getBrokerName()

Specified by:

getBrokerName in interface MQSettingsDAO

Returns:

broker name

getDataDirectory

public String getDataDirectory()

Specified by:

getDataDirectory in interface MQSettingsDAO

Returns:

data directory path

getJmxDomainName

public String getJmxDomainName()

Specified by:

getJmxDomainName in interface MQSettingsDAO

Returns:

the JMX domain name for the MQ broker

getJmxPort

public int getJmxPort()

Specified by:

getJmxPort in interface MQSettingsDAO

Returns:

the port to be used for jmx connection

getQueueName

public String getQueueName()

Specified by:

getQueueName in interface MQSettingsDAO

Returns:

the name of the communote message queue

getReplyQueueNamePrefix

public String getReplyQueueNamePrefix()

Specified by:

getReplyQueueNamePrefix in interface MQSettingsDAO

Returns:

the name of queue to reply messages to

getSSLPort

public String getSSLPort()

Specified by:

getSSLPort in interface MQSettingsDAO

Returns:

the ssl port to use

getTcpPort

public String getTcpPort()

Specified by:

getTcpPort in interface MQSettingsDAO

Returns:

the tcp port to use

getUrlHostname

public String getUrlHostname()

Specified by:

getUrlHostname in interface MQSettingsDAO

Returns:

the hostname of the url to use

getVMConnectorURL

public String getVMConnectorURL()

Specified by:

getVMConnectorURL in interface MQSettingsDAO

Returns:

the vm url for clients to connect to

isBrokerStarted

public boolean isBrokerStarted()

Specified by:

isBrokerStarted in interface MQSettingsDAO

Returns:

broker's state

isEnableSSL

public boolean isEnableSSL()

Specified by:

isEnableSSL in interface MQSettingsDAO

Returns:

true if SSL is enabled. default ist false

isEnableTCP

public boolean isEnableTCP()

Specified by:

isEnableTCP in interface MQSettingsDAO

Returns:

true to enable tcp connector. default ist false.

isEnableVM

public boolean isEnableVM()

Description copied from interface: MQSettingsDAO

This flag is only relevant for the adapter connecting to the broker, since the VM connection is always available once the broker is started. It can be used to tell the adaper, not to use the vm and connect to another host.

Specified by:

isEnableVM in interface MQSettingsDAO

Returns:

true to enable vm connection. default ist true.

isForceSSL

public boolean isForceSSL()

Specified by:

isForceSSL in interface MQSettingsDAO

Returns:

the forceSSL. default ist false.

isForceSSLClientAuthentication

public boolean isForceSSLClientAuthentication()

Specified by:

isForceSSLClientAuthentication in interface MQSettingsDAO

Returns:

true if a client certificate is required (if it is a SSL connection, will be ignored for non SSL connections)

isJmxMonitoringEnabled

public boolean isJmxMonitoringEnabled()

Specified by:

isJmxMonitoringEnabled in interface MQSettingsDAO

Returns:

true to enable the jmx monitoring

isJmxRemoteEnabled

public boolean isJmxRemoteEnabled()

Specified by:

isJmxRemoteEnabled in interface MQSettingsDAO

Returns:

true if jmx is enabled for remote connections and should be started on the MQSettingsDAO.getJmxPort() port

setBrokerStarted

public void setBrokerStarted(boolean isStarted)
                      throws AuthorizationException

Description copied from interface: MQSettingsDAO

sets broker's state flag

Specified by:

setBrokerStarted in interface MQSettingsDAO

Parameters:

isStarted - the flag value

Throws:

AuthorizationException

setDataDirectory

public void setDataDirectory(String dataDirectoryPath)
                      throws AuthorizationException

Description copied from interface: MQSettingsDAO

sets data directory path

Specified by:

setDataDirectory in interface MQSettingsDAO

Parameters:

dataDirectoryPath - path to set

Throws:

AuthorizationException

setEnableJmxRemote

public void setEnableJmxRemote(boolean enableJmx)
                        throws AuthorizationException

Specified by:

setEnableJmxRemote in interface MQSettingsDAO

Parameters:

enableJmx - the enableJmx to set

Throws:

AuthorizationException

setEnableSSL

public void setEnableSSL(boolean enableSSL)
                  throws AuthorizationException

Specified by:

setEnableSSL in interface MQSettingsDAO

Parameters:

enableSSL - true to enable the ssl connector

Throws:

AuthorizationException

setEnableTCP

public void setEnableTCP(boolean enableTCP)
                  throws AuthorizationException

Specified by:

setEnableTCP in interface MQSettingsDAO

Parameters:

enableTCP - true to enable tcp

Throws:

AuthorizationException

setEnableVM

public void setEnableVM(boolean enableVM)
                 throws AuthorizationException

Description copied from interface: MQSettingsDAO

VM = virtual machine connector

Specified by:

setEnableVM in interface MQSettingsDAO

Parameters:

enableVM - true to enable vm (which actually only relevant for the embedded adapter)

Throws:

AuthorizationException

setForceSSL

public void setForceSSL(boolean forceSSL)
                 throws AuthorizationException

Specified by:

setForceSSL in interface MQSettingsDAO

Parameters:

forceSSL - the forceSSL to set

Throws:

AuthorizationException

setForceSSLClientAuthentication

public void setForceSSLClientAuthentication(boolean needClientAuth)
                                     throws AuthorizationException

Specified by:

setForceSSLClientAuthentication in interface MQSettingsDAO

Parameters:

needClientAuth - true if a client auth by certificate is expected on connecting to the broker

Throws:

AuthorizationException