Show / Hide Table of Contents

Interface IMessageHandler

Represents incoming message handler that can be registered in DI container.

Namespace: DotNext.Net.Cluster.Messaging
Assembly: DotNext.AspNetCore.Cluster.dll
Syntax
public interface IMessageHandler

Methods

| Improve this Doc View Source

ReceiveMessage(ISubscriber, IMessage, Object)

Handles incoming message from the specified cluster member.

Declaration
Task<IMessage> ReceiveMessage(ISubscriber sender, IMessage message, object context)
Parameters
Type Name Description
ISubscriber sender

The sender of the message.

IMessage message

The received message.

Object context

The context of the underlying network request.

Returns
Type Description
Task<IMessage>

The response message.

Remarks

Implementation of this method should handle every exception inside of it and prepare response message representing such exception.

| Improve this Doc View Source

ReceiveSignal(ISubscriber, IMessage, Object)

Handles incoming signal from the specified cluster member.

Declaration
Task ReceiveSignal(ISubscriber sender, IMessage signal, object context)
Parameters
Type Name Description
ISubscriber sender

The sender of the message.

IMessage signal

The received message representing signal.

Object context

The context of the underlying network request.

Returns
Type Description
Task

The task representing asynchronous execution of the method.

Extension Methods

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)
ExpressionBuilder.Const<T>(T)
ObjectExtensions.GetUserData<T>(T)
ObjectExtensions.IsOneOf<T>(T, IEnumerable<T>)
ObjectExtensions.IsOneOf<T>(T, T[])
ObjectExtensions.Decompose<T, R1, R2>(T, Func<T, R1>, Func<T, R2>, out R1, out R2)
ObjectExtensions.Decompose<T, R1, R2>(T, ValueFunc<T, R1>, ValueFunc<T, R2>, out R1, out R2)
ObjectExtensions.Decompose<T, R1, R2>(T, Func<T, R1>, Func<T, R2>)
ObjectExtensions.Decompose<T, R1, R2>(T, ValueFunc<T, R1>, ValueFunc<T, R2>)
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)
  • Improve this Doc
  • View Source
Back to top Generated by DocFX