|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.objectweb.joram.mom.dest.amqp.AmqpConnectionHandler
public class AmqpConnectionHandler
The AmqpConnectionHandler
service handles the list of known AMQP
servers, in order to keep live connections with them.
Method Summary | |
---|---|
void |
addServer(com.rabbitmq.client.ConnectionFactory factory)
Adds an AMQP server and starts a live connection with it, accessible via the ConnectionFactory provided. |
void |
addServer(java.lang.String host,
int port)
Adds an AMQP server and starts a live connection with it, accessible via the ConnectionFactory provided. |
void |
addServer(java.lang.String host,
int port,
java.lang.String user,
java.lang.String pass)
Adds an AMQP server and starts a live connection with it, accessible via the ConnectionFactory provided. |
void |
deleteServer(java.lang.String host,
int port)
Removes the live connection to the specified AMQP server. |
static java.util.List<com.rabbitmq.client.Connection> |
getConnections()
Gets the list of currently opened connections. |
static AmqpConnectionHandler |
getInstance()
|
static void |
init(java.lang.String args,
boolean firstTime)
Initializes the service. |
static void |
stopService()
Stops all connections to AMQP servers. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Method Detail |
---|
public static AmqpConnectionHandler getInstance()
public static void init(java.lang.String args, boolean firstTime) throws java.lang.Exception
java.lang.Exception
public void addServer(com.rabbitmq.client.ConnectionFactory factory)
ConnectionFactory
provided. A server is uniquely identified
with its host and port. Adding an existing server won't do anything.
addServer
in interface AmqpConnectionHandlerMBean
factory
- the factory used to access the server, configured properly
(host, port, login, password...)public void addServer(java.lang.String host, int port)
ConnectionFactory
provided. A server is uniquely identified
with its host and port. Adding an existing server won't do anything.
addServer
in interface AmqpConnectionHandlerMBean
host
- host of the added serverport
- port of the added serverpublic void addServer(java.lang.String host, int port, java.lang.String user, java.lang.String pass)
ConnectionFactory
provided. A server is uniquely identified
with its host and port. Adding an existing server won't do anything.
addServer
in interface AmqpConnectionHandlerMBean
host
- host of the added serverport
- port of the added serveruser
- user namepass
- user passwordpublic void deleteServer(java.lang.String host, int port)
deleteServer
in interface AmqpConnectionHandlerMBean
host
- host of the removed serverport
- port of the removed serverpublic static void stopService()
public static java.util.List<com.rabbitmq.client.Connection> getConnections()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |