Show / Hide Table of Contents

Interface ISubscriber

Represents cluster member that supports messaging.

Inherited Members
IClusterMember.Id
IClusterMember.IsLeader
IClusterMember.IsRemote
IClusterMember.MemberStatusChanged
IClusterMember.Status
IClusterMember.GetMetadataAsync(bool, CancellationToken)
IClusterMember.ResignAsync(CancellationToken)
IClusterMember.OnMemberStatusChanged<TMember>(TMember, ref ClusterMemberStatus, ClusterMemberStatus, InvocationList<Action<ClusterMemberStatusChangedEventArgs<TMember>>>)
IPeer.EndPoint
IOutputChannel.SendMessageAsync<TResponse>(IMessage, MessageReader<TResponse>, CancellationToken)
IOutputChannel.SendMessageAsync<TResponse>(IMessage, CancellationToken)
IOutputChannel.SendSignalAsync(IMessage, CancellationToken)
Namespace: DotNext.Net.Cluster.Messaging
Assembly: DotNext.Net.Cluster.dll
Syntax
public interface ISubscriber : IClusterMember, IPeer, IOutputChannel

Methods

| Edit this page View Source

SendSignalAsync(IMessage, bool, CancellationToken)

Sends one-way message to this cluster member.

Declaration
Task SendSignalAsync(IMessage message, bool requiresConfirmation = true, CancellationToken token = default)
Parameters
Type Name Description
IMessage message

The message to be sent.

bool requiresConfirmation

true to wait for confirmation of delivery from receiver; otherwise, false.

CancellationToken token

The token that can be used to cancel asynchronous operation.

Returns
Type Description
Task

The task representing execution of this method.

Exceptions
Type Condition
InvalidOperationException

Attempts to send message to local or unavailable member.

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.SendJsonMessageAsync<TRequest, TResponse>(ISubscriber, MessageReader<TResponse>, string, TRequest, CancellationToken)
Messenger.SendJsonSignalAsync<TSignal>(ISubscriber, string, TSignal, bool, CancellationToken)
Messenger.SendTextMessageAsync<TResponse>(ISubscriber, MessageReader<TResponse>, string, string, string?, CancellationToken)
Messenger.SendTextSignalAsync(ISubscriber, string, string, bool, string?, CancellationToken)
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
☀
☾