A B C D E G H I L M N O P R S T U W

A

AbstractSocketChannelConnection - Class in com.marketfactory.mfapi.enterprise.api.connection

AbstractSocketChannelConnection(int, int, Logger) - Constructor for class com.marketfactory.mfapi.enterprise.api.connection.AbstractSocketChannelConnection

addWorker(Worker) - Method in class com.marketfactory.mfapi.enterprise.api.engine.Engine

assertAndAddOneToNextExpectedSequenceNumber(long) - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

assertAndAddOneToNextExpectedSequenceNumber(long) - Method in interface com.marketfactory.mfapi.enterprise.api.state.StateContext

Asserts the current next expected sequence number is equal to the parameter.

assertAndSetNextExpectedSequenceNumber(long, long) - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

assertAndSetNextExpectedSequenceNumber(long, long) - Method in interface com.marketfactory.mfapi.enterprise.api.state.StateContext

B

BackPressureNotificationHandler - Interface in com.marketfactory.mfapi.enterprise.api

Optional Handler The concept here is to receive a notification when all the bytes of a message could not be written to the TCP output buffer.

build() - Method in interface com.marketfactory.mfapi.enterprise.api.SessionBuilder

Builds the Session.

C

CallbackHandler - Interface in com.marketfactory.mfapi.enterprise.api

ChannelRegistry - Interface in com.marketfactory.mfapi.enterprise.api.connection

Implementers are responsible for dealing with registered channels.

ChannelWorker - Class in com.marketfactory.mfapi.enterprise.api.engine

Uses a Selector to generate read, write, and connect events from registered Channels.

ChannelWorker() - Constructor for class com.marketfactory.mfapi.enterprise.api.engine.ChannelWorker

com.marketfactory.mfapi.enterprise.api - package com.marketfactory.mfapi.enterprise.api

com.marketfactory.mfapi.enterprise.api.connection - package com.marketfactory.mfapi.enterprise.api.connection

Basic Socket Channel and byte-oriented classes for working with TCP sockets.

com.marketfactory.mfapi.enterprise.api.engine - package com.marketfactory.mfapi.enterprise.api.engine

Event processing engine classes - the background code that drives the sample implementation.

com.marketfactory.mfapi.enterprise.api.sbe - package com.marketfactory.mfapi.enterprise.api.sbe

Contains SBE handling classes for wrapping ByteBuffers with Encoders and Decoders for reading and writing.

com.marketfactory.mfapi.enterprise.api.session - package com.marketfactory.mfapi.enterprise.api.session

com.marketfactory.mfapi.enterprise.api.state - package com.marketfactory.mfapi.enterprise.api.state

Session state machine classes.

compareAndIncrement(long) - Method in interface com.marketfactory.mfapi.enterprise.api.NextExpectedMessageSequenceNumberStore

Checks that the next expected value is what is expected and then increments the next expected by 1.

compareAndSet(long, long) - Method in interface com.marketfactory.mfapi.enterprise.api.NextExpectedMessageSequenceNumberStore

Checks that the next expected value is what is expected.

connect(String, int) - Method in class com.marketfactory.mfapi.enterprise.api.connection.AbstractSocketChannelConnection

connect(String, int) - Method in interface com.marketfactory.mfapi.enterprise.api.connection.Connection

connect() - Method in interface com.marketfactory.mfapi.enterprise.api.connection.ConnectionManager

Attempts to connect to the configured server by host and port.

connect() - Method in class com.marketfactory.mfapi.enterprise.api.connection.SingleConnectionManager

connect() - Method in interface com.marketfactory.mfapi.enterprise.api.session.InternalSession

connect() - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

connect() - Method in interface com.marketfactory.mfapi.enterprise.api.state.StateContext

Connection - Interface in com.marketfactory.mfapi.enterprise.api.connection

ConnectionManager - Interface in com.marketfactory.mfapi.enterprise.api.connection

Manages a Connection.

convertToBD(DecimalQtyNULLDecoder) - Static method in class com.marketfactory.mfapi.enterprise.api.sbe.SbeUtils

convertToBD(PriceNULLDecoder) - Static method in class com.marketfactory.mfapi.enterprise.api.sbe.SbeUtils

convertToDouble(DecimalQtyNULLDecoder) - Static method in class com.marketfactory.mfapi.enterprise.api.sbe.SbeUtils

convertToDouble(PriceNULLDecoder) - Static method in class com.marketfactory.mfapi.enterprise.api.sbe.SbeUtils

convertToNanos(Clock) - Static method in class com.marketfactory.mfapi.enterprise.api.sbe.SbeUtils

copy(MessageHeaderDecoder, DecoderFlyweight) - Static method in class com.marketfactory.mfapi.enterprise.api.sbe.SbeUtils

Copies the messageDecoder bytes (not the header) into a newly created DirectBuffer.

copy(MessageHeaderDecoder, ByteBuffer) - Static method in class com.marketfactory.mfapi.enterprise.api.sbe.SbeUtils

Copies the messageDecoder bytes (not the header) into a destination buffer.

copyDecimalQty(DecimalQtyNULLDecoder, DecimalQtyNULLEncoder) - Static method in class com.marketfactory.mfapi.enterprise.api.sbe.SbeUtils

copyPrice(PriceNULLDecoder, PriceNULLEncoder) - Static method in class com.marketfactory.mfapi.enterprise.api.sbe.SbeUtils

createSessionBuilder() - Method in class com.marketfactory.mfapi.enterprise.api.session.SessionBuilderFactory

createSessionBuilder() - Static method in interface com.marketfactory.mfapi.enterprise.api.SessionBuilder

D

DecoderProvider - Interface in com.marketfactory.mfapi.enterprise.api.sbe

DEFAULT_HEARTBEAT_INTERVAL_SECONDS - Static variable in class com.marketfactory.mfapi.enterprise.api.session.SessionBuilderFactory

disconnect() - Method in class com.marketfactory.mfapi.enterprise.api.connection.AbstractSocketChannelConnection

disconnect() - Method in interface com.marketfactory.mfapi.enterprise.api.connection.Connection

disconnect() - Method in interface com.marketfactory.mfapi.enterprise.api.connection.ConnectionManager

disconnect() - Method in class com.marketfactory.mfapi.enterprise.api.connection.SingleConnectionManager

disconnect() - Method in interface com.marketfactory.mfapi.enterprise.api.Session

Disconnect immediately.

disconnect() - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

disconnect() - Method in interface com.marketfactory.mfapi.enterprise.api.state.StateContext

DisconnectingFromGatewayState - Class in com.marketfactory.mfapi.enterprise.api.state

Responsible for gracefully disconnecting from the MarketFactory Gateways server.

DisconnectingFromGatewayState(StateContext, int) - Constructor for class com.marketfactory.mfapi.enterprise.api.state.DisconnectingFromGatewayState

DisconnectingFromVenueState - Class in com.marketfactory.mfapi.enterprise.api.state

Responsible for gracefully logging off of the venue.

