Interface DXChannel<T>

    • Method Detail

      • getKey

        java.lang.String getKey()
        Returns the key, which uniquely identifies the channel
      • getName

        java.lang.String getName()
        Returns a user-readable short name.
      • getDescription

        java.lang.String getDescription()
        Returns a user-readable multi-line description.
      • getTypes

        RecordClassDescriptor[] getTypes()
        Returns the class descriptors associated with this channel
      • createConsumer

        deltix.data.stream.MessageSource<T> createConsumer​(ChannelPreferences options)

        Opens a source for reading data from this channel, according to the specified preferences. Iterator-like approach to consume messages: while (source.next()) source.getMessage()

        Returns:
        A message source to read messages from.
      • createPublisher

        deltix.data.stream.MessageChannel<T> createPublisher​(ChannelPreferences options)
        Creates a channel for loading data. The publisher must be closed when the loading process is finished.
        Returns:
        A consumer of messages to be loaded into the channel.