com.marketfactory.mfapi.enterprise.api.connection

Class SelectableConnection

java.lang.Object

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

com.marketfactory.mfapi.enterprise.api.connection.SelectableConnection

All Implemented Interfaces:

Connection

public class SelectableConnection
extends AbstractSocketChannelConnection

Connection with a socketChannel registered with a ChannelRegistry for reading and writing (when there are pending bytes to write).

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
SelectableConnection(int sendBufferSizeHint, int receiveBufferSizeHint, ChannelRegistry channelManager)

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) Reads as many bytes from the input channel of this Connection into the provided ByteBuffer.
void	writeFrom(java.nio.ByteBuffer byteBuffer) Writes as many bytes from the byteBuffer to the output channel of this Connection.

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

connect, disconnect, isConnected, setBufferSizes

Methods inherited from class java.lang.Object

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

Constructor Detail

SelectableConnection

public SelectableConnection(int sendBufferSizeHint,
                            int receiveBufferSizeHint,
                            ChannelRegistry channelManager)

Method Detail

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

readInto

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

Description copied from interface: Connection

Reads as many bytes from the input channel of this Connection into the provided ByteBuffer. Returns the number of bytes read, possibly 0.

Parameters:

byteBuffer - destination of the read bytes

Returns:

the number of bytes read, possibly 0

Throws:

java.io.IOException - if anything goes wrong

writeFrom

public void writeFrom(java.nio.ByteBuffer byteBuffer)
               throws java.io.IOException

Description copied from interface: Connection

Writes as many bytes from the byteBuffer to the output channel of this Connection. Returns the number of bytes written, possibly 0.

Specified by:

writeFrom in interface Connection

Overrides:

writeFrom in class AbstractSocketChannelConnection

Parameters:

byteBuffer - source of the bytes to write

Throws:

java.io.IOException - if anything goes wrong