public class ServerToClientSynchronizationState
extends java.lang.Object
- disconnects if unexpected message is received - forwards all other messages to the client - checks and increments sequence numbers as needed
| Modifier and Type | Field and Description |
|---|---|
protected CallbackHandler |
callbackHandler |
protected CoreSession |
coreSession |
protected InternalSession |
session |
protected StateContext |
stateContext |
| 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() |
protected final InternalSession session
protected final CoreSession coreSession
protected final StateContext stateContext
protected final CallbackHandler callbackHandler
public void onEnter()
public void performActions()
public void onTestRequest(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
com.marketfactory.protocol.sbe4.TestRequestDecoder message)
onTestRequest in interface MessageHandlerpublic void onSequenceGapFill(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
com.marketfactory.protocol.sbe4.SequenceResetGapFillDecoder message)
onSequenceGapFill in interface MessageHandlerpublic void initiateLogout(java.lang.String reason)
initiateLogout in interface Statepublic void initiateLogon()
initiateLogon in interface Statepublic void disconnect()
disconnect in interface Statepublic void onUserNotification(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
com.marketfactory.protocol.sbe4.UserNotificationDecoder message)
onUserNotification in interface MessageHandlerpublic void onMassQuote(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
com.marketfactory.protocol.sbe4.MassQuoteDecoder message)
onMassQuote in interface MessageHandlerpublic void onQuoteResponse(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
com.marketfactory.protocol.sbe4.QuoteResponseDecoder message)
onQuoteResponse in interface MessageHandlerpublic void onOrderCancelReject(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
com.marketfactory.protocol.sbe4.OrderCancelRejectDecoder message)
onOrderCancelReject in interface MessageHandlerpublic void onErrorReport(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
com.marketfactory.protocol.sbe4.ErrorReportDecoder message)
onErrorReport in interface MessageHandlerpublic void onOrderTimeout(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
com.marketfactory.protocol.sbe4.OrderTimeoutDecoder mesage)
onOrderTimeout in interface MessageHandlerpublic void onExecutionReport(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
com.marketfactory.protocol.sbe4.ExecutionReportDecoder mesasge)
onExecutionReport in interface MessageHandlerpublic void onExecutionAck(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
com.marketfactory.protocol.sbe4.ExecutionAckDecoder message)
onExecutionAck in interface MessageHandlerpublic void onQuote(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
com.marketfactory.protocol.sbe4.QuoteDecoder message)
onQuote in interface MessageHandlerpublic void onSecurityStatus(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
com.marketfactory.protocol.sbe4.SecurityStatusDecoder message)
onSecurityStatus in interface MessageHandlerpublic void onMarketDataRequestReject(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
com.marketfactory.protocol.sbe4.MarketDataRequestRejectDecoder message)
onMarketDataRequestReject in interface MessageHandlerpublic void onMarketDataIncrementalRefresh(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
com.marketfactory.protocol.sbe4.MarketDataIncrementalRefreshDecoder message)
onMarketDataIncrementalRefresh in interface MessageHandlerpublic void onQuoteRequest(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
com.marketfactory.protocol.sbe4.QuoteRequestDecoder message)
onQuoteRequest in interface MessageHandlerpublic void onNewOrderMultileg(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
com.marketfactory.protocol.sbe4.NewOrderMultilegDecoder message)
onNewOrderMultileg in interface MessageHandlerpublic void onQuoteCancel(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
com.marketfactory.protocol.sbe4.QuoteCancelDecoder message)
onQuoteCancel in interface MessageHandlerpublic void onLogout(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
com.marketfactory.protocol.sbe4.LogoutDecoder message)
onLogout in interface MessageHandlerpublic void onReject(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
com.marketfactory.protocol.sbe4.RejectDecoder message)
onReject in interface MessageHandlerpublic void onBusinessMessageReject(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
com.marketfactory.protocol.sbe4.BusinessMessageRejectDecoder message)
onBusinessMessageReject in interface MessageHandlerpublic void onLogoutResponse(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
com.marketfactory.protocol.sbe4.LogoutResponseDecoder message)
onLogoutResponse in interface MessageHandlerpublic void onEndMarker(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
com.marketfactory.protocol.sbe4.EndMarkerDecoder message)
onEndMarker in interface MessageHandlerpublic void onReplayedMessage(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
com.marketfactory.protocol.sbe4.ReplayedMessageDecoder message)
onReplayedMessage in interface MessageHandlerpublic void onApplicationMessageReport(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
com.marketfactory.protocol.sbe4.ApplicationMessageReportDecoder message)
onApplicationMessageReport in interface MessageHandlerpublic void onLogonResponse(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
com.marketfactory.protocol.sbe4.LogonResponseDecoder message)
onLogonResponse in interface MessageHandlerpublic void onHeartbeat(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
com.marketfactory.protocol.sbe4.HeartbeatDecoder message)
onHeartbeat in interface MessageHandler