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.LeaderChanged
ICluster.ResignAsync(CancellationToken)
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

| Edit this page View Source

Leader

Gets the leader node.

Declaration
ISubscriber? Leader { get; }
Property Value
Type Description
ISubscriber
| Edit this page 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
| Edit this page View Source

Members

Gets a set of visible cluster members.

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

Methods

| Edit this page View Source

AddListener(IInputChannel)

Adds message handler.

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

The message handler.

| Edit this page 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.GetUserData<T>(T)
BasicExtensions.IsBetween<T, TLowerBound, TUpperBound>(T, TLowerBound, TUpperBound)
BasicExtensions.IsOneOf<T>(T, ReadOnlySpan<T>)
ExpressionBuilder.Const<T>(T)
Messenger.SendBroadcastSignalAsync(IMessageBus, IMessage, bool)
AsyncLockAcquisition.AcquireLockAsync<T>(T, CancellationToken)
AsyncLockAcquisition.AcquireLockAsync<T>(T, TimeSpan, CancellationToken)
AsyncLockAcquisition.AcquireReadLockAsync<T>(T, CancellationToken)
AsyncLockAcquisition.AcquireReadLockAsync<T>(T, TimeSpan, CancellationToken)
AsyncLockAcquisition.AcquireWriteLockAsync<T>(T, bool, CancellationToken)
AsyncLockAcquisition.AcquireWriteLockAsync<T>(T, bool, TimeSpan, CancellationToken)
AsyncLockAcquisition.AcquireWriteLockAsync<T>(T, CancellationToken)
AsyncLockAcquisition.AcquireWriteLockAsync<T>(T, TimeSpan, CancellationToken)
LockAcquisition.AcquireReadLock<T>(T)
LockAcquisition.AcquireReadLock<T>(T, TimeSpan)
LockAcquisition.AcquireUpgradeableReadLock<T>(T)
LockAcquisition.AcquireUpgradeableReadLock<T>(T, TimeSpan)
LockAcquisition.AcquireWriteLock<T>(T)
LockAcquisition.AcquireWriteLock<T>(T, TimeSpan)
  • Edit this page
  • View Source
☀
☾
In this article
Back to top
Supported by the .NET Foundation
☀
☾