[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 Writes from the protocol driver will go to an intermediary Connection (need to find a better term for this) object which will place it on the outgoing buffer. Reads from the network driver should be placed on the incoming buffer. public interface ProtocolDriver { void bytesRecieved(QpidByteBuffer bytes); boolean supportsProtocol(QpidByteBuffer bytes); void setConnection(Connection con); // Called when the connection has been idle void idle(); } public interface Connection { void setProtocolDrivers(ProtocolDriver[] drivers) void setIncomingConnection(NetworkDriver driver) void writeBytes (QpidByteBuffer bytes) void setIdle (int idletimeout) // Called by NetworkDriver when the socket has closed void socketClosed() } 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 read from void setOutputBuffer(QpidByteBuffer buffer); // Set the buffer to write too 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