com.marketfactory.mfapi.enterprise.api.connection

Class AbstractSocketChannelConnection

java.lang.Object

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

All Implemented Interfaces:

Connection

Direct Known Subclasses:

SelectableConnection

public abstract class AbstractSocketChannelConnection
extends java.lang.Object
implements Connection

Field Summary

Fields

Modifier and Type	Field and Description
protected int	receiveBufferSizeHint
protected int	sendBufferSizeHint
protected java.nio.channels.SocketChannel	socketChannel

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

NO_HINT_VALUE

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractSocketChannelConnection(int sendBufferSizeHint, int receiveBufferSizeHint, org.slf4j.Logger log)

Method Summary

Modifier and Type	Method and Description
void	connect(java.lang.String hostname, int port)
void	disconnect()
boolean	isConnected()
protected abstract java.nio.channels.SocketChannel	openChannel(java.lang.String hostname, int port)
protected void	setBufferSizes(java.nio.channels.SocketChannel socketChannel)
void	writeFrom(java.nio.ByteBuffer byteBuffer) Writes as many bytes from the byteBuffer to the output channel of this Connection.

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

readInto

Field Detail

sendBufferSizeHint

protected final int sendBufferSizeHint

receiveBufferSizeHint

protected final int receiveBufferSizeHint

socketChannel

protected java.nio.channels.SocketChannel socketChannel

Constructor Detail

AbstractSocketChannelConnection

protected AbstractSocketChannelConnection(int sendBufferSizeHint,
                                          int receiveBufferSizeHint,
                                          org.slf4j.Logger log)

Method Detail

connect

public void connect(java.lang.String hostname,
                    int port)
             throws java.io.IOException

Specified by:

connect in interface Connection

Throws:

java.io.IOException

openChannel

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

Throws:

java.io.IOException

disconnect

public void disconnect()
                throws java.io.IOException

Specified by:

disconnect in interface Connection

Throws:

java.io.IOException

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

Parameters:

byteBuffer - source of the bytes to write

Throws:

java.io.IOException - if anything goes wrong

isConnected

public boolean isConnected()

Specified by:

isConnected in interface Connection

setBufferSizes

protected void setBufferSizes(java.nio.channels.SocketChannel socketChannel)
                       throws java.io.IOException

Throws:

java.io.IOException