com.marketfactory.mfapi.enterprise.api.protocol.states

Class SimpleStateContext

java.lang.Object

com.marketfactory.mfapi.enterprise.api.protocol.states.SimpleStateContext

All Implemented Interfaces:

MessageHandler, StateContext

public class SimpleStateContext
extends java.lang.Object
implements StateContext, MessageHandler

Constructor Summary

Constructors

Constructor and Description
SimpleStateContext(CallbackHandler clientMessageHandler, NextExpectedMessageSequenceNumberStore inputSequenceStore, NextOutgoingMessageSequenceNumberStore nextOutgoingMessageSequenceNumberStore, java.time.Clock clock, CoreSession coreSession, int heartbeatIntervalSeconds, int maxTxnSeconds) Constructor

Method Summary

Modifier and Type	Method and Description
void	assertAndAddOneToNextExpectedSequenceNumber(long expected) Asserts the current next expected sequence number is equal to the parameter.
void	assertAndSetNextExpectedSequenceNumber(long expected, long newValue)
void	disconnect()
java.lang.String	getCurrentStateName()
long	getNextExpectedMsgSeqNum()
long	getNextOutgoingSequenceNumber()
long	getServerLogonResponseSequenceNumber()
void	init(InternalSession internalSession)
void	initiateLogon()
void	initiateLogout(java.lang.String reason)
void	moveToClientToServerSynchronizationState()
void	moveToConnectedToGatewayState(boolean initialConnect)
void	moveToConnectedToVenueState()
void	moveToDisconnectedState()
void	moveToEndOfSessionSyncState()
void	moveToLoggingOffState()
void	moveToLogonState()
void	moveToServerToClientSyncState()
void	onApplicationMessageReport(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader, com.marketfactory.protocol.sbe4.ApplicationMessageReportDecoder applicationMessageReport)
void	onBusinessMessageReject(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader, com.marketfactory.protocol.sbe4.BusinessMessageRejectDecoder businessMessageReject)
void	onEndMarker(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader, com.marketfactory.protocol.sbe4.EndMarkerDecoder endMarker)
void	onErrorReport(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader, com.marketfactory.protocol.sbe4.ErrorReportDecoder errorReport)
void	onExecutionAck(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader, com.marketfactory.protocol.sbe4.ExecutionAckDecoder executionAck)
void	onExecutionReport(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader, com.marketfactory.protocol.sbe4.ExecutionReportDecoder executionReport)
void	onHeartbeat(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader, com.marketfactory.protocol.sbe4.HeartbeatDecoder heartbeat)
void	onLogonResponse(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader, com.marketfactory.protocol.sbe4.LogonResponseDecoder logonResponse)
void	onLogout(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader, com.marketfactory.protocol.sbe4.LogoutDecoder logout)
void	onLogoutResponse(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader, com.marketfactory.protocol.sbe4.LogoutResponseDecoder logoutResponse)
void	onMarketDataIncrementalRefresh(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader, com.marketfactory.protocol.sbe4.MarketDataIncrementalRefreshDecoder marketDataIncrementalRefresh)
void	onMarketDataRequestReject(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader, com.marketfactory.protocol.sbe4.MarketDataRequestRejectDecoder marketDataRequestReject)
void	onMassQuote(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader, com.marketfactory.protocol.sbe4.MassQuoteDecoder massQuote)
void	onNewOrderMultileg(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader, com.marketfactory.protocol.sbe4.NewOrderMultilegDecoder newOrderMultileg)
void	onOrderCancelReject(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader, com.marketfactory.protocol.sbe4.OrderCancelRejectDecoder orderCancelReject)
void	onOrderTimeout(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader, com.marketfactory.protocol.sbe4.OrderTimeoutDecoder orderTimeout)
void	onQuote(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader, com.marketfactory.protocol.sbe4.QuoteDecoder quote)
void	onQuoteCancel(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader, com.marketfactory.protocol.sbe4.QuoteCancelDecoder quoteCancel)
void	onQuoteRequest(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader, com.marketfactory.protocol.sbe4.QuoteRequestDecoder quoteRequest)
void	onQuoteResponse(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader, com.marketfactory.protocol.sbe4.QuoteResponseDecoder quoteResponse)
void	onReject(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader, com.marketfactory.protocol.sbe4.RejectDecoder reject)
void	onReplayedMessage(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader, com.marketfactory.protocol.sbe4.ReplayedMessageDecoder replayedMessage)
void	onSecurityStatus(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader, com.marketfactory.protocol.sbe4.SecurityStatusDecoder securityStatus)
void	onSequenceGapFill(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader, com.marketfactory.protocol.sbe4.SequenceResetGapFillDecoder sequenceResetGapFill)
void	onTestRequest(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader, com.marketfactory.protocol.sbe4.TestRequestDecoder testRequest)
void	onUserNotification(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader, com.marketfactory.protocol.sbe4.UserNotificationDecoder userNotification)
void	performActions()
boolean	requiresClientToReplayMessage()
boolean	requiresServerToReplayMessages()
void	setDeadConnectionDetector(DeadConnectionDetector deadConnectionDetector)
void	setHeartbeatGenerator(HeartbeatGenerator heartbeatGenerator)
void	setServerData(long serversSequenceNumber, long serversNextExpectedSeqNum)
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