DisconnectingFromVenueState(StateContext) - Constructor for class com.marketfactory.mfapi.enterprise.api.state.DisconnectingFromVenueState

disconnectNow() - Method in class com.marketfactory.mfapi.enterprise.api.engine.UserCommandWorker

dispatch(MessageHandler) - Method in interface com.marketfactory.mfapi.enterprise.api.sbe.DecoderProvider

Dispatches complete message decoders to the provided MessageHandler

dispatch(MessageHandler) - Method in class com.marketfactory.mfapi.enterprise.api.sbe.SbeDecoderProvider

doWork() - Method in class com.marketfactory.mfapi.enterprise.api.engine.ChannelWorker

doWork() - Method in class com.marketfactory.mfapi.enterprise.api.engine.TimerWorker

doWork() - Method in class com.marketfactory.mfapi.enterprise.api.engine.UserCommandWorker

doWork() - Method in interface com.marketfactory.mfapi.enterprise.api.engine.Worker

E

EncoderProvider - Interface in com.marketfactory.mfapi.enterprise.api.sbe

EndOfSessionSyncState - Class in com.marketfactory.mfapi.enterprise.api.state

At the end of the synchronization states - even if there was no actual messages replayed - the server will send a test request to indicate synchronization is complete.

Engine - Class in com.marketfactory.mfapi.enterprise.api.engine

Uses a thread to call Worker.doWork() on all added Worker objects.

Engine(ExecutorService) - Constructor for class com.marketfactory.mfapi.enterprise.api.engine.Engine

EngineThreadFactory - Class in com.marketfactory.mfapi.enterprise.api.engine

EngineThreadFactory(String, Thread.UncaughtExceptionHandler) - Constructor for class com.marketfactory.mfapi.enterprise.api.engine.EngineThreadFactory

EventHandler - Interface in com.marketfactory.mfapi.enterprise.api.engine

G

get() - Static method in class com.marketfactory.mfapi.enterprise.api.session.SessionBuilderFactory

getAndIncrementNextMsgSequenceNumber() - Method in interface com.marketfactory.mfapi.enterprise.api.NextOutgoingMessageSequenceNumberStore

Increments the next message sequence number.

getApplicationMessageRequestEncoder() - Method in interface com.marketfactory.mfapi.enterprise.api.sbe.EncoderProvider

getApplicationMessageRequestEncoder() - Method in class com.marketfactory.mfapi.enterprise.api.sbe.SbeEncoderProvider

getCurrentTimeMs() - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

getCurrentTimeMs() - Method in interface com.marketfactory.mfapi.enterprise.api.state.StateContext

getDaysSinceEpoch(LocalDate) - Static method in class com.marketfactory.mfapi.enterprise.api.sbe.SbeUtils

getExecutionAckEncoder() - Method in interface com.marketfactory.mfapi.enterprise.api.sbe.EncoderProvider

getExecutionAckEncoder() - Method in class com.marketfactory.mfapi.enterprise.api.sbe.SbeEncoderProvider

getExecutionReportEncoder() - Method in interface com.marketfactory.mfapi.enterprise.api.sbe.EncoderProvider

getExecutionReportEncoder() - Method in class com.marketfactory.mfapi.enterprise.api.sbe.SbeEncoderProvider

getHeartbeatEncoder() - Method in interface com.marketfactory.mfapi.enterprise.api.sbe.EncoderProvider

getHeartbeatEncoder() - Method in class com.marketfactory.mfapi.enterprise.api.sbe.SbeEncoderProvider

getId() - Method in interface com.marketfactory.mfapi.enterprise.api.connection.ConnectionManager

getId() - Method in class com.marketfactory.mfapi.enterprise.api.connection.SingleConnectionManager

getLastReceivedMessageTimestampMs() - Method in interface com.marketfactory.mfapi.enterprise.api.connection.ConnectionManager

getLastReceivedMessageTimestampMs() - Method in class com.marketfactory.mfapi.enterprise.api.connection.SingleConnectionManager

getLastReceivedMessageTimestampMs() - Method in interface com.marketfactory.mfapi.enterprise.api.session.InternalSession

The time the last message was received or 0 if no message has been received.

getLastReceivedTimestamp() - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

getLastReceivedTimestamp() - Method in interface com.marketfactory.mfapi.enterprise.api.state.StateContext

getLastSentMessageTimestampMs() - Method in interface com.marketfactory.mfapi.enterprise.api.connection.ConnectionManager

getLastSentMessageTimestampMs() - Method in class com.marketfactory.mfapi.enterprise.api.connection.SingleConnectionManager

getLastSentMessageTimestampMs() - Method in interface com.marketfactory.mfapi.enterprise.api.session.InternalSession

The time the last message was send or 0 if no message has been sent.

getLastSentTimestamp() - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

getLastSentTimestamp() - Method in interface com.marketfactory.mfapi.enterprise.api.state.StateContext

getLogonEncoder() - Method in interface com.marketfactory.mfapi.enterprise.api.sbe.EncoderProvider

getLogonEncoder() - Method in class com.marketfactory.mfapi.enterprise.api.sbe.SbeEncoderProvider

getLogoutEncoder() - Method in interface com.marketfactory.mfapi.enterprise.api.sbe.EncoderProvider

getLogoutEncoder() - Method in class com.marketfactory.mfapi.enterprise.api.sbe.SbeEncoderProvider

getLogoutResponseEncoder() - Method in interface com.marketfactory.mfapi.enterprise.api.sbe.EncoderProvider

getLogoutResponseEncoder() - Method in class com.marketfactory.mfapi.enterprise.api.sbe.SbeEncoderProvider

getMarketDataRequestEncoder() - Method in interface com.marketfactory.mfapi.enterprise.api.sbe.EncoderProvider

getMarketDataRequestEncoder() - Method in class com.marketfactory.mfapi.enterprise.api.sbe.SbeEncoderProvider

getMassQuoteEncoder() - Method in interface com.marketfactory.mfapi.enterprise.api.sbe.EncoderProvider

getMassQuoteEncoder() - Method in class com.marketfactory.mfapi.enterprise.api.sbe.SbeEncoderProvider

getMultilegOrderCancelReplaceRequestEncoder() - Method in interface com.marketfactory.mfapi.enterprise.api.sbe.EncoderProvider

getMultilegOrderCancelReplaceRequestEncoder() - Method in class com.marketfactory.mfapi.enterprise.api.sbe.SbeEncoderProvider

getNewOrderMultilegEncoder() - Method in interface com.marketfactory.mfapi.enterprise.api.sbe.EncoderProvider

getNewOrderMultilegEncoder() - Method in class com.marketfactory.mfapi.enterprise.api.sbe.SbeEncoderProvider

getNextExpected() - Method in interface com.marketfactory.mfapi.enterprise.api.NextExpectedMessageSequenceNumberStore

Get the current next expected message sequence number.

getNextExpectedMsgSeqNum() - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

getNextExpectedMsgSeqNum() - Method in interface com.marketfactory.mfapi.enterprise.api.state.StateContext

