Class JsonMessageSource

  • All Implemented Interfaces:
    deltix.data.stream.MessageSource<RawMessage>, deltix.util.concurrent.AbstractCursor, deltix.util.lang.Disposable, java.io.Closeable, java.lang.AutoCloseable

    public class JsonMessageSource
    extends java.lang.Object
    implements deltix.data.stream.MessageSource<RawMessage>
    • Constructor Detail

      • JsonMessageSource

        public JsonMessageSource​(RecordClassDescriptor[] descriptors,
                                 java.io.Reader reader,
                                 java.lang.String typeField)
                          throws java.io.IOException
        Throws:
        java.io.IOException
    • Method Detail

      • getMessage

        public RawMessage getMessage()
        Specified by:
        getMessage in interface deltix.data.stream.MessageSource<RawMessage>
      • next

        public boolean next()
        Specified by:
        next in interface deltix.util.concurrent.AbstractCursor
      • isAtEnd

        public boolean isAtEnd()
        Specified by:
        isAtEnd in interface deltix.util.concurrent.AbstractCursor
      • close

        public void close()
        Specified by:
        close in interface java.lang.AutoCloseable
        Specified by:
        close in interface java.io.Closeable
        Specified by:
        close in interface deltix.util.lang.Disposable