Show / Hide Table of Contents

Interface IMessageBus

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

Inherited Members
ICluster.LeaderChanged
ICluster.ResignAsync(CancellationToken)
Namespace: DotNext.Net.Cluster.Messaging
Assembly: DotNext.Net.Cluster.dll
Syntax
public interface IMessageBus : ICluster

Properties

| Improve this Doc View Source

Leader

Gets the leader node.

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

Members

Represents a collection of nodes in the network.

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

Methods

| Improve this Doc View Source

AddListener(IInputChannel)

Adds message handler.

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

The message handler.

| Improve this Doc View Source

RemoveListener(IInputChannel)

Removes message handler.

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

The message handler.

Explicit Interface Implementations

| Improve this Doc View Source

ICluster.Leader

Declaration
IClusterMember ICluster.Leader { get; }
Returns
Type Description
IClusterMember
| Improve this Doc View Source

ICluster.Members

Declaration
IReadOnlyCollection<IClusterMember> ICluster.Members { get; }
Returns
Type Description
IReadOnlyCollection<IClusterMember>

Extension Methods

Messenger.SendBroadcastSignalAsync(IMessageBus, IMessage, Boolean)
AsyncLockAcquisition.AcquireLockAsync<T>(T, TimeSpan)
AsyncLockAcquisition.AcquireLockAsync<T>(T, CancellationToken)
AsyncLockAcquisition.AcquireReadLockAsync<T>(T, TimeSpan)
AsyncLockAcquisition.AcquireReadLockAsync<T>(T, CancellationToken)
AsyncLockAcquisition.AcquireWriteLockAsync<T>(T, TimeSpan)
AsyncLockAcquisition.AcquireWriteLockAsync<T>(T, CancellationToken)
AsyncLockAcquisition.AcquireUpgradeableReadLockAsync<T>(T, TimeSpan)
AsyncLockAcquisition.AcquireUpgradeableReadLockAsync<T>(T, CancellationToken)
ObjectExtensions.GetUserData<T>(T)
ObjectExtensions.IsOneOf<T>(T, IEnumerable<T>)
ObjectExtensions.IsOneOf<T>(T, T[])
ObjectExtensions.Decompose<T, TResult1, TResult2>(T, Func<T, TResult1>, Func<T, TResult2>, out TResult1, out TResult2)
ObjectExtensions.Decompose<T, TResult1, TResult2>(T, ValueFunc<T, TResult1>, ValueFunc<T, TResult2>, out TResult1, out TResult2)
ObjectExtensions.Decompose<T, TResult1, TResult2>(T, Func<T, TResult1>, Func<T, TResult2>)
ObjectExtensions.Decompose<T, TResult1, TResult2>(T, ValueFunc<T, TResult1>, ValueFunc<T, TResult2>)
ObjectExtensions.As<T>(T)
LockAcquisition.AcquireReadLock<T>(T)
LockAcquisition.AcquireReadLock<T>(T, TimeSpan)
LockAcquisition.AcquireWriteLock<T>(T)
LockAcquisition.AcquireWriteLock<T>(T, TimeSpan)
LockAcquisition.AcquireUpgradeableReadLock<T>(T)
LockAcquisition.AcquireUpgradeableReadLock<T>(T, TimeSpan)
ExpressionBuilder.Const<T>(T)
  • Improve this Doc
  • View Source
In This Article
Back to top Generated by DocFX