SimpleStateContext

public SimpleStateContext(CallbackHandler clientMessageHandler,
                          NextExpectedMessageSequenceNumberStore inputSequenceStore,
                          NextOutgoingMessageSequenceNumberStore nextOutgoingMessageSequenceNumberStore,
                          java.time.Clock clock,
                          CoreSession coreSession,
                          int heartbeatIntervalSeconds,
                          int maxTxnSeconds)

Constructor

Parameters:

clientMessageHandler - handler

inputSequenceStore - inputStore

nextOutgoingMessageSequenceNumberStore - outgoing message store

clock - time source

coreSession - session

heartbeatIntervalSeconds - interval to send heartbeats at (in seconds)

maxTxnSeconds - maximum time to wait for messages (in seconds)

Method Detail

init

public void init(InternalSession internalSession)

setHeartbeatGenerator

public void setHeartbeatGenerator(HeartbeatGenerator heartbeatGenerator)

setDeadConnectionDetector

public void setDeadConnectionDetector(DeadConnectionDetector deadConnectionDetector)

moveToEndOfSessionSyncState

public void moveToEndOfSessionSyncState()

Specified by:

moveToEndOfSessionSyncState in interface StateContext

moveToConnectedToGatewayState

public void moveToConnectedToGatewayState(boolean initialConnect)

Specified by:

moveToConnectedToGatewayState in interface StateContext

moveToConnectedToVenueState

public void moveToConnectedToVenueState()

Specified by:

moveToConnectedToVenueState in interface StateContext

moveToServerToClientSyncState

public void moveToServerToClientSyncState()

Specified by:

moveToServerToClientSyncState in interface StateContext

performActions

public void performActions()

Specified by:

performActions in interface StateContext

setServerData

public void setServerData(long serversSequenceNumber,
                          long serversNextExpectedSeqNum)

Specified by:

setServerData in interface StateContext

getServerLogonResponseSequenceNumber

public long getServerLogonResponseSequenceNumber()

Specified by:

getServerLogonResponseSequenceNumber in interface StateContext

moveToClientToServerSynchronizationState

public void moveToClientToServerSynchronizationState()

Specified by:

moveToClientToServerSynchronizationState in interface StateContext

getNextExpectedMsgSeqNum

public long getNextExpectedMsgSeqNum()

Specified by:

getNextExpectedMsgSeqNum in interface StateContext

moveToDisconnectedState

public void moveToDisconnectedState()

Specified by:

moveToDisconnectedState in interface StateContext

moveToLogonState

public void moveToLogonState()

Specified by:

moveToLogonState in interface StateContext

assertAndSetNextExpectedSequenceNumber

public void assertAndSetNextExpectedSequenceNumber(long expected,
                                                   long newValue)
                                            throws java.lang.IllegalStateException

Specified by:

assertAndSetNextExpectedSequenceNumber in interface StateContext

Throws:

java.lang.IllegalStateException

assertAndAddOneToNextExpectedSequenceNumber

public void assertAndAddOneToNextExpectedSequenceNumber(long expected)
                                                 throws java.lang.IllegalStateException

Description copied from interface: StateContext

Asserts the current next expected sequence number is equal to the parameter. If it is, the next expected sequence number is incremented by one. If it's not equal then a message has been missed and an IllegalStateException is thrown.

Specified by:

assertAndAddOneToNextExpectedSequenceNumber in interface StateContext

Parameters:

expected - value the current next expected sequence number should be.

Throws:

java.lang.IllegalStateException - if the current next expected sequence number is not equal to the parameter value.

getNextOutgoingSequenceNumber

public long getNextOutgoingSequenceNumber()

Specified by:

getNextOutgoingSequenceNumber in interface StateContext

requiresServerToReplayMessages

public boolean requiresServerToReplayMessages()

Specified by:

requiresServerToReplayMessages in interface StateContext

requiresClientToReplayMessage

public boolean requiresClientToReplayMessage()

Specified by:

requiresClientToReplayMessage in interface StateContext

initiateLogout

public void initiateLogout(java.lang.String reason)

Specified by:

initiateLogout in interface StateContext

initiateLogon

public void initiateLogon()

Specified by:

initiateLogon in interface StateContext

getCurrentStateName

public java.lang.String getCurrentStateName()

Specified by:

getCurrentStateName in interface StateContext

disconnect

public void disconnect()

Specified by:

disconnect in interface StateContext

moveToLoggingOffState

public void moveToLoggingOffState()

Specified by:

moveToLoggingOffState in interface StateContext

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

onLogonResponse

public void onLogonResponse(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
                            com.marketfactory.protocol.sbe4.LogonResponseDecoder logonResponse)

Specified by:

onLogonResponse in interface MessageHandler

onLogout

public void onLogout(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
                     com.marketfactory.protocol.sbe4.LogoutDecoder logout)

Specified by:

