com.marketfactory.mfapi.enterprise.api.core

Class SingleServiceCoreSession

java.lang.Object

com.marketfactory.mfapi.enterprise.api.core.SingleServiceCoreSession

All Implemented Interfaces:

CoreSession

public class SingleServiceCoreSession
extends java.lang.Object
implements CoreSession

Represents a single session with Whisperer A session is unique to a (user and venueName and type) combination A session has a state that handles messages appropriately

Constructor Summary

Constructors

Constructor and Description
SingleServiceCoreSession(java.lang.String host, int port, java.lang.String id, java.time.Clock clock, Connection connection, MessageProvider messageProvider, 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()
boolean	isConnected()
boolean	isWritePending()
void	readNext(MessageHandler messageHandler)
int	send(int byteCount) Tries to send the message.
java.lang.String	toString()
boolean	tryConnect()
int	writePendingBytes()

Methods inherited from class java.lang.Object

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

Constructor Detail

SingleServiceCoreSession

public SingleServiceCoreSession(java.lang.String host,
                                int port,
                                java.lang.String id,
                                java.time.Clock clock,
                                Connection connection,
                                MessageProvider messageProvider,
                                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

messageProvider - source of input messages

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: CoreSession

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

Specified by:

connect in interface CoreSession

disconnect

public void disconnect()

Specified by:

disconnect in interface CoreSession

readNext

public void readNext(MessageHandler messageHandler)

Specified by:

readNext in interface CoreSession

getId

public java.lang.String getId()

Specified by:

getId in interface CoreSession

isWritePending

public boolean isWritePending()

Specified by:

isWritePending in interface CoreSession

writePendingBytes

public int writePendingBytes()

Specified by:

writePendingBytes in interface CoreSession

isConnected

public boolean isConnected()

Specified by:

isConnected in interface CoreSession

tryConnect

public boolean tryConnect()

Specified by:

tryConnect in interface CoreSession

getLastReceivedMessageTimestampMs

public long getLastReceivedMessageTimestampMs()

Specified by:

getLastReceivedMessageTimestampMs in interface CoreSession

getLastSentMessageTimestampMs

public long getLastSentMessageTimestampMs()

Specified by:

getLastSentMessageTimestampMs in interface CoreSession

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

send

public int send(int byteCount)

Description copied from interface: CoreSession

Tries to send the message. Expects No checking is done at this point that the messageSeqNum is correct. The value provided will be used in the message. If the return value is greater than 0, it means that not all the bytes could be written to the output (most likely a TCP channel).

Specified by:

send in interface CoreSession

Parameters:

byteCount - total number of bytes to write

Returns:

the number of bytes remaining to write