getNextMsgSequenceNumber() - Method in interface com.marketfactory.mfapi.enterprise.api.NextOutgoingMessageSequenceNumberStore

Gets the current next message sequence number.

getNextOutgoingSequenceNumber() - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

getNextOutgoingSequenceNumber() - Method in interface com.marketfactory.mfapi.enterprise.api.state.StateContext

getOr(T, T) - Static method in class com.marketfactory.mfapi.enterprise.api.sbe.SbeUtils

getOrderCancelRejectEncoder() - Method in interface com.marketfactory.mfapi.enterprise.api.sbe.EncoderProvider

getOrderCancelRejectEncoder() - Method in class com.marketfactory.mfapi.enterprise.api.sbe.SbeEncoderProvider

getOrderCancelRequestEncoder() - Method in interface com.marketfactory.mfapi.enterprise.api.sbe.EncoderProvider

getOrderCancelRequestEncoder() - Method in class com.marketfactory.mfapi.enterprise.api.sbe.SbeEncoderProvider

getOrderTimeoutEncoder() - Method in interface com.marketfactory.mfapi.enterprise.api.sbe.EncoderProvider

getOrderTimeoutEncoder() - Method in class com.marketfactory.mfapi.enterprise.api.sbe.SbeEncoderProvider

getQuoteCancelEncoder() - Method in interface com.marketfactory.mfapi.enterprise.api.sbe.EncoderProvider

getQuoteCancelEncoder() - Method in class com.marketfactory.mfapi.enterprise.api.sbe.SbeEncoderProvider

getQuoteEncoder() - Method in interface com.marketfactory.mfapi.enterprise.api.sbe.EncoderProvider

getQuoteEncoder() - Method in class com.marketfactory.mfapi.enterprise.api.sbe.SbeEncoderProvider

getQuoteRequestEncoder() - Method in interface com.marketfactory.mfapi.enterprise.api.sbe.EncoderProvider

getQuoteRequestEncoder() - Method in class com.marketfactory.mfapi.enterprise.api.sbe.SbeEncoderProvider

getQuoteResponseEncoder() - Method in interface com.marketfactory.mfapi.enterprise.api.sbe.EncoderProvider

getQuoteResponseEncoder() - Method in class com.marketfactory.mfapi.enterprise.api.sbe.SbeEncoderProvider

getRuntimeInfo() - Static method in class com.marketfactory.mfapi.enterprise.api.session.InfoProvider

getSequenceResetGapFillEncoder() - Method in interface com.marketfactory.mfapi.enterprise.api.sbe.EncoderProvider

getSequenceResetGapFillEncoder() - Method in class com.marketfactory.mfapi.enterprise.api.sbe.SbeEncoderProvider

getTestRequestEncoder() - Method in interface com.marketfactory.mfapi.enterprise.api.sbe.EncoderProvider

getTestRequestEncoder() - Method in class com.marketfactory.mfapi.enterprise.api.sbe.SbeEncoderProvider

getUserRequestEncoder() - Method in interface com.marketfactory.mfapi.enterprise.api.sbe.EncoderProvider

getUserRequestEncoder() - Method in class com.marketfactory.mfapi.enterprise.api.sbe.SbeEncoderProvider

H

handleUnexpectedMessage(MessageHeaderDecoder, MessageDecoderFlyweight) - Method in interface com.marketfactory.mfapi.enterprise.api.CallbackHandler

Override this if you want to change the unexpected method handling.

I

InfoProvider - Class in com.marketfactory.mfapi.enterprise.api.session

Provides runtime data that can sent with a logon message and logged on the server.

init(InternalSession) - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

initiateLogon() - Method in interface com.marketfactory.mfapi.enterprise.api.Session

Initiates a connection and full session synchronization.

initiateLogout(String) - Method in interface com.marketfactory.mfapi.enterprise.api.Session

Attempts to logout of either the venue or the MarketFactory gateway server; depending on the state.

InternalSession - Interface in com.marketfactory.mfapi.enterprise.api.session

isConnected() - Method in class com.marketfactory.mfapi.enterprise.api.connection.AbstractSocketChannelConnection

isConnected() - Method in interface com.marketfactory.mfapi.enterprise.api.connection.Connection

isReplaySession() - Method in interface com.marketfactory.mfapi.enterprise.api.session.InternalSession

isReplaySession() - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

isReplaySession() - Method in interface com.marketfactory.mfapi.enterprise.api.state.StateContext

L

LoggingOnState - Class in com.marketfactory.mfapi.enterprise.api.state

After a successful connection is made in the OfflineConnectingState this state is responsible for Authentication by sending a Logon message.

LoggingOnState(StateContext) - Constructor for class com.marketfactory.mfapi.enterprise.api.state.LoggingOnState

M

MessageHandler - Interface in com.marketfactory.mfapi.enterprise.api.sbe

Callback handler for every MF API Message Decoder.

MFDisconnectedException - Exception in com.marketfactory.mfapi.enterprise.api.connection

MFDisconnectedException(String) - Constructor for exception com.marketfactory.mfapi.enterprise.api.connection.MFDisconnectedException

MFRuntimeException - Exception in com.marketfactory.mfapi.enterprise.api

MFRuntimeException(String) - Constructor for exception com.marketfactory.mfapi.enterprise.api.MFRuntimeException

MFRuntimeException(String, Throwable) - Constructor for exception com.marketfactory.mfapi.enterprise.api.MFRuntimeException

MFRuntimeException(Throwable) - Constructor for exception com.marketfactory.mfapi.enterprise.api.MFRuntimeException

MFRuntimeException(String, Throwable, boolean, boolean) - Constructor for exception com.marketfactory.mfapi.enterprise.api.MFRuntimeException

MFRuntimeException() - Constructor for exception com.marketfactory.mfapi.enterprise.api.MFRuntimeException

moveToClientToServerSyncState(long) - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

moveToClientToServerSyncState(long) - Method in interface com.marketfactory.mfapi.enterprise.api.state.StateContext

moveToDisconnectingFromGatewayState() - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

moveToDisconnectingFromGatewayState() - Method in interface com.marketfactory.mfapi.enterprise.api.state.StateContext

moveToDisconnectingFromVenueState() - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

moveToDisconnectingFromVenueState() - Method in interface com.marketfactory.mfapi.enterprise.api.state.StateContext

moveToEndOfSessionSyncState() - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

moveToEndOfSessionSyncState() - Method in interface com.marketfactory.mfapi.enterprise.api.state.StateContext

moveToLoggedOnToGatewayState() - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

moveToLoggedOnToGatewayState() - Method in interface com.marketfactory.mfapi.enterprise.api.state.StateContext

moveToLoggedOnToVenueState() - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

moveToLoggedOnToVenueState() - Method in interface com.marketfactory.mfapi.enterprise.api.state.StateContext

moveToLoggingOnState() - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

moveToLoggingOnState() - Method in interface com.marketfactory.mfapi.enterprise.api.state.StateContext

moveToOfflineConnectingState() - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

