com.marketfactory.mfapi.enterprise.api.connection

Class BlockingSocketChannelConnection

java.lang.Object

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

com.marketfactory.mfapi.enterprise.api.connection.BlockingSocketChannelConnection

All Implemented Interfaces:

Connection

public class BlockingSocketChannelConnection
extends AbstractSocketChannelConnection
implements Connection

Blocks, with timeout, using NIO selector.

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_READ_TIMEOUT_MS

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
BlockingSocketChannelConnection(int readTimeoutMs)
BlockingSocketChannelConnection(int sendBufferSizeHint, int receiveBufferSizeHint, int readTimeoutMs)

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

Field Detail

DEFAULT_READ_TIMEOUT_MS

public static final int DEFAULT_READ_TIMEOUT_MS

See Also:

Constant Field Values

Constructor Detail

BlockingSocketChannelConnection

public BlockingSocketChannelConnection(int sendBufferSizeHint,
                                       int receiveBufferSizeHint,
                                       int readTimeoutMs)

BlockingSocketChannelConnection

public BlockingSocketChannelConnection(int readTimeoutMs)

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