com.marketfactory.mfapi.enterprise.api.core

Interface CoreSession

All Known Implementing Classes:

SingleServiceCoreSession

public interface CoreSession

Basic, core CoreSession. Support for basic SBE reading and sending. There is no MF Enterprise protocol support at this, core, level. Classes like the SingleServiceCoreSession, can be used if you want to write your implementation of the MF protocol. MFRuntimeException will be thrown if any error occurs. The exception will contain the original source exception

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 totalBytesToWrite) Tries to send the message.
boolean	tryConnect()
int	writePendingBytes()

Method Detail

connect

void connect()
      throws MFRuntimeException

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

Throws:

MFRuntimeException - if any connection issue happens

tryConnect

boolean tryConnect()

isConnected

boolean isConnected()

disconnect

void disconnect()

readNext

void readNext(MessageHandler messageHandler)
       throws MFRuntimeException

Throws:

MFRuntimeException

send

int send(int totalBytesToWrite)
  throws MFRuntimeException

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).

Parameters:

totalBytesToWrite - total number of bytes to write

Returns:

the number of bytes remaining to write

Throws:

MFRuntimeException - if the send fails due to connectivity issues

getLastReceivedMessageTimestampMs

long getLastReceivedMessageTimestampMs()

getLastSentMessageTimestampMs

long getLastSentMessageTimestampMs()

getId

java.lang.String getId()

isWritePending

boolean isWritePending()

writePendingBytes

int writePendingBytes()
               throws MFRuntimeException

Throws:

MFRuntimeException