[CONF] Apache Qpid > Create interface in common

[confluence]

Create interface in common Page edited by Aidan Skinner passes and receives QpidByteBuffer to/from the network driver which is responsible for writing / reading into those buffers outgoing and incoming buffers are held by the IO layer, not the underlying network driver (eg. MINA, o.a.q.transport.network.io) the protocol driver takes data in a QpidByteBuffer the protocol driver writes data as a QpidByteBuffer protocol driver should be non-blocking network interface and drivers should be thread model agnostic. At a minimum capable of using both single thread and thread pool an SSLConfiguration object of some description will be passed down to the network driver which will use it to configure eg. the certificate store idle timers, buffer sizing and similar common functionality are shared at the level immediately above the network driver public interface ProtocolDriver { public void bytesRecieved(QpidByteBuffer bytes); public void setNetworkDriver(NetworkDriver driver); public boolean supportsProtocol(QpidByteBuffer bytes); } public interface NetworkDriver { void open(InetAddress destination); void close(); // Use the preconfigured SSLEngine void setSSLEngine(SSLEngine engine); // Taken from Socket void setKeepAlive(boolean on) void setOOBInline(boolean on) void setReceiveBufferSize(int size) void setReuseAddress(boolean on) void setSendBufferSize(int size) void setSoLinger(boolean on, int linger) void setSoTimeout(int timeout) void setTcpNoDelay(boolean on) void setTrafficClass(int tc) // Set the buffer to write too void setOutputBuffer(QpidByteBuffer buffer); // Set the buffer to read from void setInputBuffer(QpidByteBuffer buffer); } Change Notification Preferences View Online | View Change | Add Comment --------------------------------------------------------------------- Apache Qpid - AMQP Messaging Implementation Project: http://qpid.apache.org Use/Interact: mailto:commits-subscr...@qpid.apache.org