Class StreamConfigurationHelper


  • public class StreamConfigurationHelper
    extends java.lang.Object
    • Field Detail

      • BS_NO_BAR_SIZE

        public static final int BS_NO_BAR_SIZE
        Returned when bar message descriptor does not contain the barSize field.
        See Also:
        Constant Field Values
      • STREAM_TRUNCATED_MESSAGE_DESCRIPTOR

        public static final RecordClassDescriptor STREAM_TRUNCATED_MESSAGE_DESCRIPTOR
      • SPACE_RENAME_MESSAGE_DESCRIPTOR

        public static final RecordClassDescriptor SPACE_RENAME_MESSAGE_DESCRIPTOR
      • SPACE_DELETE_MESSAGE_DESCRIPTOR

        public static final RecordClassDescriptor SPACE_DELETE_MESSAGE_DESCRIPTOR
      • SPACE_CREATE_MESSAGE_DESCRIPTOR

        public static final RecordClassDescriptor SPACE_CREATE_MESSAGE_DESCRIPTOR
      • META_DATA_CHANGE_MESSAGE_DESCRIPTOR

        public static final RecordClassDescriptor META_DATA_CHANGE_MESSAGE_DESCRIPTOR
      • REAL_TIME_START_MESSAGE_DESCRIPTOR

        public static final RecordClassDescriptor REAL_TIME_START_MESSAGE_DESCRIPTOR
    • Constructor Detail

      • StreamConfigurationHelper

        public StreamConfigurationHelper()
    • Method Detail

      • mkField

        public static DataField mkField​(java.lang.String name,
                                        java.lang.String title,
                                        DataType type,
                                        java.lang.String relativeTo,
                                        java.lang.Object staticValue)
      • mkMarketMessageDescriptor

        public static RecordClassDescriptor mkMarketMessageDescriptor​(java.lang.Integer staticCurrencyCode)
      • mkMarketMessageDescriptor

        public static RecordClassDescriptor mkMarketMessageDescriptor​(java.lang.Integer staticCurrencyCode,
                                                                      boolean staticOriginalTimestamp)
      • mkMarketMessageDescriptor

        public static RecordClassDescriptor mkMarketMessageDescriptor​(java.lang.Integer staticCurrencyCode,
                                                                      java.lang.Boolean staticOriginalTimestamp,
                                                                      java.lang.Boolean staticNanoTime)
        Builds RecordClassDescriptor for standard message class MarketMessage
        Parameters:
        staticOriginalTimestamp - Controls MarketMessage.originalTimestamp: pass null to omit this field, true if you want to make this fields static, false otherwise.
        staticNanoTime - Controls MarketMessage.nanoTime: pass null to omit this field, true if you want to make this fields static, false otherwise.
      • mkBarMessageDescriptor

        public static RecordClassDescriptor mkBarMessageDescriptor​(RecordClassDescriptor marketMsgDescriptor,
                                                                   java.lang.String staticExchangeCode,
                                                                   java.lang.Integer staticCurrencyCode,
                                                                   java.lang.String priceEncoding,
                                                                   java.lang.String sizeEncoding)
      • mkTradeMessageDescriptor

        public static RecordClassDescriptor mkTradeMessageDescriptor​(RecordClassDescriptor marketMsgDescriptor,
                                                                     java.lang.String staticExchangeCode,
                                                                     java.lang.Integer staticCurrencyCode,
                                                                     java.lang.String priceEncoding,
                                                                     java.lang.String sizeEncoding)
      • mkBBOMessageDescriptor

        public static RecordClassDescriptor mkBBOMessageDescriptor​(RecordClassDescriptor marketMsgDescriptor,
                                                                   java.lang.Boolean isNational,
                                                                   java.lang.String staticExchangeCode,
                                                                   java.lang.Integer staticCurrencyCode,
                                                                   java.lang.String priceEncoding,
                                                                   java.lang.String sizeEncoding)
      • mkLevel2MessageDescriptor

        public static RecordClassDescriptor mkLevel2MessageDescriptor​(RecordClassDescriptor marketMsgDescriptor,
                                                                      java.lang.String staticExchangeCode,
                                                                      java.lang.Integer staticCurrencyCode,
                                                                      java.lang.String priceEncoding,
                                                                      java.lang.String sizeEncoding)
      • mkLevel2ActionDescriptor

        public static RecordClassDescriptor mkLevel2ActionDescriptor​(java.lang.String priceEncoding,
                                                                     java.lang.String sizeEncoding)
      • mkL2SnapshotMessageDescriptor

        public static RecordClassDescriptor mkL2SnapshotMessageDescriptor​(RecordClassDescriptor marketMsgDescriptor,
                                                                          java.lang.String staticExchangeCode,
                                                                          java.lang.Integer staticCurrencyCode,
                                                                          java.lang.String priceEncoding,
                                                                          java.lang.String sizeEncoding)
      • setBarNoExchNoCur

        public static void setBarNoExchNoCur​(DXTickStream stream,
                                             deltix.util.time.Interval periodicity)
      • setBar

        public static void setBar​(DXTickStream stream,
                                  java.lang.String staticExchangeCode,
                                  java.lang.Integer staticCurrencyCode,
                                  deltix.util.time.Interval periodicity)
      • setBar

        public static void setBar​(DXTickStream stream,
                                  java.lang.String staticExchangeCode,
                                  java.lang.Integer staticCurrencyCode,
                                  deltix.util.time.Interval periodicity,
                                  java.lang.String priceEncoding,
                                  java.lang.String sizeEncoding)
      • setTradeNoExchNoCur

        public static void setTradeNoExchNoCur​(DXTickStream stream)
      • setTrade

        public static void setTrade​(DXTickStream stream,
                                    java.lang.String staticExchangeCode,
                                    java.lang.Integer staticCurrencyCode)
      • setTrade

        public static void setTrade​(DXTickStream stream,
                                    java.lang.String staticExchangeCode,
                                    java.lang.Integer staticCurrencyCode,
                                    java.lang.String priceEncoding,
                                    java.lang.String sizeEncoding)
      • setBBONoExchNoCur

        public static void setBBONoExchNoCur​(DXTickStream stream)
      • setBBO

        public static void setBBO​(DXTickStream stream,
                                  java.lang.Boolean isNational,
                                  java.lang.String staticExchangeCode,
                                  java.lang.Integer staticCurrencyCode)
      • setBBO

        public static void setBBO​(DXTickStream stream,
                                  java.lang.Boolean isNational,
                                  java.lang.String staticExchangeCode,
                                  java.lang.Integer staticCurrencyCode,
                                  java.lang.String priceEncoding,
                                  java.lang.String sizeEncoding)
      • setTradeOrBBO

        public static void setTradeOrBBO​(DXTickStream stream,
                                         java.lang.Boolean isNational,
                                         java.lang.String staticExchangeCode,
                                         java.lang.Integer staticCurrencyCode)
      • setTradeOrBBO

        public static void setTradeOrBBO​(DXTickStream stream,
                                         java.lang.Boolean isNational,
                                         java.lang.String staticExchangeCode,
                                         java.lang.Integer staticCurrencyCode,
                                         java.lang.String priceEncoding,
                                         java.lang.String sizeEncoding)
      • mkUniversalTradeMessageDescriptor

        public static RecordClassDescriptor mkUniversalTradeMessageDescriptor()
      • mkUniversalBarMessageDescriptor

        public static RecordClassDescriptor mkUniversalBarMessageDescriptor()
      • mkUniversalBBOMessageDescriptor

        public static RecordClassDescriptor mkUniversalBBOMessageDescriptor()
      • mkUniversalDescriptor

        public static RecordClassDescriptor mkUniversalDescriptor​(java.lang.Class<?> cls)
      • mkUniversalMarketDescriptors

        public static RecordClassDescriptor[] mkUniversalMarketDescriptors​(deltix.timebase.api.MarketMessageType[] types)
      • setUniversalMarket

        public static void setUniversalMarket​(DXTickStream stream)
      • containsSubclassesOnly

        public static boolean containsSubclassesOnly​(RecordClassDescriptor[] rcds,
                                                     java.lang.Class<?> cls)
      • containsSubclassesOnly

        public static boolean containsSubclassesOnly​(RecordClassDescriptor[] rcds,
                                                     java.lang.String newPath,
                                                     java.lang.String oldPath)
      • containsSubclassesOnly

        public static boolean containsSubclassesOnly​(TickStream stream,
                                                     java.lang.Class<?> cls)
      • containsMarketMessagesOnly

        public static boolean containsMarketMessagesOnly​(TickStream... streams)
      • containsMarketMessagesOnly

        public static boolean containsMarketMessagesOnly​(TickStream stream)
      • isFixedBuiltIn

        public static boolean isFixedBuiltIn​(TickStream stream,
                                             java.lang.Class<?> cls)
      • mayContainSubclasses

        public static boolean mayContainSubclasses​(TickStream stream,
                                                   java.lang.Class<?> cls)
      • mayContainSubclasses

        public static boolean mayContainSubclasses​(TickStream stream,
                                                   java.lang.Class<?>... cls)
      • mayContainSubclasses

        public static boolean mayContainSubclasses​(DXChannel channel,
                                                   java.lang.Class<?> cls)
      • containsTradeMessagesOnly

        public static boolean containsTradeMessagesOnly​(TickStream stream)
      • containsBBOMessagesOnly

        public static boolean containsBBOMessagesOnly​(TickStream stream)
      • containsBarMessagesOnly

        public static boolean containsBarMessagesOnly​(TickStream stream)
      • mayContainTradeMessages

        public static boolean mayContainTradeMessages​(TickStream stream)
      • mayContainLevel2Messages

        public static boolean mayContainLevel2Messages​(TickStream stream)
      • mayContainL2Descriptors

        public static boolean mayContainL2Descriptors​(TickStream stream)
      • mayContainBBOMessages

        public static boolean mayContainBBOMessages​(TickStream stream)
      • mayContainBarMessages

        public static boolean mayContainBarMessages​(TickStream stream)
      • getPeriodicity

        public static deltix.util.time.Interval getPeriodicity​(DXChannel channel)
      • getChannel

        public static DXChannel<deltix.qsrv.hf.pub.InstrumentMessage> getChannel​(DXTickDB db,
                                                                                 java.lang.String key)
      • setTradeOrBBOOrBar

        public static void setTradeOrBBOOrBar​(DXTickStream stream,
                                              java.lang.Boolean isNational,
                                              java.lang.String staticExchangeCode,
                                              java.lang.Integer staticCurrencyCode)
      • setBBOOrBar

        public static void setBBOOrBar​(DXTickStream stream,
                                       java.lang.Boolean isNational,
                                       java.lang.String staticExchangeCode,
                                       java.lang.Integer staticCurrencyCode)
      • setTradeOrBar

        public static void setTradeOrBar​(DXTickStream stream,
                                         java.lang.String staticExchangeCode,
                                         java.lang.Integer staticCurrencyCode)
      • setMeta

        public static void setMeta​(DXTickStream stream)