public interface CallbackHandler
| Modifier and Type | Method and Description |
|---|---|
default void |
handleUnexpectedMessage(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
org.agrona.sbe.MessageDecoderFlyweight message)
Override this if you want to change the unexpected method handling.
|
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) |
default void |
onLogout(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
com.marketfactory.protocol.sbe4.LogoutDecoder logout)
Passed through to client if they want the original messages.
|
void |
onLogoutRequest()
Server has requested client logout.
|
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) |
default void |
onMarketFactoryLogOff()
Called after session has been logged out and disconnected from the MarketFactory Server.
|
default void |
onMarketFactoryLogOn()
Called after connection and synchronization is complete to MarketFactory Server.
|
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 |
onReplayRequest(long startSeqNum,
long targetSeqNum)
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. |
void |
onSecurityStatus(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
com.marketfactory.protocol.sbe4.SecurityStatusDecoder securityStatus) |
default void |
onUserNotification(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
com.marketfactory.protocol.sbe4.UserNotificationDecoder userNotification)
Passed through to client if they want the original messages.
|
default void |
onVenueLogoff()
Called after session has been successfully logged out of the venue.
|
default void |
onVenueLogon()
Called after session has been logged into the venue.
|
default void onMarketFactoryLogOn()
default void onMarketFactoryLogOff()
default void onVenueLogon()
default void onVenueLogoff()
default void onUserNotification(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
com.marketfactory.protocol.sbe4.UserNotificationDecoder userNotification)
default void onLogout(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
com.marketfactory.protocol.sbe4.LogoutDecoder logout)
void onReplayRequest(long startSeqNum,
long targetSeqNum)
SequenceResetGapFillEncoder should be used to skip to the next replayable message or the
targetSeqNum value.
startSeqNum - the sequence number to start replaying fromtargetSeqNum - the sequence number the last sent SequenceResetGapFill newSeqNo should be set tovoid onLogoutRequest()
default void handleUnexpectedMessage(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
org.agrona.sbe.MessageDecoderFlyweight message)
messageHeader - message header of unexpected messagemessage - the unexpected messagevoid onMassQuote(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
com.marketfactory.protocol.sbe4.MassQuoteDecoder massQuote)
void onErrorReport(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
com.marketfactory.protocol.sbe4.ErrorReportDecoder errorReport)
void onQuoteResponse(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
com.marketfactory.protocol.sbe4.QuoteResponseDecoder quoteResponse)
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 onExecutionReport(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
com.marketfactory.protocol.sbe4.ExecutionReportDecoder executionReport)
void onExecutionAck(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
com.marketfactory.protocol.sbe4.ExecutionAckDecoder executionAck)
void onQuote(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
com.marketfactory.protocol.sbe4.QuoteDecoder quote)
void onSecurityStatus(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
com.marketfactory.protocol.sbe4.SecurityStatusDecoder securityStatus)
void onMarketDataRequestReject(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
com.marketfactory.protocol.sbe4.MarketDataRequestRejectDecoder marketDataRequestReject)
void onMarketDataIncrementalRefresh(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
com.marketfactory.protocol.sbe4.MarketDataIncrementalRefreshDecoder marketDataIncrementalRefresh)
void onQuoteRequest(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
com.marketfactory.protocol.sbe4.QuoteRequestDecoder quoteRequest)
void onNewOrderMultileg(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
com.marketfactory.protocol.sbe4.NewOrderMultilegDecoder newOrderMultileg)
void onQuoteCancel(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
com.marketfactory.protocol.sbe4.QuoteCancelDecoder quoteCancel)
void onEndMarker(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
com.marketfactory.protocol.sbe4.EndMarkerDecoder endMarker)
void onReject(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
com.marketfactory.protocol.sbe4.RejectDecoder reject)
void onBusinessMessageReject(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
com.marketfactory.protocol.sbe4.BusinessMessageRejectDecoder businessMessageReject)
void onReplayedMessage(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
com.marketfactory.protocol.sbe4.ReplayedMessageDecoder replayedMessage)
void onApplicationMessageReport(com.marketfactory.protocol.sbe4.MessageHeaderDecoder messageHeader,
com.marketfactory.protocol.sbe4.ApplicationMessageReportDecoder applicationMessageReport)