com.marketfactory.mfapi.enterprise.api.connection

Class NonblockingSocketChannelConnection

java.lang.Object

com.marketfactory.mfapi.enterprise.api.connection.AbstractSocketChannelConnection

com.marketfactory.mfapi.enterprise.api.connection.NonblockingSocketChannelConnection

All Implemented Interfaces:

Connection

public class NonblockingSocketChannelConnection
extends AbstractSocketChannelConnection
implements Connection

Field Summary

Fields inherited from class com.marketfactory.mfapi.enterprise.api.connection.AbstractSocketChannelConnection

receiveBufferSizeHint, sendBufferSizeHint, socketChannel

Fields inherited from interface com.marketfactory.mfapi.enterprise.api.connection.Connection

NO_HINT_VALUE

Constructor Summary

Constructors

Constructor and Description
NonblockingSocketChannelConnection(int sendBufferSizeHint, int receiveBufferSizeHint)

Method Summary

Modifier and Type	Method and Description
protected java.nio.channels.SocketChannel	openChannel(java.lang.String hostname, int port)
int	readInto(java.nio.ByteBuffer byteBuffer)

Methods inherited from class com.marketfactory.mfapi.enterprise.api.connection.AbstractSocketChannelConnection

connect, disconnect, isConnected, setBufferSizes, tryFinishConnect, writeFrom

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.marketfactory.mfapi.enterprise.api.connection.Connection

connect, disconnect, isConnected, tryFinishConnect, writeFrom

Constructor Detail

NonblockingSocketChannelConnection

public NonblockingSocketChannelConnection(int sendBufferSizeHint,
                                          int receiveBufferSizeHint)

Method Detail

readInto

public int readInto(java.nio.ByteBuffer byteBuffer)
             throws java.io.IOException

Specified by:

readInto in interface Connection

Throws:

java.io.IOException

openChannel

protected java.nio.channels.SocketChannel openChannel(java.lang.String hostname,
                                                      int port)
                                               throws java.io.IOException

Specified by:

openChannel in class AbstractSocketChannelConnection

Throws:

java.io.IOException