moveToOfflineConnectingState() - Method in interface com.marketfactory.mfapi.enterprise.api.state.StateContext

moveToOfflineWaitingState() - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

moveToOfflineWaitingState() - Method in interface com.marketfactory.mfapi.enterprise.api.state.StateContext

moveToServerToClientSyncState(long, long, boolean) - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

moveToServerToClientSyncState(long, long, boolean) - Method in interface com.marketfactory.mfapi.enterprise.api.state.StateContext

N

newThread(Runnable) - Method in class com.marketfactory.mfapi.enterprise.api.engine.EngineThreadFactory

NextExpectedMessageSequenceNumberStore - Interface in com.marketfactory.mfapi.enterprise.api

Implemented by the client

NextOutgoingMessageSequenceNumberStore - Interface in com.marketfactory.mfapi.enterprise.api

Implemented by the client

NO_HINT_VALUE - Static variable in interface com.marketfactory.mfapi.enterprise.api.connection.Connection

NoopBackPressureNotificationHandler - Class in com.marketfactory.mfapi.enterprise.api.session

Default BackPressureNotificationHandler.

NoopBackPressureNotificationHandler() - Constructor for class com.marketfactory.mfapi.enterprise.api.session.NoopBackPressureNotificationHandler

notifyClientLogoffRequest() - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

notifyClientLogoffRequest() - Method in interface com.marketfactory.mfapi.enterprise.api.state.StateContext

notifyClientMarketFactoryLogOff() - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

notifyClientMarketFactoryLogOff() - Method in interface com.marketfactory.mfapi.enterprise.api.state.StateContext

notifyClientMarketFactoryLogOn() - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

notifyClientMarketFactoryLogOn() - Method in interface com.marketfactory.mfapi.enterprise.api.state.StateContext

notifyClientReplayRequest(long, long) - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

notifyClientReplayRequest(long, long) - Method in interface com.marketfactory.mfapi.enterprise.api.state.StateContext

notifyClientVenueLogoff() - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

notifyClientVenueLogoff() - Method in interface com.marketfactory.mfapi.enterprise.api.state.StateContext

notifyClientVenueLogon() - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

notifyClientVenueLogon() - Method in interface com.marketfactory.mfapi.enterprise.api.state.StateContext

notifyPendingWrite(SocketChannel) - Method in interface com.marketfactory.mfapi.enterprise.api.connection.ChannelRegistry

notifyPendingWrite(SocketChannel) - Method in class com.marketfactory.mfapi.enterprise.api.engine.ChannelWorker

NULL_STRING_VALUE - Static variable in class com.marketfactory.mfapi.enterprise.api.sbe.SbeUtils

O

OfflineConnectingState - Class in com.marketfactory.mfapi.enterprise.api.state

Responsible for opening a connection to MarketFactory.

OfflineConnectingState(StateContext) - Constructor for class com.marketfactory.mfapi.enterprise.api.state.OfflineConnectingState

OfflineWaitingState - Class in com.marketfactory.mfapi.enterprise.api.state

Initial state.

OfflineWaitingState(StateContext) - Constructor for class com.marketfactory.mfapi.enterprise.api.state.OfflineWaitingState

onApplicationMessageReport(MessageHeaderDecoder, ApplicationMessageReportDecoder) - Method in interface com.marketfactory.mfapi.enterprise.api.CallbackHandler

onApplicationMessageReport(MessageHeaderDecoder, ApplicationMessageReportDecoder) - Method in interface com.marketfactory.mfapi.enterprise.api.sbe.MessageHandler

onApplicationMessageReport(MessageHeaderDecoder, ApplicationMessageReportDecoder) - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

onBackPressureEnd() - Method in interface com.marketfactory.mfapi.enterprise.api.BackPressureNotificationHandler

Called when all the remaining queued bytes have been written to the TCP socket.

onBackPressureEnd() - Method in class com.marketfactory.mfapi.enterprise.api.session.NoopBackPressureNotificationHandler

onBackPressureStart() - Method in interface com.marketfactory.mfapi.enterprise.api.BackPressureNotificationHandler

Called when at least one byte could not be written to the TCP socket.

onBackPressureStart() - Method in class com.marketfactory.mfapi.enterprise.api.session.NoopBackPressureNotificationHandler

onBusinessMessageReject(MessageHeaderDecoder, BusinessMessageRejectDecoder) - Method in interface com.marketfactory.mfapi.enterprise.api.CallbackHandler

onBusinessMessageReject(MessageHeaderDecoder, BusinessMessageRejectDecoder) - Method in interface com.marketfactory.mfapi.enterprise.api.sbe.MessageHandler

onBusinessMessageReject(long, BusinessMessageRejectDecoder) - Method in class com.marketfactory.mfapi.enterprise.api.state.DisconnectingFromVenueState

This is a special case that needs to be considered.

onBusinessMessageReject(MessageHeaderDecoder, BusinessMessageRejectDecoder) - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

The handling of the BusinessMessageReject is slightly different to other business-level messages.

onClientRequestedDisconnection() - Method in interface com.marketfactory.mfapi.enterprise.api.engine.EventHandler

Called when a client wants the session to disconnect immediately

onClientRequestedDisconnection() - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

onClientRequestedLogon() - Method in interface com.marketfactory.mfapi.enterprise.api.engine.EventHandler

Called when a client wants the session to logon

onClientRequestedLogon() - Method in class com.marketfactory.mfapi.enterprise.api.state.OfflineWaitingState

onClientRequestedLogon() - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

onClientRequestedLogout() - Method in interface com.marketfactory.mfapi.enterprise.api.engine.EventHandler

Called when a client wants the session to gracefully logout

onClientRequestedLogout() - Method in class com.marketfactory.mfapi.enterprise.api.state.OfflineConnectingState

onClientRequestedLogout() - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

onConnection() - Method in interface com.marketfactory.mfapi.enterprise.api.engine.EventHandler

Called when a connection is made to a MF server.

onConnection() - Method in class com.marketfactory.mfapi.enterprise.api.state.OfflineConnectingState

onConnection() - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

onDisconnection() - Method in interface com.marketfactory.mfapi.enterprise.api.engine.EventHandler

Called when a connection is lost from a MF server.

onDisconnection() - Method in class com.marketfactory.mfapi.enterprise.api.state.DisconnectingFromGatewayState

onDisconnection() - Method in class com.marketfactory.mfapi.enterprise.api.state.DisconnectingFromVenueState

If the server drop the connection/disconnects us at this point since we wanted to be logged off we will go directly to the OfflineWaitingState state.

onDisconnection() - Method in class com.marketfactory.mfapi.enterprise.api.state.LoggingOnState

onDisconnection() - Method in class com.marketfactory.mfapi.enterprise.api.state.OfflineConnectingState

onDisconnection() - Method in class com.marketfactory.mfapi.enterprise.api.state.OfflineWaitingState

onDisconnection() - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

onEndMarker(MessageHeaderDecoder, EndMarkerDecoder) - Method in interface com.marketfactory.mfapi.enterprise.api.CallbackHandler

