RawTopicProducer

QuixStreams.Streaming

QuixStreams.Streaming.Raw

RawTopicProducer Class

Class to produce raw messages into a Topic (capable to producing non-quixstreams messages)

public class RawTopicProducer :
QuixStreams.Streaming.Raw.IRawTopicProducer,
System.IDisposable

Inheritance System.Object 🡒 RawTopicProducer

Implements IRawTopicProducer, System.IDisposable

Constructors
RawTopicProducer(string, string, Dictionary<string,string>)	Initializes a new instance of RawTopicProducer

Methods
Dispose()	Flushes pending messages and disposes underlying resources
Flush()	Flushes pending messages to the broker
Publish(RawMessage)	Publish data to the topic

Events
OnDisposed	Raised when the resource is disposed