Class Publisher
Represents an operator that creates a publisher socket for transmitting a sequence of messages as part of the pub-sub pattern.
public class Publisher : Sink<NetMQMessage>
- Inheritance
-
Sink<NetMQMessage>Publisher
- Inherited Members
Properties
- ConnectionString
Gets or sets a value specifying the endpoints to attach the socket to.
- Topic
Gets or sets the topic under which to publish each sent message.
Methods
- Process(IObservable<NetMQMessage>)
Creates a publisher socket for transmitting an observable sequence of multiple part messages.
- Process(IObservable<byte[]>)
Creates a publisher socket for transmitting an observable sequence of binary coded messages.
- Process(IObservable<string>)
Creates a publisher socket for transmitting an observable sequence of string messages.