onEndMarker(MessageHeaderDecoder, EndMarkerDecoder) - Method in interface com.marketfactory.mfapi.enterprise.api.sbe.MessageHandler

onEndMarker(MessageHeaderDecoder, EndMarkerDecoder) - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

onEnter() - Method in class com.marketfactory.mfapi.enterprise.api.state.DisconnectingFromGatewayState

onEnter() - Method in class com.marketfactory.mfapi.enterprise.api.state.DisconnectingFromVenueState

onEnter() - Method in class com.marketfactory.mfapi.enterprise.api.state.LoggingOnState

onEnter() - Method in class com.marketfactory.mfapi.enterprise.api.state.OfflineWaitingState

onErrorReport(MessageHeaderDecoder, ErrorReportDecoder) - Method in interface com.marketfactory.mfapi.enterprise.api.CallbackHandler

onErrorReport(MessageHeaderDecoder, ErrorReportDecoder) - Method in interface com.marketfactory.mfapi.enterprise.api.sbe.MessageHandler

onErrorReport(MessageHeaderDecoder, ErrorReportDecoder) - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

onExecutionAck(MessageHeaderDecoder, ExecutionAckDecoder) - Method in interface com.marketfactory.mfapi.enterprise.api.CallbackHandler

onExecutionAck(MessageHeaderDecoder, ExecutionAckDecoder) - Method in interface com.marketfactory.mfapi.enterprise.api.sbe.MessageHandler

onExecutionAck(MessageHeaderDecoder, ExecutionAckDecoder) - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

onExecutionReport(MessageHeaderDecoder, ExecutionReportDecoder) - Method in interface com.marketfactory.mfapi.enterprise.api.CallbackHandler

onExecutionReport(MessageHeaderDecoder, ExecutionReportDecoder) - Method in interface com.marketfactory.mfapi.enterprise.api.sbe.MessageHandler

onExecutionReport(MessageHeaderDecoder, ExecutionReportDecoder) - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

onHeartbeat(MessageHeaderDecoder, HeartbeatDecoder) - Method in interface com.marketfactory.mfapi.enterprise.api.sbe.MessageHandler

onHeartbeat(MessageHeaderDecoder, HeartbeatDecoder) - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

onLogonResponse(MessageHeaderDecoder, LogonResponseDecoder) - Method in interface com.marketfactory.mfapi.enterprise.api.sbe.MessageHandler

onLogonResponse(long, LogonResponseDecoder) - Method in class com.marketfactory.mfapi.enterprise.api.state.LoggingOnState

The server has authenticated the credentials and the requested session - now we need to determine what, if any, message synchronization is needed.

onLogonResponse(MessageHeaderDecoder, LogonResponseDecoder) - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

onLogout(MessageHeaderDecoder, LogoutDecoder) - Method in interface com.marketfactory.mfapi.enterprise.api.CallbackHandler

Passed through to client if they want the original messages.

onLogout(MessageHeaderDecoder, LogoutDecoder) - Method in interface com.marketfactory.mfapi.enterprise.api.sbe.MessageHandler

onLogout(long, LogoutDecoder) - Method in class com.marketfactory.mfapi.enterprise.api.state.LoggingOnState

onLogout(MessageHeaderDecoder, LogoutDecoder) - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

onLogoutRequest() - Method in interface com.marketfactory.mfapi.enterprise.api.CallbackHandler

Server has requested client logout.

onLogoutResponse(MessageHeaderDecoder, LogoutResponseDecoder) - Method in interface com.marketfactory.mfapi.enterprise.api.sbe.MessageHandler

onLogoutResponse(long, LogoutResponseDecoder) - Method in class com.marketfactory.mfapi.enterprise.api.state.DisconnectingFromGatewayState

onLogoutResponse(MessageHeaderDecoder, LogoutResponseDecoder) - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

onMarketDataIncrementalRefresh(MessageHeaderDecoder, MarketDataIncrementalRefreshDecoder) - Method in interface com.marketfactory.mfapi.enterprise.api.CallbackHandler

onMarketDataIncrementalRefresh(MessageHeaderDecoder, MarketDataIncrementalRefreshDecoder) - Method in interface com.marketfactory.mfapi.enterprise.api.sbe.MessageHandler

onMarketDataIncrementalRefresh(MessageHeaderDecoder, MarketDataIncrementalRefreshDecoder) - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

onMarketDataRequestReject(MessageHeaderDecoder, MarketDataRequestRejectDecoder) - Method in interface com.marketfactory.mfapi.enterprise.api.CallbackHandler

onMarketDataRequestReject(MessageHeaderDecoder, MarketDataRequestRejectDecoder) - Method in interface com.marketfactory.mfapi.enterprise.api.sbe.MessageHandler

onMarketDataRequestReject(MessageHeaderDecoder, MarketDataRequestRejectDecoder) - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

onMarketFactoryLogOff() - Method in interface com.marketfactory.mfapi.enterprise.api.CallbackHandler

Called after session has been logged out and disconnected from the MarketFactory Server.

onMarketFactoryLogOn() - Method in interface com.marketfactory.mfapi.enterprise.api.CallbackHandler

Called after connection and synchronization is complete to MarketFactory Server.

onMassQuote(MessageHeaderDecoder, MassQuoteDecoder) - Method in interface com.marketfactory.mfapi.enterprise.api.CallbackHandler

onMassQuote(MessageHeaderDecoder, MassQuoteDecoder) - Method in interface com.marketfactory.mfapi.enterprise.api.sbe.MessageHandler

onMassQuote(MessageHeaderDecoder, MassQuoteDecoder) - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

onNewOrderMultileg(MessageHeaderDecoder, NewOrderMultilegDecoder) - Method in interface com.marketfactory.mfapi.enterprise.api.CallbackHandler

onNewOrderMultileg(MessageHeaderDecoder, NewOrderMultilegDecoder) - Method in interface com.marketfactory.mfapi.enterprise.api.sbe.MessageHandler

onNewOrderMultileg(MessageHeaderDecoder, NewOrderMultilegDecoder) - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

onOrderCancelReject(MessageHeaderDecoder, OrderCancelRejectDecoder) - Method in interface com.marketfactory.mfapi.enterprise.api.CallbackHandler

onOrderCancelReject(MessageHeaderDecoder, OrderCancelRejectDecoder) - Method in interface com.marketfactory.mfapi.enterprise.api.sbe.MessageHandler

onOrderCancelReject(MessageHeaderDecoder, OrderCancelRejectDecoder) - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

onOrderTimeout(MessageHeaderDecoder, OrderTimeoutDecoder) - Method in interface com.marketfactory.mfapi.enterprise.api.CallbackHandler

onOrderTimeout(MessageHeaderDecoder, OrderTimeoutDecoder) - Method in interface com.marketfactory.mfapi.enterprise.api.sbe.MessageHandler

onOrderTimeout(MessageHeaderDecoder, OrderTimeoutDecoder) - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

