Package deltix.qsrv.hf.topic.loader

Class DirectLoaderFactory

java.lang.Object

deltix.qsrv.hf.topic.loader.DirectLoaderFactory

@ParametersAreNonnullByDefault
public class DirectLoaderFactory
extends java.lang.Object

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
deltix.data.stream.MessageChannel<deltix.qsrv.hf.pub.InstrumentMessage>	create(io.aeron.Aeron aeron, boolean raw, java.lang.String publisherChannel, java.lang.String metadataSubscriberChannel, int dataStreamId, int serverMetadataUpdatesStreamId, java.util.List<RecordClassDescriptor> typeList, byte loaderNumber, java.io.OutputStream outputStream, java.util.List<deltix.qsrv.hf.pub.ConstantInstrumentKey> mapping, java.lang.Runnable closeCallback, IdleStrategy publicationIdleStrategy)

Methods inherited from class java.lang.Object

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

Constructor Detail

DirectLoaderFactory

public DirectLoaderFactory(CodecFactory codecFactory,
                           TypeLoader typeLoader)

DirectLoaderFactory

public DirectLoaderFactory(CodecFactory codecFactory)

DirectLoaderFactory

public DirectLoaderFactory()

Method Detail

create

public deltix.data.stream.MessageChannel<deltix.qsrv.hf.pub.InstrumentMessage> create(io.aeron.Aeron aeron,
                                                                                      boolean raw,
                                                                                      java.lang.String publisherChannel,
                                                                                      java.lang.String metadataSubscriberChannel,
                                                                                      int dataStreamId,
                                                                                      int serverMetadataUpdatesStreamId,
                                                                                      java.util.List<RecordClassDescriptor> typeList,
                                                                                      byte loaderNumber,
                                                                                      java.io.OutputStream outputStream,
                                                                                      java.util.List<deltix.qsrv.hf.pub.ConstantInstrumentKey> mapping,
                                                                                      @Nullable
                                                                                      java.lang.Runnable closeCallback,
                                                                                      @Nullable
                                                                                      IdleStrategy publicationIdleStrategy)