Table of Contents

Class MessageBrokerStream

Namespace
LfrlAnvil.MessageBroker.Server
Assembly
LfrlAnvil.MessageBroker.Server.dll

Represents a message broker stream, which allows MessageBrokerChannelPublisherBinding instances to push messages in order to be processed and moved to relevant MessageBrokerChannelListenerBinding instances.

public sealed class MessageBrokerStream
Inheritance
MessageBrokerStream
Inherited Members

Properties

Id

Stream's unique identifier assigned by the server.

public int Id { get; }

Property Value

int

Messages

Collection of messages stored in this stream.

public MessageBrokerStreamMessageCollection Messages { get; }

Property Value

MessageBrokerStreamMessageCollection

Name

Stream's unique name.

public string Name { get; }

Property Value

string

Publishers

Collection of MessageBrokerChannelPublisherBinding instances attached to this stream, identified by (client-id, channel-id) tuples.

public MessageBrokerStreamPublisherCollection Publishers { get; }

Property Value

MessageBrokerStreamPublisherCollection

Server

MessageBrokerServer instance that owns this stream.

public MessageBrokerServer Server { get; }

Property Value

MessageBrokerServer

State

Current stream's state.

public MessageBrokerStreamState State { get; }

Property Value

MessageBrokerStreamState

Remarks

See MessageBrokerStreamState for more information.

Methods

ToString()

Returns a string representation of this MessageBrokerStream instance.

[Pure]
public override string ToString()

Returns

string

String representation.