Package org.ow2.joram.tools.jmscheck

Class JMSConnectorStatus

java.lang.Object

org.ow2.joram.tools.jmscheck.JMSConnectorStatus

All Implemented Interfaces:

JMSConnectorStatusMBean

final class JMSConnectorStatus
extends Object
implements JMSConnectorStatusMBean

Field Summary

Fields

Modifier and Type	Field	Description
(package private) ScheduledFuture<?>	callableHandle
private JMSConnectorCheck	check
(package private) JMSStatus	jmsStatus	Root component
private static Logger	logger
private String	mbeanName
private int	period	The period of time between 2 checks (in seconds).

Constructor Summary

Constructors

Constructor	Description
JMSConnectorStatus(JMSStatus jmsStatus, String cfname, InitialContext ictx, String user, String pass, String qname, int period, int timeOut)	Creates a JMS connectors healthcheck component.

Method Summary

Modifier and Type	Method	Description
String	getErrorMsg()	Returns the error message of the last try.
String	getLastConnectTime()	Returns the date of last successful connection.
long	getLatencyConnect()	Returns the latency of the connection during the last try.
long	getLatencyPubSub()	Returns the latency of the send/receive during the last try.
String	getName()
int	getNbFailures()	Returns the total number of failures since starting.
int	getNbTry()	Returns the total number of try since starting.
int	getPeriod()	Returns the period of time between 2 checks.
int	getStatus()	Returns the status of the connector: 0 => RUNNING, >0 => UNREACHABLE.
String	getStatusInfo()
int	getTimeOut()	Returns the maximum time waiting for connection.
private void	registerMBean()
private void	schedule()
void	setPeriod(int period)	Sets the period of time between 2 checks.
void	setTimeOut(int timeOut)	Sets the maximum time waiting for connection.
(package private) void	start()
(package private) void	stop()
private void	unregisterMBean()

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

check

private JMSConnectorCheck check

period

private int period

The period of time between 2 checks (in seconds).

jmsStatus

JMSStatus jmsStatus

Root component

callableHandle

ScheduledFuture<?> callableHandle

mbeanName

private String mbeanName

Constructor Detail

JMSConnectorStatus

JMSConnectorStatus(JMSStatus jmsStatus,
                   String cfname,
                   InitialContext ictx,
                   String user,
                   String pass,
                   String qname,
                   int period,
                   int timeOut)

Creates a JMS connectors healthcheck component.

Parameters:

jmsStatus - Root component.

cfname - JNDI name of the ConnectionFactory to use.

ictx - JNDI context allowing to get the ConnectionFactory.

user - User name for authentication, if null uses the ConnectioNfactory default.

pass - Password for authentication, if null uses the ConnectioNfactory default.

qname - Name of the queue used to check the JMS behavior. It is an internal not a JNDI name, this destination is created by the module.

period - Period (in seconds) between 2 attempts of check.

timeOut - Maximum amount of time to wait either the connection or the message.

Method Detail

getStatus

public int getStatus()

Description copied from interface: JMSConnectorStatusMBean

Returns the status of the connector: 0 => RUNNING, >0 => UNREACHABLE.

Specified by:

getStatus in interface JMSConnectorStatusMBean

Returns:

the number of unreachable connection

getStatusInfo

public String getStatusInfo()

Specified by:

getStatusInfo in interface JMSConnectorStatusMBean

getNbTry

public int getNbTry()

Description copied from interface: JMSConnectorStatusMBean

Returns the total number of try since starting.

Specified by:

getNbTry in interface JMSConnectorStatusMBean

Returns:

the total number of try since starting.

getNbFailures

public int getNbFailures()

Description copied from interface: JMSConnectorStatusMBean

Returns the total number of failures since starting.

Specified by:

getNbFailures in interface JMSConnectorStatusMBean

Returns:

the total number of failures since starting.

getErrorMsg

public String getErrorMsg()

Description copied from interface: JMSConnectorStatusMBean

Returns the error message of the last try. Returns null if the test is successful.

Specified by:

getErrorMsg in interface JMSConnectorStatusMBean

Returns:

getLatencyConnect

public long getLatencyConnect()

Description copied from interface: JMSConnectorStatusMBean

Returns the latency of the connection during the last try. Returns -1 if the test failed.

Specified by:

getLatencyConnect in interface JMSConnectorStatusMBean

Returns:

the latency of the connection during the last try.

getLastConnectTime

public String getLastConnectTime()

Description copied from interface: JMSConnectorStatusMBean

Returns the date of last successful connection.

Specified by:

getLastConnectTime in interface JMSConnectorStatusMBean

Returns:

the date of last successful connection.

getLatencyPubSub

public long getLatencyPubSub()

Description copied from interface: JMSConnectorStatusMBean

Returns the latency of the send/receive during the last try. Returns -1 if the test failed.

Specified by:

getLatencyPubSub in interface JMSConnectorStatusMBean

Returns:

the latency of the send/receive during the last try.

getPeriod

public int getPeriod()

Description copied from interface: JMSConnectorStatusMBean

Returns the period of time between 2 checks.

Specified by:

getPeriod in interface JMSConnectorStatusMBean

Returns:

the period of time between 2 checks.

setPeriod

public void setPeriod(int period)

Description copied from interface: JMSConnectorStatusMBean

Sets the period of time between 2 checks.

Specified by:

setPeriod in interface JMSConnectorStatusMBean

Parameters:

period - the period of time between 2 checks.

getTimeOut

public int getTimeOut()

Description copied from interface: JMSConnectorStatusMBean

Returns the maximum time waiting for connection.

Specified by:

getTimeOut in interface JMSConnectorStatusMBean

Returns:

the maximum time waiting for connection.

setTimeOut

public void setTimeOut(int timeOut)

Description copied from interface: JMSConnectorStatusMBean

Sets the maximum time waiting for connection.

Specified by:

setTimeOut in interface JMSConnectorStatusMBean

Parameters:

timeOut - the maximum time waiting for connection.

getName

public String getName()

Specified by:

getName in interface JMSConnectorStatusMBean

schedule

private void schedule()

start

void start()

stop

void stop()

registerMBean

private void registerMBean()

unregisterMBean

private void unregisterMBean()