org.apache.qpid.client.transport
Class TransportConnection
java.lang.Object
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.
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
TransportConnection
public TransportConnection()
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