com.marketfactory.mfapi.enterprise.api.connection

Class SingleConnectionManager

java.lang.Object

com.marketfactory.mfapi.enterprise.api.connection.SingleConnectionManager

All Implemented Interfaces:

ConnectionManager

public class SingleConnectionManager
extends java.lang.Object
implements ConnectionManager

Responsible for a single connection with a MF server. Handles reading bytes from a Connection into the provided receiveByteBuffer. Handles writing bytes to a Connection from the provided sendByteBuffer. The sendByteBuffer and receiveByteBuffer are shared the other classes that do tha actual reading/writing of SBE messages to/from the buffers.

Constructor Summary

Constructors

Constructor and Description
SingleConnectionManager(java.lang.String host, int port, java.lang.String id, java.time.Clock clock, Connection connection, BackPressureNotificationHandler backPressureNotificationHandler, java.nio.ByteBuffer sendByteBuffer, java.nio.ByteBuffer receiveByteBuffer) Construct

Method Summary

Modifier and Type	Method and Description
void	connect() Attempts to connect to the configured server by host and port.
void	disconnect()
java.lang.String	getId()
long	getLastReceivedMessageTimestampMs()
long	getLastSentMessageTimestampMs()
void	read()
int	send(int byteCount)
java.lang.String	toString()
void	writePendingBytes()

Methods inherited from class java.lang.Object

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

Constructor Detail

SingleConnectionManager

public SingleConnectionManager(java.lang.String host,
                               int port,
                               java.lang.String id,
                               java.time.Clock clock,
                               Connection connection,
                               BackPressureNotificationHandler backPressureNotificationHandler,
                               java.nio.ByteBuffer sendByteBuffer,
                               java.nio.ByteBuffer receiveByteBuffer)

Construct

Parameters:

host - host to connect to

port - port to connect to

id - descriptive session identifier

clock - clock

connection - connection to use

backPressureNotificationHandler - handler to

sendByteBuffer - buffer to send data with

receiveByteBuffer - buffer to receive data with

Method Detail

connect

public void connect()

Description copied from interface: ConnectionManager

Attempts to connect to the configured server by host and port. Will not retry automatically. Will not block

Specified by:

connect in interface ConnectionManager

disconnect

public void disconnect()

Specified by:

disconnect in interface ConnectionManager

getId

public java.lang.String getId()

Specified by:

getId in interface ConnectionManager

writePendingBytes

public void writePendingBytes()

Specified by:

writePendingBytes in interface ConnectionManager

read

public void read()
          throws MFDisconnectedException

Specified by:

read in interface ConnectionManager

Throws:

MFDisconnectedException

getLastReceivedMessageTimestampMs

public long getLastReceivedMessageTimestampMs()

Specified by:

getLastReceivedMessageTimestampMs in interface ConnectionManager

getLastSentMessageTimestampMs

public long getLastSentMessageTimestampMs()

Specified by:

getLastSentMessageTimestampMs in interface ConnectionManager

send

public int send(int byteCount)

Specified by:

send in interface ConnectionManager

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object