Package deltix.qsrv.hf.topic.consumer

Class DirectReaderFactory

java.lang.Object

deltix.qsrv.hf.topic.consumer.DirectReaderFactory

@ParametersAreNonnullByDefault
public class DirectReaderFactory
extends java.lang.Object

Constructor Summary

Constructors

Constructor	Description
DirectReaderFactory()
DirectReaderFactory(CodecFactory codecFactory)
DirectReaderFactory(CodecFactory codecFactory, TypeLoader typeLoader)

Method Summary

Modifier and Type	Method	Description
SubscriptionWorker	createListener(io.aeron.Aeron aeron, boolean raw, java.lang.String channel, int dataStreamId, java.util.List<RecordClassDescriptor> types, MessageProcessor processor, IdleStrategy idleStrategy, MappingProvider mappingProvider)
deltix.data.stream.MessageSource<deltix.qsrv.hf.pub.InstrumentMessage>	createMessageSource(io.aeron.Aeron aeron, boolean raw, java.lang.String channel, int dataStreamId, java.util.List<RecordClassDescriptor> types, IdleStrategy idleStrategy, MappingProvider mappingProvider)
MessagePoller	createPoller(io.aeron.Aeron aeron, boolean raw, java.lang.String channel, int dataStreamId, java.util.List<RecordClassDescriptor> types, MappingProvider mappingProvider)

Methods inherited from class java.lang.Object

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

Constructor Detail

DirectReaderFactory

public DirectReaderFactory()

DirectReaderFactory

public DirectReaderFactory(CodecFactory codecFactory)

DirectReaderFactory

public DirectReaderFactory(CodecFactory codecFactory,
                           TypeLoader typeLoader)

Method Detail

createListener

public SubscriptionWorker createListener(io.aeron.Aeron aeron,
                                         boolean raw,
                                         java.lang.String channel,
                                         int dataStreamId,
                                         java.util.List<RecordClassDescriptor> types,
                                         MessageProcessor processor,
                                         @Nullable
                                         IdleStrategy idleStrategy,
                                         MappingProvider mappingProvider)

createPoller

public MessagePoller createPoller(io.aeron.Aeron aeron,
                                  boolean raw,
                                  java.lang.String channel,
                                  int dataStreamId,
                                  java.util.List<RecordClassDescriptor> types,
                                  MappingProvider mappingProvider)

createMessageSource

public deltix.data.stream.MessageSource<deltix.qsrv.hf.pub.InstrumentMessage> createMessageSource(io.aeron.Aeron aeron,
                                                                                                  boolean raw,
                                                                                                  java.lang.String channel,
                                                                                                  int dataStreamId,
                                                                                                  java.util.List<RecordClassDescriptor> types,
                                                                                                  @Nullable
                                                                                                  IdleStrategy idleStrategy,
                                                                                                  MappingProvider mappingProvider)