onQuote(MessageHeaderDecoder, QuoteDecoder) - Method in interface com.marketfactory.mfapi.enterprise.api.CallbackHandler

onQuote(MessageHeaderDecoder, QuoteDecoder) - Method in interface com.marketfactory.mfapi.enterprise.api.sbe.MessageHandler

onQuote(MessageHeaderDecoder, QuoteDecoder) - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

onQuoteCancel(MessageHeaderDecoder, QuoteCancelDecoder) - Method in interface com.marketfactory.mfapi.enterprise.api.CallbackHandler

onQuoteCancel(MessageHeaderDecoder, QuoteCancelDecoder) - Method in interface com.marketfactory.mfapi.enterprise.api.sbe.MessageHandler

onQuoteCancel(MessageHeaderDecoder, QuoteCancelDecoder) - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

onQuoteRequest(MessageHeaderDecoder, QuoteRequestDecoder) - Method in interface com.marketfactory.mfapi.enterprise.api.CallbackHandler

onQuoteRequest(MessageHeaderDecoder, QuoteRequestDecoder) - Method in interface com.marketfactory.mfapi.enterprise.api.sbe.MessageHandler

onQuoteRequest(MessageHeaderDecoder, QuoteRequestDecoder) - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

onQuoteResponse(MessageHeaderDecoder, QuoteResponseDecoder) - Method in interface com.marketfactory.mfapi.enterprise.api.CallbackHandler

onQuoteResponse(MessageHeaderDecoder, QuoteResponseDecoder) - Method in interface com.marketfactory.mfapi.enterprise.api.sbe.MessageHandler

onQuoteResponse(MessageHeaderDecoder, QuoteResponseDecoder) - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

onReadable() - Method in interface com.marketfactory.mfapi.enterprise.api.engine.EventHandler

Called when a connection has data to read

onReadable() - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

onReject(MessageHeaderDecoder, RejectDecoder) - Method in interface com.marketfactory.mfapi.enterprise.api.CallbackHandler

onReject(MessageHeaderDecoder, RejectDecoder) - Method in interface com.marketfactory.mfapi.enterprise.api.sbe.MessageHandler

onReject(MessageHeaderDecoder, RejectDecoder) - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

onReplayedMessage(MessageHeaderDecoder, ReplayedMessageDecoder) - Method in interface com.marketfactory.mfapi.enterprise.api.CallbackHandler

onReplayedMessage(MessageHeaderDecoder, ReplayedMessageDecoder) - Method in interface com.marketfactory.mfapi.enterprise.api.sbe.MessageHandler

onReplayedMessage(MessageHeaderDecoder, ReplayedMessageDecoder) - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

onReplayRequest(long, long) - Method in interface com.marketfactory.mfapi.enterprise.api.CallbackHandler

Must replay messages starting at the startSeqNum or, if a message or messages are not suitable for replay then a SequenceResetGapFillEncoder should be used to skip to the next replayable message or the targetSeqNum value.

onSecurityStatus(MessageHeaderDecoder, SecurityStatusDecoder) - Method in interface com.marketfactory.mfapi.enterprise.api.CallbackHandler

onSecurityStatus(MessageHeaderDecoder, SecurityStatusDecoder) - Method in interface com.marketfactory.mfapi.enterprise.api.sbe.MessageHandler

onSecurityStatus(MessageHeaderDecoder, SecurityStatusDecoder) - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

onSequenceResetGapFill(MessageHeaderDecoder, SequenceResetGapFillDecoder) - Method in interface com.marketfactory.mfapi.enterprise.api.sbe.MessageHandler

onSequenceResetGapFill(long, SequenceResetGapFillDecoder) - Method in class com.marketfactory.mfapi.enterprise.api.state.ServerToClientSyncState

onSequenceResetGapFill(MessageHeaderDecoder, SequenceResetGapFillDecoder) - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

onTestRequest(MessageHeaderDecoder, TestRequestDecoder) - Method in interface com.marketfactory.mfapi.enterprise.api.sbe.MessageHandler

onTestRequest(long, TestRequestDecoder) - Method in class com.marketfactory.mfapi.enterprise.api.state.EndOfSessionSyncState

onTestRequest(long, TestRequestDecoder) - Method in class com.marketfactory.mfapi.enterprise.api.state.ServerToClientSyncState

onTestRequest(MessageHeaderDecoder, TestRequestDecoder) - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

onTimer(long) - Method in interface com.marketfactory.mfapi.enterprise.api.engine.EventHandler

Called periodically to generate a stream of events that can be used to send heartbeats, detect dead connections, etc.

onTimer(long) - Method in class com.marketfactory.mfapi.enterprise.api.state.DisconnectingFromGatewayState

onTimer(long) - Method in class com.marketfactory.mfapi.enterprise.api.state.OfflineConnectingState

onTimer(long) - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

onUserNotification(MessageHeaderDecoder, UserNotificationDecoder) - Method in interface com.marketfactory.mfapi.enterprise.api.CallbackHandler

Passed through to client if they want the original messages.

onUserNotification(MessageHeaderDecoder, UserNotificationDecoder) - Method in interface com.marketfactory.mfapi.enterprise.api.sbe.MessageHandler

onUserNotification(long, UserNotificationDecoder) - Method in class com.marketfactory.mfapi.enterprise.api.state.DisconnectingFromGatewayState

onUserNotification(long, UserNotificationDecoder) - Method in class com.marketfactory.mfapi.enterprise.api.state.DisconnectingFromVenueState

onUserNotification(MessageHeaderDecoder, UserNotificationDecoder) - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

onVenueLogoff() - Method in interface com.marketfactory.mfapi.enterprise.api.CallbackHandler

Called after session has been successfully logged out of the venue.

onVenueLogon() - Method in interface com.marketfactory.mfapi.enterprise.api.CallbackHandler

Called after session has been logged into the venue.

onWritable() - Method in interface com.marketfactory.mfapi.enterprise.api.engine.EventHandler

Called when a connection can be written to.

onWritable() - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

openChannel(String, int) - Method in class com.marketfactory.mfapi.enterprise.api.connection.AbstractSocketChannelConnection

openChannel(String, int) - Method in class com.marketfactory.mfapi.enterprise.api.connection.SelectableConnection

P

populateCurrentMessageHeader(long, MessageEncoderFlyweight) - Method in interface com.marketfactory.mfapi.enterprise.api.sbe.EncoderProvider

Sets all the header values.

populateCurrentMessageHeader(long, MessageEncoderFlyweight) - Method in class com.marketfactory.mfapi.enterprise.api.sbe.SbeEncoderProvider

populateDecimalQtyNullEncoder(DecimalQtyNULLEncoder, long, int) - Static method in class com.marketfactory.mfapi.enterprise.api.sbe.SbeUtils

populateDecimalQtyNullEncoder(DecimalQtyNULLEncoder, BigDecimal) - Static method in class com.marketfactory.mfapi.enterprise.api.sbe.SbeUtils

Populates the provided DecimalQtyNULLEncoder (mantissa and exponent) from the provided BigDecimal quantity.

