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

Class AmqpConnections

java.lang.Object

org.objectweb.joram.mom.dest.amqp.AmqpConnections

All Implemented Interfaces:

AmqpConnectionsMBean

public class AmqpConnections
extends Object
implements AmqpConnectionsMBean

The AmqpConnections service handles the list of known AMQP servers, in order to keep live connections with them.

Field Summary

Fields

Modifier and Type	Field	Description
private static Logger	logger
(package private) static String	SAVE_FILE_NAME
private Map<String,LiveServerConnection>	servers

Constructor Summary

Constructors

Constructor	Description
AmqpConnections()

Method Summary

Modifier and Type	Method	Description
void	addServer(String name, String host, int port)	Adds an AMQP server and starts a live connection with it, accessible via the host and port provided.
void	addServer(String name, String host, int port, String user, String pass)	Adds an AMQP server and starts a live connection with it, accessible via the host and port provided.
void	deleteServer(String name)	Removes the live connection to the specified AMQP server.
List<LiveServerConnection>	getConnections()	Gets the list of currently opened connections.
String[]	getServerNames()	Gets the list of known servers.
(package private) void	readSavedConf()
void	stop()

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

SAVE_FILE_NAME

static final String SAVE_FILE_NAME

See Also:

Constant Field Values

servers

private Map<String,LiveServerConnection> servers

Constructor Detail

AmqpConnections

AmqpConnections()

Method Detail

readSavedConf

void readSavedConf()

addServer

public void addServer(String name,
                      String host,
                      int port)

Adds an AMQP server and starts a live connection with it, accessible via the host and port provided. A server is uniquely identified by the given name. Adding an existing server won't do anything.

Specified by:

addServer in interface AmqpConnectionsMBean

Parameters:

name - the name identifying the server

host - host of the added server

port - port of the added server

addServer

public void addServer(String name,
                      String host,
                      int port,
                      String user,
                      String pass)

Adds an AMQP server and starts a live connection with it, accessible via the host and port provided. A server is uniquely identified by the given name. Adding an existing server won't do anything.

Specified by:

addServer in interface AmqpConnectionsMBean

Parameters:

name - the name identifying the server

host - host of the added server

port - port of the added server

user - user name

pass - user password

deleteServer

public void deleteServer(String name)

Removes the live connection to the specified AMQP server.

Specified by:

deleteServer in interface AmqpConnectionsMBean

Parameters:

name - the name identifying the server

getServerNames

public String[] getServerNames()

Gets the list of known servers.

Specified by:

getServerNames in interface AmqpConnectionsMBean

getConnections

public List<LiveServerConnection> getConnections()

Gets the list of currently opened connections.

Returns:

the list of usable connections.

stop

public void stop()