com.marketfactory.mfapi.enterprise.api.sbe

Class SbeEncoderProvider

java.lang.Object

com.marketfactory.mfapi.enterprise.api.sbe.SbeEncoderProvider

All Implemented Interfaces:

EncoderProvider

public class SbeEncoderProvider
extends java.lang.Object
implements EncoderProvider

Wraps the bytes (using the sendByteBuffer) with the requested MessageEncoderFlyweight subclass. Space for the message header is given. After the client uses the message encoder, the populateCurrentMessageHeader(long, MessageEncoderFlyweight) method MUST be called to populate the header fields. This is done AFTER the message is completely written because the messageLength value is only known at that point - i.e. the encoder.encodedLength() will return the length of the message including repeating groups and variable length text fields.

Constructor Summary

Constructors

Constructor and Description
SbeEncoderProvider(java.nio.ByteBuffer sendByteBuffer, java.time.Clock clock)

Method Summary

Modifier and Type	Method and Description
com.marketfactory.protocol.sbe4.ApplicationMessageRequestEncoder	getApplicationMessageRequestEncoder()
com.marketfactory.protocol.sbe4.ExecutionAckEncoder	getExecutionAckEncoder()
com.marketfactory.protocol.sbe4.ExecutionReportEncoder	getExecutionReportEncoder()
com.marketfactory.protocol.sbe4.HeartbeatEncoder	getHeartbeatEncoder()
com.marketfactory.protocol.sbe4.LogonEncoder	getLogonEncoder()
com.marketfactory.protocol.sbe4.LogoutEncoder	getLogoutEncoder()
com.marketfactory.protocol.sbe4.LogoutResponseEncoder	getLogoutResponseEncoder()
com.marketfactory.protocol.sbe4.MarketDataRequestEncoder	getMarketDataRequestEncoder()
com.marketfactory.protocol.sbe4.MassQuoteEncoder	getMassQuoteEncoder()
com.marketfactory.protocol.sbe4.MultilegOrderCancelReplaceRequestEncoder	getMultilegOrderCancelReplaceRequestEncoder()
com.marketfactory.protocol.sbe4.NewOrderMultilegEncoder	getNewOrderMultilegEncoder()
com.marketfactory.protocol.sbe4.OrderCancelRejectEncoder	getOrderCancelRejectEncoder()
com.marketfactory.protocol.sbe4.OrderCancelRequestEncoder	getOrderCancelRequestEncoder()
com.marketfactory.protocol.sbe4.OrderTimeoutEncoder	getOrderTimeoutEncoder()
com.marketfactory.protocol.sbe4.QuoteCancelEncoder	getQuoteCancelEncoder()
com.marketfactory.protocol.sbe4.QuoteEncoder	getQuoteEncoder()
com.marketfactory.protocol.sbe4.QuoteRequestEncoder	getQuoteRequestEncoder()
com.marketfactory.protocol.sbe4.QuoteResponseEncoder	getQuoteResponseEncoder()
com.marketfactory.protocol.sbe4.SequenceResetGapFillEncoder	getSequenceResetGapFillEncoder()
com.marketfactory.protocol.sbe4.TestRequestEncoder	getTestRequestEncoder()
com.marketfactory.protocol.sbe4.UserRequestEncoder	getUserRequestEncoder()
int	populateCurrentMessageHeader(long messageSeqNum, org.agrona.sbe.MessageEncoderFlyweight encoder) Sets all the header values.

Methods inherited from class java.lang.Object

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

Constructor Detail

SbeEncoderProvider

public SbeEncoderProvider(java.nio.ByteBuffer sendByteBuffer,
                          java.time.Clock clock)

Method Detail

populateCurrentMessageHeader

public int populateCurrentMessageHeader(long messageSeqNum,
                                        org.agrona.sbe.MessageEncoderFlyweight encoder)

Description copied from interface: EncoderProvider

Sets all the header values. Returns the total message size including both the MessageHeader and MessageEncoder.

Specified by:

populateCurrentMessageHeader in interface EncoderProvider

Parameters:

messageSeqNum - to set in the header

encoder - encoder to create the header for

Returns:

the total bytes of the entire message including the header

getLogonEncoder

public com.marketfactory.protocol.sbe4.LogonEncoder getLogonEncoder()

Specified by:

getLogonEncoder in interface EncoderProvider

getLogoutEncoder