populateDecimalQtyNullEncoderWithNullValue(DecimalQtyNULLEncoder) - Static method in class com.marketfactory.mfapi.enterprise.api.sbe.SbeUtils

populatePriceNullEncoder(PriceNULLEncoder, long, int) - Static method in class com.marketfactory.mfapi.enterprise.api.sbe.SbeUtils

populatePriceNullEncoder(PriceNULLEncoder, BigDecimal) - Static method in class com.marketfactory.mfapi.enterprise.api.sbe.SbeUtils

Populates the provided PriceNULLEncoder (mantissa and exponent) from the provided BigDecimal price.

populatePriceNullEncoderWithNullValue(PriceNULLEncoder) - Static method in class com.marketfactory.mfapi.enterprise.api.sbe.SbeUtils

R

read() - Method in interface com.marketfactory.mfapi.enterprise.api.connection.ConnectionManager

read() - Method in class com.marketfactory.mfapi.enterprise.api.connection.SingleConnectionManager

read(MessageHandler) - Method in interface com.marketfactory.mfapi.enterprise.api.session.InternalSession

readInto(ByteBuffer) - Method in interface com.marketfactory.mfapi.enterprise.api.connection.Connection

Reads as many bytes from the input channel of this Connection into the provided ByteBuffer.

readInto(ByteBuffer) - Method in class com.marketfactory.mfapi.enterprise.api.connection.SelectableConnection

receiveBufferSizeHint - Variable in class com.marketfactory.mfapi.enterprise.api.connection.AbstractSocketChannelConnection

RECONNECTION_DELAY_MS - Static variable in class com.marketfactory.mfapi.enterprise.api.state.OfflineConnectingState

register(SocketChannel) - Method in interface com.marketfactory.mfapi.enterprise.api.connection.ChannelRegistry

register(SocketChannel, EventHandler) - Method in class com.marketfactory.mfapi.enterprise.api.engine.ChannelWorker

S

SbeDecoderProvider - Class in com.marketfactory.mfapi.enterprise.api.sbe

After reading bytes from the socket to the receiveByteBuffer ByteBuffer, this class will in order, - determines if are enough bytes for the next message header - from the message header determines if there are enough bytes available for the whole messages - from the message header determines which decoder to use and wraps the bytes - dispatch the header and message to the MessageHandler.

SbeDecoderProvider(ByteBuffer) - Constructor for class com.marketfactory.mfapi.enterprise.api.sbe.SbeDecoderProvider

SbeEncoderProvider - Class in com.marketfactory.mfapi.enterprise.api.sbe

Wraps the bytes (using the sendByteBuffer) with the requested MessageEncoderFlyweight subclass.

SbeEncoderProvider(ByteBuffer, Clock) - Constructor for class com.marketfactory.mfapi.enterprise.api.sbe.SbeEncoderProvider

SbeUtils - Class in com.marketfactory.mfapi.enterprise.api.sbe

Useful utilities for dealing with SBE messages.

SelectableConnection - Class in com.marketfactory.mfapi.enterprise.api.connection

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

SelectableConnection(int, int, ChannelRegistry) - Constructor for class com.marketfactory.mfapi.enterprise.api.connection.SelectableConnection

send(int) - Method in interface com.marketfactory.mfapi.enterprise.api.connection.ConnectionManager

send(int) - Method in class com.marketfactory.mfapi.enterprise.api.connection.SingleConnectionManager

sendApplicationMessageRequest(BiConsumer<Long, ApplicationMessageRequestEncoder>) - Method in interface com.marketfactory.mfapi.enterprise.api.Session

sendBufferSizeHint - Variable in class com.marketfactory.mfapi.enterprise.api.connection.AbstractSocketChannelConnection

sendExecutionAck(BiConsumer<Long, ExecutionAckEncoder>) - Method in interface com.marketfactory.mfapi.enterprise.api.Session

sendExecutionReport(BiConsumer<Long, ExecutionReportEncoder>) - Method in interface com.marketfactory.mfapi.enterprise.api.Session

sendHeartbeatMessage(String) - Method in interface com.marketfactory.mfapi.enterprise.api.session.InternalSession

sendHeartbeatMessage() - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

sendHeartbeatMessage() - Method in interface com.marketfactory.mfapi.enterprise.api.state.StateContext

sendLogonMessage(String) - Method in interface com.marketfactory.mfapi.enterprise.api.session.InternalSession

sendLogonMessage() - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

sendLogonMessage() - Method in interface com.marketfactory.mfapi.enterprise.api.state.StateContext

sendLogoutMessage(String) - Method in interface com.marketfactory.mfapi.enterprise.api.session.InternalSession

sendLogoutMessage(String) - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

sendLogoutMessage(String) - Method in interface com.marketfactory.mfapi.enterprise.api.state.StateContext

sendLogoutResponseMessage(String) - Method in interface com.marketfactory.mfapi.enterprise.api.Session

sendLogoutResponseMessage() - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

sendLogoutResponseMessage() - Method in interface com.marketfactory.mfapi.enterprise.api.state.StateContext

sendMarketDataRequest(BiConsumer<Long, MarketDataRequestEncoder>) - Method in interface com.marketfactory.mfapi.enterprise.api.Session

sendMassQuote(BiConsumer<Long, MassQuoteEncoder>) - Method in interface com.marketfactory.mfapi.enterprise.api.Session

sendMultilegOrderCancelReplaceRequest(BiConsumer<Long, MultilegOrderCancelReplaceRequestEncoder>) - Method in interface com.marketfactory.mfapi.enterprise.api.Session

sendNewOrderMultileg(BiConsumer<Long, NewOrderMultilegEncoder>) - Method in interface com.marketfactory.mfapi.enterprise.api.Session

sendOrderCancelReject(BiConsumer<Long, OrderCancelRejectEncoder>) - Method in interface com.marketfactory.mfapi.enterprise.api.Session

sendOrderCancelRequest(BiConsumer<Long, OrderCancelRequestEncoder>) - Method in interface com.marketfactory.mfapi.enterprise.api.Session

sendOrderTimeout(BiConsumer<Long, OrderTimeoutEncoder>) - Method in interface com.marketfactory.mfapi.enterprise.api.Session

sendQuote(BiConsumer<Long, QuoteEncoder>) - Method in interface com.marketfactory.mfapi.enterprise.api.Session

sendQuoteCancel(BiConsumer<Long, QuoteCancelEncoder>) - Method in interface com.marketfactory.mfapi.enterprise.api.Session

sendQuoteRequest(BiConsumer<Long, QuoteRequestEncoder>) - Method in interface com.marketfactory.mfapi.enterprise.api.Session

Sends the message.

sendQuoteResponse(BiConsumer<Long, QuoteResponseEncoder>) - Method in interface com.marketfactory.mfapi.enterprise.api.Session

sendSequenceResetGapFillMessage(long, long) - Method in interface com.marketfactory.mfapi.enterprise.api.Session

