Show / Hide Table of Contents

Interface IMessageBus

Specifies a cloud of nodes that can communicate with each other through the network.

Inherited Members
ICluster.WaitForLeaderAsync(TimeSpan, CancellationToken)
ICluster.ResignAsync(CancellationToken)
ICluster.LeaderChanged
IPeerMesh<IClusterMember>.TryGetPeer(EndPoint)
IPeerMesh.Peers
IPeerMesh.PeerDiscovered
IPeerMesh.PeerGone
Namespace: DotNext.Net.Cluster.Messaging
Assembly: DotNext.Net.Cluster.dll
Syntax
public interface IMessageBus : ICluster, IPeerMesh<IClusterMember>, IPeerMesh<ISubscriber>, IPeerMesh

Properties

View Source

Leader

Gets the leader node.

Declaration
ISubscriber? Leader { get; }
Property Value
Type Description
ISubscriber
View Source

LeaderRouter

Allows to route messages to the leader even if it is changed during transmission.

Declaration
IOutputChannel LeaderRouter { get; }
Property Value
Type Description
IOutputChannel
View Source

Members

Gets a set of visible cluster members.

Declaration
IReadOnlyCollection<ISubscriber> Members { get; }
Property Value
Type Description
IReadOnlyCollection<ISubscriber>

Methods

View Source

AddListener(IInputChannel)

Adds message handler.

Declaration
void AddListener(IInputChannel handler)
Parameters
Type Name Description
IInputChannel handler

The message handler.

View Source

RemoveListener(IInputChannel)

Removes message handler.

Declaration
void RemoveListener(IInputChannel handler)
Parameters
Type Name Description
IInputChannel handler

The message handler.

Extension Methods

BasicExtensions.As<T>(T)
BasicExtensions.IsBetween<T, TLowerBound, TUpperBound>(T, TLowerBound, TUpperBound)
BasicExtensions.IsOneOf<T>(T, params ReadOnlySpan<T>)
Messenger.SendBroadcastSignalAsync(IMessageBus, IMessage, bool)
  • View Source
☀
☾
In this article
Back to top
Supported by the .NET Foundation
☀
☾