public com.marketfactory.protocol.sbe4.LogoutEncoder getLogoutEncoder()

Specified by:

getLogoutEncoder in interface EncoderProvider

getHeartbeatEncoder

public com.marketfactory.protocol.sbe4.HeartbeatEncoder getHeartbeatEncoder()

Specified by:

getHeartbeatEncoder in interface EncoderProvider

getSequenceResetGapFillEncoder

public com.marketfactory.protocol.sbe4.SequenceResetGapFillEncoder getSequenceResetGapFillEncoder()

Specified by:

getSequenceResetGapFillEncoder in interface EncoderProvider

getLogoutResponseEncoder

public com.marketfactory.protocol.sbe4.LogoutResponseEncoder getLogoutResponseEncoder()

Specified by:

getLogoutResponseEncoder in interface EncoderProvider

getTestRequestEncoder

public com.marketfactory.protocol.sbe4.TestRequestEncoder getTestRequestEncoder()

Specified by:

getTestRequestEncoder in interface EncoderProvider

getUserRequestEncoder

public com.marketfactory.protocol.sbe4.UserRequestEncoder getUserRequestEncoder()

Specified by:

getUserRequestEncoder in interface EncoderProvider

getQuoteRequestEncoder

public com.marketfactory.protocol.sbe4.QuoteRequestEncoder getQuoteRequestEncoder()

Specified by:

getQuoteRequestEncoder in interface EncoderProvider

getNewOrderMultilegEncoder

public com.marketfactory.protocol.sbe4.NewOrderMultilegEncoder getNewOrderMultilegEncoder()

Specified by:

getNewOrderMultilegEncoder in interface EncoderProvider

getMultilegOrderCancelReplaceRequestEncoder

public com.marketfactory.protocol.sbe4.MultilegOrderCancelReplaceRequestEncoder getMultilegOrderCancelReplaceRequestEncoder()

Specified by:

getMultilegOrderCancelReplaceRequestEncoder in interface EncoderProvider

getQuoteResponseEncoder

public com.marketfactory.protocol.sbe4.QuoteResponseEncoder getQuoteResponseEncoder()

Specified by:

getQuoteResponseEncoder in interface EncoderProvider

getOrderTimeoutEncoder

public com.marketfactory.protocol.sbe4.OrderTimeoutEncoder getOrderTimeoutEncoder()

Specified by:

getOrderTimeoutEncoder in interface EncoderProvider

getMarketDataRequestEncoder

public com.marketfactory.protocol.sbe4.MarketDataRequestEncoder getMarketDataRequestEncoder()

Specified by:

getMarketDataRequestEncoder in interface EncoderProvider

getQuoteEncoder

public com.marketfactory.protocol.sbe4.QuoteEncoder getQuoteEncoder()

Specified by:

getQuoteEncoder in interface EncoderProvider

getMassQuoteEncoder

public com.marketfactory.protocol.sbe4.MassQuoteEncoder getMassQuoteEncoder()

Specified by:

getMassQuoteEncoder in interface EncoderProvider

getQuoteCancelEncoder

public com.marketfactory.protocol.sbe4.QuoteCancelEncoder getQuoteCancelEncoder()

Specified by:

getQuoteCancelEncoder in interface EncoderProvider

getOrderCancelRequestEncoder

public com.marketfactory.protocol.sbe4.OrderCancelRequestEncoder getOrderCancelRequestEncoder()

Specified by:

getOrderCancelRequestEncoder in interface EncoderProvider

getExecutionAckEncoder

public com.marketfactory.protocol.sbe4.ExecutionAckEncoder getExecutionAckEncoder()

Specified by:

getExecutionAckEncoder in interface EncoderProvider

getExecutionReportEncoder

public com.marketfactory.protocol.sbe4.ExecutionReportEncoder getExecutionReportEncoder()

Specified by:

getExecutionReportEncoder in interface EncoderProvider

getOrderCancelRejectEncoder

public com.marketfactory.protocol.sbe4.OrderCancelRejectEncoder getOrderCancelRejectEncoder()

Specified by:

getOrderCancelRejectEncoder in interface EncoderProvider

getApplicationMessageRequestEncoder

public com.marketfactory.protocol.sbe4.ApplicationMessageRequestEncoder getApplicationMessageRequestEncoder()

Specified by:

getApplicationMessageRequestEncoder in interface EncoderProvider