org.apache.qpid.transport.network.io
Class IoTransport<E>
java.lang.Object
org.apache.qpid.transport.network.io.IoTransport<E>
- All Implemented Interfaces:
- IoContext
public final class IoTransport<E>
- extends Object
- implements IoContext
This class provides a socket based transport using the java.io
classes.
The following params are configurable via JVM arguments
TCP_NO_DELAY - amqj.tcpNoDelay
SO_RCVBUF - amqj.receiveBufferSize
SO_SNDBUF - amqj.sendBufferSize
Method Summary |
static void |
connect_0_9(AMQVersionAwareProtocolSession session,
String host,
int port,
boolean ssl)
|
static
|
connect(String host,
int port,
Binding<E,ByteBuffer> binding,
boolean ssl)
|
static Connection |
connect(String host,
int port,
ConnectionDelegate delegate,
boolean ssl)
|
IoReceiver |
getReceiver()
|
Sender<ByteBuffer> |
getSender()
|
Socket |
getSocket()
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
IoTransport
IoTransport(Socket socket,
Binding<E,ByteBuffer> binding,
boolean ssl)
getSender
public Sender<ByteBuffer> getSender()
- Specified by:
getSender
in interface IoContext
getReceiver
public IoReceiver getReceiver()
- Specified by:
getReceiver
in interface IoContext
getSocket
public Socket getSocket()
- Specified by:
getSocket
in interface IoContext
connect
public static final <E> E connect(String host,
int port,
Binding<E,ByteBuffer> binding,
boolean ssl)
connect
public static final Connection connect(String host,
int port,
ConnectionDelegate delegate,
boolean ssl)
connect_0_9
public static void connect_0_9(AMQVersionAwareProtocolSession session,
String host,
int port,
boolean ssl)
Licensed to the Apache Software Foundation