Package org.objectweb.joram.mom.dest.amqp

Class LiveServerConnection

java.lang.Object

org.objectweb.joram.mom.dest.amqp.LiveServerConnection

All Implemented Interfaces:

com.rabbitmq.client.ShutdownListener, Serializable, EventListener, LiveServerConnectionMBean

public class LiveServerConnection
extends Object
implements LiveServerConnectionMBean, com.rabbitmq.client.ShutdownListener, Serializable

A LiveServerConnection keeps alive a connection to an AMQP server. When the connection fails, a reconnection routine starts.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private class	LiveServerConnection.ReconnectionDaemon	The ReconnectionDaemon thread is responsible for reconnecting the module with the foreign AMQP server in case of disconnection.

Field Summary

Fields

Modifier and Type	Field	Description
private LiveServerConnection.ReconnectionDaemon	cnxDaemon
private com.rabbitmq.client.ConnectionFactory	cnxFactory
private com.rabbitmq.client.Connection	conn
private static boolean	DEBUG
private String	host
private static Logger	logger
private String	name
private String	password
private int	port
private static long	serialVersionUID	define serialVersionUID for interoperability
private String	user

Constructor Summary

Constructors

Constructor	Description
LiveServerConnection()	Starts a connection with a default AMQP server.
LiveServerConnection(String name, String host, int port, String user, String password)	Starts a connection with a server accessible via the factory provided.

Method Summary

Modifier and Type	Method	Description
com.rabbitmq.client.Connection	getConnection()
com.rabbitmq.client.ConnectionFactory	getConnectionFactory()
String	getHost()
private String	getMBeanName()
String	getName()
int	getPort()
String	getState()
String	getUserName()
boolean	isConnectionOpen()
void	shutdownCompleted(com.rabbitmq.client.ShutdownSignalException cause)
void	startLiveConnection()
void	stopLiveConnection()	Stops maintaining the connection alive with the server.

Methods inherited from class java.lang.Object

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

Field Detail

serialVersionUID

private static final long serialVersionUID

define serialVersionUID for interoperability

See Also:

Constant Field Values

logger

private static final Logger logger

DEBUG

private static final boolean DEBUG

cnxFactory

private transient com.rabbitmq.client.ConnectionFactory cnxFactory

cnxDaemon

private transient LiveServerConnection.ReconnectionDaemon cnxDaemon

conn

private transient volatile com.rabbitmq.client.Connection conn

name

private String name

host

private String host

port

private int port

user

private String user

password

private String password

Constructor Detail

LiveServerConnection

public LiveServerConnection()

Starts a connection with a default AMQP server.

LiveServerConnection

public LiveServerConnection(String name,
                            String host,
                            int port,
                            String user,
                            String password)

Starts a connection with a server accessible via the factory provided.

Parameters:

factory - the factory used to access the server.

Method Detail

startLiveConnection

public void startLiveConnection()

isConnectionOpen

public boolean isConnectionOpen()

getConnection

public com.rabbitmq.client.Connection getConnection()

getConnectionFactory

public com.rabbitmq.client.ConnectionFactory getConnectionFactory()

getMBeanName

private String getMBeanName()

stopLiveConnection

public void stopLiveConnection()

Stops maintaining the connection alive with the server.

shutdownCompleted

public void shutdownCompleted(com.rabbitmq.client.ShutdownSignalException cause)

Specified by:

shutdownCompleted in interface com.rabbitmq.client.ShutdownListener

getHost

public String getHost()

Specified by:

getHost in interface LiveServerConnectionMBean

getPort

public int getPort()

Specified by:

getPort in interface LiveServerConnectionMBean

getName

public String getName()

getUserName

public String getUserName()

Specified by:

getUserName in interface LiveServerConnectionMBean

getState

public String getState()

Specified by:

getState in interface LiveServerConnectionMBean