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

Class ServerToClientSynchronizationState

java.lang.Object

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

All Implemented Interfaces:

MessageHandler, State

public class ServerToClientSynchronizationState
extends java.lang.Object

Server is sending messages to us. Need to process the messages. The client is caught up when it's next expected sequence number matches what the server sends. To indicate this stage is complete the server will send a TestRequest to which we need to send a response.

- disconnects if unexpected message is received - forwards all other messages to the client - checks and increments sequence numbers as needed

Field Summary

Fields

Modifier and Type	Field and Description
protected CallbackHandler	callbackHandler
protected CoreSession	coreSession
protected InternalSession	session
protected StateContext	stateContext

Method Summary

Modifier and Type	Method and Description
void	disconnect()
void	initiateLogon()
void	initiateLogout(java.lang.String reason)
void	onApplicationMessageReport(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader, com.marketfactory.protocol.sbe4.ApplicationMessageReportDecoder message)
void	onBusinessMessageReject(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader, com.marketfactory.protocol.sbe4.BusinessMessageRejectDecoder message)
void	onEndMarker(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader, com.marketfactory.protocol.sbe4.EndMarkerDecoder message)
void	onEnter() Should only enter this state if and only if there is something to sync.
void	onErrorReport(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader, com.marketfactory.protocol.sbe4.ErrorReportDecoder message)
void	onExecutionAck(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader, com.marketfactory.protocol.sbe4.ExecutionAckDecoder message)
void	onExecutionReport(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader, com.marketfactory.protocol.sbe4.ExecutionReportDecoder mesasge)
void	onHeartbeat(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader, com.marketfactory.protocol.sbe4.HeartbeatDecoder message)
void	onLogonResponse(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader, com.marketfactory.protocol.sbe4.LogonResponseDecoder message)
void	onLogout(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader, com.marketfactory.protocol.sbe4.LogoutDecoder message)
void	onLogoutResponse(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader, com.marketfactory.protocol.sbe4.LogoutResponseDecoder message)
void	onMarketDataIncrementalRefresh(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader, com.marketfactory.protocol.sbe4.MarketDataIncrementalRefreshDecoder message)
void	onMarketDataRequestReject(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader, com.marketfactory.protocol.sbe4.MarketDataRequestRejectDecoder message)
void	onMassQuote(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader, com.marketfactory.protocol.sbe4.MassQuoteDecoder message)
void	onNewOrderMultileg(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader, com.marketfactory.protocol.sbe4.NewOrderMultilegDecoder message)
void	onOrderCancelReject(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader, com.marketfactory.protocol.sbe4.OrderCancelRejectDecoder message)
void	onOrderTimeout(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader, com.marketfactory.protocol.sbe4.OrderTimeoutDecoder mesage)
void	onQuote(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader, com.marketfactory.protocol.sbe4.QuoteDecoder message)
void	onQuoteCancel(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader, com.marketfactory.protocol.sbe4.QuoteCancelDecoder message)
void	onQuoteRequest(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader, com.marketfactory.protocol.sbe4.QuoteRequestDecoder message)
void	onQuoteResponse(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader, com.marketfactory.protocol.sbe4.QuoteResponseDecoder message)
void	onReject(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader, com.marketfactory.protocol.sbe4.RejectDecoder message)
void	onReplayedMessage(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader, com.marketfactory.protocol.sbe4.ReplayedMessageDecoder message)
void	onSecurityStatus(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader, com.marketfactory.protocol.sbe4.SecurityStatusDecoder message)
void	onSequenceGapFill(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader, com.marketfactory.protocol.sbe4.SequenceResetGapFillDecoder message)
void	onTestRequest(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader, com.marketfactory.protocol.sbe4.TestRequestDecoder message)
void	onUserNotification(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader, com.marketfactory.protocol.sbe4.UserNotificationDecoder message)
void	performActions()

Methods inherited from class java.lang.Object

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

Field Detail

session

protected final InternalSession session

coreSession

protected final CoreSession coreSession

stateContext

protected final StateContext stateContext

callbackHandler

protected final CallbackHandler callbackHandler

Method Detail

onEnter

public void onEnter()

Should only enter this state if and only if there is something to sync.

Specified by:

onEnter in interface State

performActions

public void performActions()

onTestRequest

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

Specified by:

onTestRequest in interface MessageHandler

onSequenceGapFill

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

Specified by:

onSequenceGapFill in interface MessageHandler

initiateLogout

public void initiateLogout(java.lang.String reason)

Specified by:

initiateLogout in interface State

initiateLogon

public void initiateLogon()

Specified by:

initiateLogon in interface State

disconnect

public void disconnect()

Specified by:

disconnect in interface State

onUserNotification

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

Specified by:

onUserNotification in interface MessageHandler

onMassQuote

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

Specified by:

onMassQuote in interface MessageHandler

onQuoteResponse

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

Specified by:

onQuoteResponse in interface MessageHandler

onOrderCancelReject

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

Specified by:

onOrderCancelReject in interface MessageHandler

onErrorReport

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

Specified by:

onErrorReport in interface MessageHandler

onOrderTimeout

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

Specified by:

onOrderTimeout in interface MessageHandler

onExecutionReport

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

Specified by:

onExecutionReport in interface MessageHandler

onExecutionAck

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

Specified by:

onExecutionAck in interface MessageHandler

onQuote

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

Specified by:

onQuote in interface MessageHandler

onSecurityStatus

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

Specified by:

onSecurityStatus in interface MessageHandler

onMarketDataRequestReject

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

Specified by:

onMarketDataRequestReject in interface MessageHandler

onMarketDataIncrementalRefresh

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

Specified by:

onMarketDataIncrementalRefresh in interface MessageHandler

onQuoteRequest

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

Specified by:

onQuoteRequest in interface MessageHandler

onNewOrderMultileg

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

Specified by:

onNewOrderMultileg in interface MessageHandler

onQuoteCancel

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

Specified by:

onQuoteCancel in interface MessageHandler

onLogout

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

Specified by:

onLogout in interface MessageHandler

onReject

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

Specified by:

onReject in interface MessageHandler

onBusinessMessageReject

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

Specified by:

onBusinessMessageReject in interface MessageHandler

onLogoutResponse

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

Specified by:

onLogoutResponse in interface MessageHandler

onEndMarker

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

Specified by:

onEndMarker in interface MessageHandler

onReplayedMessage

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

Specified by:

onReplayedMessage in interface MessageHandler

onApplicationMessageReport

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

Specified by:

onApplicationMessageReport in interface MessageHandler

onLogonResponse

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

Specified by:

onLogonResponse in interface MessageHandler

onHeartbeat

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

Specified by:

onHeartbeat in interface MessageHandler