onLogout in interface MessageHandler

onLogoutResponse

public void onLogoutResponse(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
                             com.marketfactory.protocol.sbe4.LogoutResponseDecoder logoutResponse)

Specified by:

onLogoutResponse in interface MessageHandler

onSequenceGapFill

public void onSequenceGapFill(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
                              com.marketfactory.protocol.sbe4.SequenceResetGapFillDecoder sequenceResetGapFill)

Specified by:

onSequenceGapFill in interface MessageHandler

onHeartbeat

public void onHeartbeat(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
                        com.marketfactory.protocol.sbe4.HeartbeatDecoder heartbeat)

Specified by:

onHeartbeat in interface MessageHandler

onTestRequest

public void onTestRequest(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
                          com.marketfactory.protocol.sbe4.TestRequestDecoder testRequest)

Specified by:

onTestRequest in interface MessageHandler

onUserNotification

public void onUserNotification(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
                               com.marketfactory.protocol.sbe4.UserNotificationDecoder userNotification)

Specified by:

onUserNotification in interface MessageHandler

onMassQuote

public void onMassQuote(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
                        com.marketfactory.protocol.sbe4.MassQuoteDecoder massQuote)

Specified by:

onMassQuote in interface MessageHandler

onErrorReport

public void onErrorReport(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
                          com.marketfactory.protocol.sbe4.ErrorReportDecoder errorReport)

Specified by:

onErrorReport in interface MessageHandler

onQuoteResponse

public void onQuoteResponse(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
                            com.marketfactory.protocol.sbe4.QuoteResponseDecoder quoteResponse)

Specified by:

onQuoteResponse in interface MessageHandler

onOrderCancelReject

public void onOrderCancelReject(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
                                com.marketfactory.protocol.sbe4.OrderCancelRejectDecoder orderCancelReject)

Specified by:

onOrderCancelReject in interface MessageHandler

onOrderTimeout

public void onOrderTimeout(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
                           com.marketfactory.protocol.sbe4.OrderTimeoutDecoder orderTimeout)

Specified by:

onOrderTimeout in interface MessageHandler

onExecutionReport

public void onExecutionReport(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
                              com.marketfactory.protocol.sbe4.ExecutionReportDecoder executionReport)

Specified by:

onExecutionReport in interface MessageHandler

onExecutionAck

public void onExecutionAck(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
                           com.marketfactory.protocol.sbe4.ExecutionAckDecoder executionAck)

Specified by:

onExecutionAck in interface MessageHandler

onQuote

public void onQuote(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
                    com.marketfactory.protocol.sbe4.QuoteDecoder quote)

Specified by:

onQuote in interface MessageHandler

onSecurityStatus

public void onSecurityStatus(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
                             com.marketfactory.protocol.sbe4.SecurityStatusDecoder securityStatus)

Specified by:

onSecurityStatus in interface MessageHandler

onMarketDataRequestReject

public void onMarketDataRequestReject(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
                                      com.marketfactory.protocol.sbe4.MarketDataRequestRejectDecoder marketDataRequestReject)

Specified by:

onMarketDataRequestReject in interface MessageHandler

onMarketDataIncrementalRefresh

public void onMarketDataIncrementalRefresh(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
                                           com.marketfactory.protocol.sbe4.MarketDataIncrementalRefreshDecoder marketDataIncrementalRefresh)

Specified by:

onMarketDataIncrementalRefresh in interface MessageHandler

onQuoteRequest

public void onQuoteRequest(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
                           com.marketfactory.protocol.sbe4.QuoteRequestDecoder quoteRequest)

Specified by:

onQuoteRequest in interface MessageHandler

onNewOrderMultileg

public void onNewOrderMultileg(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
                               com.marketfactory.protocol.sbe4.NewOrderMultilegDecoder newOrderMultileg)

Specified by:

onNewOrderMultileg in interface MessageHandler

onQuoteCancel

public void onQuoteCancel(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
                          com.marketfactory.protocol.sbe4.QuoteCancelDecoder quoteCancel)

Specified by:

onQuoteCancel in interface MessageHandler

onEndMarker

public void onEndMarker(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
                        com.marketfactory.protocol.sbe4.EndMarkerDecoder endMarker)

Specified by:

onEndMarker in interface MessageHandler

onReject

public void onReject(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
                     com.marketfactory.protocol.sbe4.RejectDecoder reject)

Specified by:

onReject in interface MessageHandler

onBusinessMessageReject

public void onBusinessMessageReject(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
                                    com.marketfactory.protocol.sbe4.BusinessMessageRejectDecoder businessMessageReject)

Specified by:

onBusinessMessageReject in interface MessageHandler

onReplayedMessage

public void onReplayedMessage(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
                              com.marketfactory.protocol.sbe4.ReplayedMessageDecoder replayedMessage)

Specified by:

onReplayedMessage in interface MessageHandler

onApplicationMessageReport

public void onApplicationMessageReport(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
                                       com.marketfactory.protocol.sbe4.ApplicationMessageReportDecoder applicationMessageReport)

Specified by:

onApplicationMessageReport in interface MessageHandler