sendTestRequestMessage(String) - Method in interface com.marketfactory.mfapi.enterprise.api.session.InternalSession

sendTestRequestMessage(String) - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

sendTestRequestMessage(String) - Method in interface com.marketfactory.mfapi.enterprise.api.state.StateContext

sendTestRequestResponseMessage(String) - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

sendTestRequestResponseMessage(String) - Method in interface com.marketfactory.mfapi.enterprise.api.state.StateContext

sendUserRequestMessage(UserRequestType, String) - Method in interface com.marketfactory.mfapi.enterprise.api.Session

sendUserRequestMessage(UserRequestType, String) - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

sendUserRequestMessage(UserRequestType, String) - Method in interface com.marketfactory.mfapi.enterprise.api.state.StateContext

ServerToClientSyncState - Class in com.marketfactory.mfapi.enterprise.api.state

Represents state where the server needs to replay messages to us - the client.

ServerToClientSyncState(StateContext, long, long, boolean) - Constructor for class com.marketfactory.mfapi.enterprise.api.state.ServerToClientSyncState

Session - Interface in com.marketfactory.mfapi.enterprise.api

Primary interface for client code to interact with a venue.

SessionBuilder - Interface in com.marketfactory.mfapi.enterprise.api

Start here to create a SessionBuilder, populate the required information and build a Session.

SessionBuilderFactory - Class in com.marketfactory.mfapi.enterprise.api.session

SessionBuilderFactory() - Constructor for class com.marketfactory.mfapi.enterprise.api.session.SessionBuilderFactory

SessionStateContext - Class in com.marketfactory.mfapi.enterprise.api.state

SessionStateContext(CallbackHandler, NextExpectedMessageSequenceNumberStore, NextOutgoingMessageSequenceNumberStore, Clock, int) - Constructor for class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

set(long) - Method in interface com.marketfactory.mfapi.enterprise.api.NextExpectedMessageSequenceNumberStore

set(long) - Method in interface com.marketfactory.mfapi.enterprise.api.NextOutgoingMessageSequenceNumberStore

setBufferSizes(SocketChannel) - Method in class com.marketfactory.mfapi.enterprise.api.connection.AbstractSocketChannelConnection

setUncaughtExceptionHandler(Thread.UncaughtExceptionHandler) - Static method in class com.marketfactory.mfapi.enterprise.api.session.SessionBuilderFactory

SingleConnectionManager - Class in com.marketfactory.mfapi.enterprise.api.connection

Responsible for a single connection with a MF server.

SingleConnectionManager(String, int, String, Clock, Connection, BackPressureNotificationHandler, ByteBuffer, ByteBuffer) - Constructor for class com.marketfactory.mfapi.enterprise.api.connection.SingleConnectionManager

Construct

socketChannel - Variable in class com.marketfactory.mfapi.enterprise.api.connection.AbstractSocketChannelConnection

start() - Method in class com.marketfactory.mfapi.enterprise.api.engine.Engine

start() - Method in class com.marketfactory.mfapi.enterprise.api.engine.UserCommandWorker

StateContext - Interface in com.marketfactory.mfapi.enterprise.api.state

stop() - Method in class com.marketfactory.mfapi.enterprise.api.engine.Engine

stop() - Method in class com.marketfactory.mfapi.enterprise.api.engine.UserCommandWorker

SystemExitOnUnexpectedErrorHandler - Class in com.marketfactory.mfapi.enterprise.api.engine

SystemExitOnUnexpectedErrorHandler() - Constructor for class com.marketfactory.mfapi.enterprise.api.engine.SystemExitOnUnexpectedErrorHandler

T

TimerWorker - Class in com.marketfactory.mfapi.enterprise.api.engine

Responsible for generating and dispatching timer events to all registered EventHandlers Not thread safe; expects to be called by the thread that handles the events.

TimerWorker(Clock, EventHandler) - Constructor for class com.marketfactory.mfapi.enterprise.api.engine.TimerWorker

toString() - Method in class com.marketfactory.mfapi.enterprise.api.connection.SingleConnectionManager

toString() - Method in class com.marketfactory.mfapi.enterprise.api.state.SessionStateContext

U

uncaughtException(Thread, Throwable) - Method in class com.marketfactory.mfapi.enterprise.api.engine.SystemExitOnUnexpectedErrorHandler

UserCommandWorker - Class in com.marketfactory.mfapi.enterprise.api.engine

Responsible for handling User generated command events.

UserCommandWorker(EventHandler) - Constructor for class com.marketfactory.mfapi.enterprise.api.engine.UserCommandWorker

W

withBackPressureNotificationHandler(BackPressureNotificationHandler) - Method in interface com.marketfactory.mfapi.enterprise.api.SessionBuilder

Optional.

withCallbackHandler(CallbackHandler) - Method in interface com.marketfactory.mfapi.enterprise.api.SessionBuilder

Required.

withCredentials(String, String) - Method in interface com.marketfactory.mfapi.enterprise.api.SessionBuilder

Required.

withHeartbeatInterval(int) - Method in interface com.marketfactory.mfapi.enterprise.api.SessionBuilder

Optional.

withHost(String, int) - Method in interface com.marketfactory.mfapi.enterprise.api.SessionBuilder

Required.

withNextExpectedMessageSequenceNumberStore(NextExpectedMessageSequenceNumberStore) - Method in interface com.marketfactory.mfapi.enterprise.api.SessionBuilder

Required.

withNextOutgoingMessageSequenceNumberStore(NextOutgoingMessageSequenceNumberStore) - Method in interface com.marketfactory.mfapi.enterprise.api.SessionBuilder

Required.

withResetSeqNum(boolean) - Method in interface com.marketfactory.mfapi.enterprise.api.SessionBuilder

Optional.

withTcpReceiveBufferSizeHint(int) - Method in interface com.marketfactory.mfapi.enterprise.api.SessionBuilder

Optional.

withTcpSendBufferSizeHint(int) - Method in interface com.marketfactory.mfapi.enterprise.api.SessionBuilder

Optional.

withVenue(String, SessionType) - Method in interface com.marketfactory.mfapi.enterprise.api.SessionBuilder

Required.

Worker - Interface in com.marketfactory.mfapi.enterprise.api.engine

General interface for doing work.

writeFrom(ByteBuffer) - Method in class com.marketfactory.mfapi.enterprise.api.connection.AbstractSocketChannelConnection

writeFrom(ByteBuffer) - Method in interface com.marketfactory.mfapi.enterprise.api.connection.Connection

Writes as many bytes from the byteBuffer to the output channel of this Connection.

writeFrom(ByteBuffer) - Method in class com.marketfactory.mfapi.enterprise.api.connection.SelectableConnection

writePending() - Method in interface com.marketfactory.mfapi.enterprise.api.session.InternalSession

writePendingBytes() - Method in interface com.marketfactory.mfapi.enterprise.api.connection.ConnectionManager

writePendingBytes() - Method in class com.marketfactory.mfapi.enterprise.api.connection.SingleConnectionManager

A B C D E G H I L M N O P R S T U W