Show / Hide Table of Contents

Interface ISubscriber

Represents cluster member that supports messaging.

Inherited Members
IClusterMember.Endpoint
IClusterMember.Id
IClusterMember.IsLeader
IClusterMember.IsRemote
IClusterMember.MemberStatusChanged
IClusterMember.Status
IClusterMember.GetMetadataAsync(Boolean, CancellationToken)
IClusterMember.ResignAsync(CancellationToken)
IClusterMember.OnMemberStatusChanged(IClusterMember, AtomicEnum<ClusterMemberStatus>, ClusterMemberStatus, ClusterMemberStatusChanged)
IOutputChannel.SendMessageAsync<TResponse>(IMessage, MessageReader<TResponse>, CancellationToken)
IOutputChannel.SendSignalAsync(IMessage, CancellationToken)
Namespace: DotNext.Net.Cluster.Messaging
Assembly: DotNext.Net.Cluster.dll
Syntax
public interface ISubscriber : IClusterMember, IOutputChannel

Methods

| Improve this Doc View Source

SendSignalAsync(IMessage, Boolean, CancellationToken)

Sends one-way message to this cluster member.

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

The message to be sent.

Boolean 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.

Explicit Interface Implementations

| Improve this Doc View Source

IOutputChannel.SendSignalAsync(IMessage, CancellationToken)

Declaration
Task IOutputChannel.SendSignalAsync(IMessage message, CancellationToken token)
Parameters
Type Name Description
IMessage message
CancellationToken token
Returns
Type Description
Task

Extension Methods

Messenger.SendTextMessageAsync<TResponse>(ISubscriber, MessageReader<TResponse>, String, String, String, CancellationToken)
Messenger.SendTextSignalAsync(ISubscriber, String, String, Boolean, String, CancellationToken)
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