org.objectweb.joram.mom.dest.amqp
Interface AmqpConnectionHandlerMBean

All Known Implementing Classes:
AmqpConnectionHandler

public interface AmqpConnectionHandlerMBean


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.
 

Method Detail

addServer

void addServer(com.rabbitmq.client.ConnectionFactory factory)
Adds an AMQP server and starts a live connection with it, accessible via the ConnectionFactory provided. A server is uniquely identified with its host and port. Adding an existing server won't do anything.

Parameters:
factory - the factory used to access the server, configured properly (host, port, login, password...)

addServer

void addServer(java.lang.String host,
               int port)
Adds an AMQP server and starts a live connection with it, accessible via the ConnectionFactory provided. A server is uniquely identified with its host and port. Adding an existing server won't do anything.

Parameters:
host - host of the added server
port - port of the added server

addServer

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. A server is uniquely identified with its host and port. Adding an existing server won't do anything.

Parameters:
host - host of the added server
port - port of the added server
user - user name
pass - user password

deleteServer

void deleteServer(java.lang.String host,
                  int port)
Removes the live connection to the specified AMQP server.

Parameters:
host - host of the removed server
port - port of the removed server


Copyright © 2011 ScalAgent D.T.. All Rights Reserved.