Interface IMessageBus

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

Inherited Members
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

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

SendMessageToLeaderAsync<TResponse>(IMessage, MessageReader<TResponse>, CancellationToken)

Sends a message to the cluster leader.

Declaration
Task<TResponse> SendMessageToLeaderAsync<TResponse>(IMessage message, MessageReader<TResponse> responseReader, CancellationToken token = null)
Parameters
Type Name Description
IMessage message

The message to be sent.
MessageReader<TResponse> responseReader

The response reader.
CancellationToken token

The token that can be used to cancel asynchronous operation.
Returns
Type Description
Task<TResponse>

The message representing response; or null if request message in one-way.
Type Parameters
Name Description
TResponse

The type of the parsed response message.
Remarks

message should be reusable because or can be called multiple times.

| Improve this Doc View Source

SendSignalToLeaderAsync(IMessage, CancellationToken)

Sends one-way message to the cluster leader.

Declaration
Task SendSignalToLeaderAsync(IMessage message, CancellationToken token = null)
Parameters
Type Name Description
IMessage message

The message to be sent.
CancellationToken token

The token that can be used to cancel asynchronous operation.
Returns
Type Description
Task

The task representing execution of this method.
Remarks

message should be reusable because or can be called multiple times.

Extension Methods