org.apache.qpid.transport.network.io
Class IoTransport<E>

java.lang.Object
  extended by 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


Constructor Summary
IoTransport(Socket socket, Binding<E,ByteBuffer> binding, boolean ssl)
           
 
Method Summary
static void connect_0_9(AMQVersionAwareProtocolSession session, String host, int port, boolean ssl)
           
static
<E> E
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
 

Constructor Detail

IoTransport

IoTransport(Socket socket,
            Binding<E,ByteBuffer> binding,
            boolean ssl)
Method Detail

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