Package org.objectweb.joram.mom.proxies

Class ConnectionManager

java.lang.Object

org.objectweb.joram.mom.proxies.ConnectionManager

All Implemented Interfaces:

ConnectionManagerMBean

public class ConnectionManager
extends Object
implements ConnectionManagerMBean

A ConnectionManager is started as a service in each MOM agent server for allowing connections with external clients.

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	activated	true if new connections are accepted.
static String	CTRLFLOW_THRESHOLD	Name of property allowing to define the threshold beyond which the flow-control of incoming messages is activated.
static String	CTRLFLOW_THROUGHPUT	Name of property allowing to define the average throughput of the server for the calculation of flow control.
private static long	ctrlFlowDelay	Definition of average delay for the implementation of flow control (it is computed from the CTRLFLOW_THROUGHPUT parameter.
private static int	ctrlFlowThreshold	Threshold beyond which the flow-control of incoming messages is activated.
private static ConnectionManager	currentInstance	Unique ConnectionManager instance.
private static boolean	DEBUG
static String	DIRECT_NOTIFICATION
private static boolean	directNotification
static int	inFlow	Limit of incoming messages flow (msgs/s) requested if any, default value is -1 (no limitation).
private static Logger	logger	logger
private List<ConnectionManagerMBean>	managers	List of registered managers (tcp, ssl, local, ...)
private static String	MBEAN_NAME
static String	MULTI_CNX_SYNC	Name of property allowing to activate the synchronization mode of multiples connections.
static String	MULTI_CNX_SYNC_DELAY	Name of property allowing to configure the synchronization mode of multiples connections.
private static boolean	multiCnxSync	True if the synchronization mode is activated.
private static Hashtable<AgentId,MultiCnxSync>	multiCnxSyncTable
private static long	multiThreadSyncDelay	Duration in ms of instant to pack the commands.
static String	version

Constructor Summary

Constructors

Constructor	Description
ConnectionManager()

Method Summary

Modifier and Type	Method	Description
void	activate()	Activates the connection manager.
void	addManager(ConnectionManagerMBean manager)	Registers a new manager.
boolean	checkCredentials(String userName, String password)	Checks the validity of the given name and password.
void	closeAllConnections()	Closes all opened connections.
private static CountDownCallback	createCallback(AbstractJmsRequest req, ConnectionContext ctx)
private static Identity	createIdentity(String adminName, String adminPassword, String identityClassName)	Create an admin Identity.
void	deactivate()	Deactivates the connection manager.
private static void	flowControl()
static ConnectionManager	getCurrentInstance()
int	getFailedLoginCount()	Gets the number of connections rejected due to a failed authentication.
int	getInitiatedConnectionCount()	Gets the number of initiated connections since server start.
String	getMBeanName()	Gets the name of the MBean.
static MultiCnxSync	getMultiCnxSync(AgentId proxyId)
static long	getMultiThreadSyncDelay()
int	getRunningConnectionsCount()	Gets the number of living connections.
String	getVersion()	Gets the name of the MBean.
static void	init(String args, boolean firstTime)	Initializes the connection manager as a service.
boolean	isActivated()	Tells if the ConnectionManager is active.
static void	registerFactories()
private void	removeAllManagers()
void	removeManager(ConnectionManagerMBean manager)	Removes a registered manager.
static void	sendToProxy(AgentId proxyId, int cnxKey, AbstractJmsRequest req, Object msg, ConnectionContext ctx)
static void	setActivate(boolean activate)	Activates/deactivates the connection manager.
static void	stopService()	Stops the ConnectionManager service.

Methods inherited from class java.lang.Object

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

Field Detail

logger

private static final Logger logger

logger

DEBUG

private static final boolean DEBUG

MULTI_CNX_SYNC

public static final String MULTI_CNX_SYNC

Name of property allowing to activate the synchronization mode of multiples connections.

This mode allows to pack commands that occurs in a same time in order to minimize the number of transactions.

This property can be fixed either from java launching command or a3servers.xml configuration file.

See Also:

Constant Field Values

multiCnxSync

private static boolean multiCnxSync

True if the synchronization mode is activated.

MULTI_CNX_SYNC_DELAY

public static final String MULTI_CNX_SYNC_DELAY

Name of property allowing to configure the synchronization mode of multiples connections.

This property allows to define the duration of instant to pack the commands.

This property can be fixed either from java launching command or a3servers.xml configuration file.

See Also:

Constant Field Values

multiThreadSyncDelay

private static long multiThreadSyncDelay

Duration in ms of instant to pack the commands.

CTRLFLOW_THRESHOLD

public static final String CTRLFLOW_THRESHOLD

Name of property allowing to define the threshold beyond which the flow-control of incoming messages is activated. Default value is 25.

This property can be fixed either from java launching command or a3servers.xml configuration file.

See Also:

Constant Field Values

ctrlFlowThreshold

private static int ctrlFlowThreshold

Threshold beyond which the flow-control of incoming messages is activated.

CTRLFLOW_THROUGHPUT

public static final String CTRLFLOW_THROUGHPUT

Name of property allowing to define the average throughput of the server for the calculation of flow control. Default value is 100000.

This property can be fixed either from java launching command or a3servers.xml configuration file.

See Also:

Constant Field Values

ctrlFlowDelay

private static long ctrlFlowDelay

Definition of average delay for the implementation of flow control (it is computed from the CTRLFLOW_THROUGHPUT parameter.

DIRECT_NOTIFICATION

public static final String DIRECT_NOTIFICATION

See Also:

Constant Field Values

directNotification

private static boolean directNotification

MBEAN_NAME

private static final String MBEAN_NAME

See Also:

Constant Field Values

activated

private boolean activated

true if new connections are accepted.

managers

private List<ConnectionManagerMBean> managers

List of registered managers (tcp, ssl, local, ...)

currentInstance

private static ConnectionManager currentInstance

Unique ConnectionManager instance.

multiCnxSyncTable

private static Hashtable<AgentId,MultiCnxSync> multiCnxSyncTable

inFlow

public static final int inFlow

Limit of incoming messages flow (msgs/s) requested if any, default value is -1 (no limitation). This value can be adjusted by setting ConnectionManager.inFlow property. This property can be fixed either from java launching command, or in a3servers.xml configuration file.

version

public static final String version

Constructor Detail

ConnectionManager

public ConnectionManager()

Method Detail

registerFactories

public static final void registerFactories()

createCallback

private static CountDownCallback createCallback(AbstractJmsRequest req,
                                                ConnectionContext ctx)

flowControl

private static void flowControl()

sendToProxy

public static final void sendToProxy(AgentId proxyId,
                                     int cnxKey,
                                     AbstractJmsRequest req,
                                     Object msg,
                                     ConnectionContext ctx)

getMultiThreadSyncDelay

public static final long getMultiThreadSyncDelay()

getMultiCnxSync

public static MultiCnxSync getMultiCnxSync(AgentId proxyId)

getVersion

public String getVersion()

Description copied from interface: ConnectionManagerMBean

Gets the name of the MBean.

Specified by:

getVersion in interface ConnectionManagerMBean

init

public static void init(String args,
                        boolean firstTime)
                 throws Exception

Initializes the connection manager as a service. Creates and deploys the administration topic, the connection manager agent and if requested the administration user proxy.

Parameters:

args - name and password of the administrator (optional).

firstTime - true when the agent server starts.

Throws:

Exception - Thrown when processing the String argument or in case of a problem when deploying the ConnectionFactory.

createIdentity

private static Identity createIdentity(String adminName,
                                       String adminPassword,
                                       String identityClassName)
                                throws Exception

Create an admin Identity.

Parameters:

adminName - Name of the admin.

adminPassword - Password of the admin.

identityClassName - identity class name.

Returns:

identity admin Identity.

Throws:

Exception

stopService

public static void stopService()

Stops the ConnectionManager service.

activate

public void activate()

Description copied from interface: ConnectionManagerMBean

Activates the connection manager. Creation of new connections will be allowed.

Specified by:

activate in interface ConnectionManagerMBean

closeAllConnections

public void closeAllConnections()

Description copied from interface: ConnectionManagerMBean

Closes all opened connections.

Specified by:

closeAllConnections in interface ConnectionManagerMBean

deactivate

public void deactivate()

Description copied from interface: ConnectionManagerMBean

Deactivates the connection manager. No new connection will be opened.

Specified by:

deactivate in interface ConnectionManagerMBean

getRunningConnectionsCount

public int getRunningConnectionsCount()

Description copied from interface: ConnectionManagerMBean

Gets the number of living connections.

Specified by:

getRunningConnectionsCount in interface ConnectionManagerMBean

Returns:

the number of living connections.

isActivated

public boolean isActivated()

Description copied from interface: ConnectionManagerMBean

Tells if the ConnectionManager is active.

Specified by:

isActivated in interface ConnectionManagerMBean

Returns:

ConnectionManager's active state.

getCurrentInstance

public static ConnectionManager getCurrentInstance()

addManager

public void addManager(ConnectionManagerMBean manager)

Registers a new manager.

removeManager

public void removeManager(ConnectionManagerMBean manager)

Removes a registered manager.

removeAllManagers

private void removeAllManagers()

getMBeanName

public String getMBeanName()

Description copied from interface: ConnectionManagerMBean

Gets the name of the MBean.

Specified by:

getMBeanName in interface ConnectionManagerMBean

getFailedLoginCount

public int getFailedLoginCount()

Description copied from interface: ConnectionManagerMBean

Gets the number of connections rejected due to a failed authentication.

Specified by:

getFailedLoginCount in interface ConnectionManagerMBean

Returns:

the number of connections rejected due to a failed authentication.

getInitiatedConnectionCount

public int getInitiatedConnectionCount()

Description copied from interface: ConnectionManagerMBean

Gets the number of initiated connections since server start.

Specified by:

getInitiatedConnectionCount in interface ConnectionManagerMBean

Returns:

the number of initiated connection.

checkCredentials

public boolean checkCredentials(String userName,
                                String password)

Checks the validity of the given name and password.

Parameters:

userName - the name of the user

password - the password of the user

Returns:

true if the name and password match an existing user.

setActivate

public static void setActivate(boolean activate)

Activates/deactivates the connection manager.

Parameters:

activate - true, activates the connection manager.