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

Class AmqpConnectionService

java.lang.Object

org.objectweb.joram.mom.dest.amqp.AmqpConnectionService

public class AmqpConnectionService
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static class	AmqpConnectionService.MyURLStreamHandler

Field Summary

Fields

Modifier and Type	Field	Description
private static boolean	DEBUG
private static Logger	logger
private static AmqpConnections	singleton

Constructor Summary

Constructors

Constructor	Description
AmqpConnectionService()

Method Summary

Modifier and Type	Method	Description
static void	addServer(String urls)	Adds an AMQP server and starts a live connection with it, accessible via the host and port provided.
static 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.
static 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.
static List<String>	convertToList(String value)
static void	deleteServer(String names)	Removes the live connection to the specified AMQP server.
static AmqpConnections	getInstance()
static String[]	getServerNames()	Gets the list of known servers.
static void	init(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

Field Detail

logger

private static final Logger logger

DEBUG

private static final boolean DEBUG

singleton

private static AmqpConnections singleton

Constructor Detail

AmqpConnectionService

public AmqpConnectionService()

Method Detail

getInstance

public static AmqpConnections getInstance()

addServer

public static 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.

Parameters:

name - the name identifying the server

host - host of the added server

port - port of the added server

addServer

public static 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.

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

addServer

public static void addServer(String urls)

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.

Parameters:

urls - the amqp url list identifying the servers separate by space. ex: amqp://user:pass@localhost:5672/?name=serv1 amqp://user:pass@localhost:5678/?name=serv2 serv1 and serv2 are the name identifying the server.

deleteServer

public static void deleteServer(String names)

Removes the live connection to the specified AMQP server.

Parameters:

names - the name identifying the server or list of name separate by space

getServerNames

public static String[] getServerNames()

Gets the list of known servers.

init

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

Initializes the service. Starts a connection with one server.

Throws:

Exception

stopService

public static void stopService()

Stops all connections to AMQP servers.

convertToList

public static List<String> convertToList(String value)