Package trading.keysquare.api.session

Interface KeySessionRouting

public interface KeySessionRouting

Methods to register message processors for different types of messages. All methods must be invoked before starting the session.

Method Summary

Modifier and Type	Method	Description
<T> void	custom(Class<T> type, MessageProcessor<T> messageProcessor, Optional<MessageProcessor<T>> voidedMessageProcessor)	Register a message processor for Custom messages.
<T extends trading.keysquare.model.KeyDto> void	dto(Class<T> type, MessageProcessor<T> messageProcessor, Optional<MessageProcessor<T>> voidedMessageProcessor)	Register a message processor for DTO messages.
<T> void	flexible(Class<? super T> type, MessageProcessor<T> messageProcessor, Optional<MessageProcessor<T>> voidedMessageProcessor)	Register a message processor for Flexible messages.
void	raw(int schemaId, int templateId, MessageProcessor<RawPayload> messageProcessor, Optional<MessageProcessor<RawPayload>> voidedMessageProcessor)	Register a message processor for raw messages identified by schema and template id.
<T extends org.agrona.sbe.MessageDecoderFlyweight> void	sbe(Class<T> type, MessageProcessor<T> messageProcessor, Optional<MessageProcessor<T>> voidedMessageProcessor)	Register a message processor for SBE messages.

Method Details

sbe

<T extends org.agrona.sbe.MessageDecoderFlyweight>
void sbe(Class<T> type,
 MessageProcessor<T> messageProcessor,
 Optional<MessageProcessor<T>> voidedMessageProcessor)

Register a message processor for SBE messages. This may only be invoked before starting the session.

dto

<T extends trading.keysquare.model.KeyDto> void dto(Class<T> type,
 MessageProcessor<T> messageProcessor,
 Optional<MessageProcessor<T>> voidedMessageProcessor)

Register a message processor for DTO messages. This may only be invoked before starting the session.

flexible

<T> void flexible(Class<? super T> type,
 MessageProcessor<T> messageProcessor,
 Optional<MessageProcessor<T>> voidedMessageProcessor)

Register a message processor for Flexible messages. This may only be invoked before starting the session.

custom

<T> void custom(Class<T> type,
 MessageProcessor<T> messageProcessor,
 Optional<MessageProcessor<T>> voidedMessageProcessor)

Register a message processor for Custom messages. This may only be invoked before starting the session.

raw

void raw(int schemaId,
 int templateId,
 MessageProcessor<RawPayload> messageProcessor,
 Optional<MessageProcessor<RawPayload>> voidedMessageProcessor)

Register a message processor for raw messages identified by schema and template id. This may only be invoked before starting the session.