public interface StateContext
void disconnect()
void connect()
boolean isReplaySession()
void moveToEndOfSessionSyncState()
void moveToServerToClientSyncState(long serverNextExpectedMsgSeqNum,
long serverLogonResponseMsgSeqNum,
boolean requiresClientToServerSynchronization)
void moveToClientToServerSyncState(long serverNextExpectedMsgSeqNum)
void moveToLoggingOnState()
void moveToOfflineConnectingState()
void moveToOfflineWaitingState()
void moveToLoggedOnToGatewayState()
void moveToLoggedOnToVenueState()
void moveToDisconnectingFromGatewayState()
void moveToDisconnectingFromVenueState()
long getNextExpectedMsgSeqNum()
void assertAndSetNextExpectedSequenceNumber(long expected,
long newValue)
throws java.lang.IllegalStateException
java.lang.IllegalStateExceptionvoid assertAndAddOneToNextExpectedSequenceNumber(long expected)
throws java.lang.IllegalStateException
expected - value the current next expected sequence number should be.java.lang.IllegalStateException - if the current next expected sequence number is not equal to the parameter value.long getNextOutgoingSequenceNumber()
long getCurrentTimeMs()
void sendHeartbeatMessage()
void sendTestRequestMessage(java.lang.String testReqID)
void sendTestRequestResponseMessage(java.lang.String testReqID)
void notifyClientMarketFactoryLogOn()
void notifyClientMarketFactoryLogOff()
void notifyClientVenueLogon()
void notifyClientVenueLogoff()
void notifyClientReplayRequest(long initialSeqNum,
long targetSeqNum)
void notifyClientLogoffRequest()
void sendLogonMessage()
void sendUserRequestMessage(com.marketfactory.protocol.sbe4.UserRequestType userRequestType,
java.lang.String reason)
void sendLogoutMessage(java.lang.String reason)
void sendLogoutResponseMessage()
long getLastSentTimestamp()
long getLastReceivedTimestamp()