org.apache.qpid.client.transport
Class TransportConnection

java.lang.Object
  extended by org.apache.qpid.client.transport.TransportConnection

public class TransportConnection
extends Object

The TransportConnection is a helper class responsible for connecting to an AMQ server. It sets up the underlying connector, which currently always uses TCP/IP sockets. It creates the "protocol handler" which deals with MINA protocol events.

Could be extended in future to support different transport types by turning this into concrete class/interface combo.


Constructor Summary
TransportConnection()
           
 
Method Summary
static void createVMBroker(int port)
           
static ITransportConnection getInstance(BrokerDetails details)
           
static void killAllVMBrokers()
           
static void killVMBroker(int port)
           
static void registerOpenSocket(String socketID, Socket openSocket)
           
static Socket removeOpenSocket(String socketID)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

TransportConnection

public TransportConnection()
Method Detail

registerOpenSocket

public static void registerOpenSocket(String socketID,
                                      Socket openSocket)

removeOpenSocket

public static Socket removeOpenSocket(String socketID)

getInstance

public static ITransportConnection getInstance(BrokerDetails details)
                                        throws AMQTransportConnectionException
Throws:
AMQTransportConnectionException

createVMBroker

public static void createVMBroker(int port)
                           throws AMQVMBrokerCreationException
Throws:
AMQVMBrokerCreationException

killAllVMBrokers

public static void killAllVMBrokers()

killVMBroker

public static void killVMBroker(int port)


Licensed to the Apache Software Foundation