Class InboxProcessor<TPayload, TResult>

Namespace

PatternKit.Messaging.Reliability

Assembly

PatternKit.Core.dll

Inbox processor that applies an idempotent receiver around a message handler.

public sealed class InboxProcessor<TPayload, TResult>

Type Parameters

TPayload

TResult

Inheritance

object

InboxProcessor<TPayload, TResult>

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.ReferenceEquals(object, object)

object.ToString()

Methods

Create(IdempotentReceiver<TPayload, TResult>)

Creates an inbox processor from an idempotent receiver.

public static InboxProcessor<TPayload, TResult> Create(IdempotentReceiver<TPayload, TResult> receiver)

Parameters

receiver IdempotentReceiver<TPayload, TResult>

Returns

InboxProcessor<TPayload, TResult>

ProcessAsync(Message<TPayload>, MessageContext?, CancellationToken)

Processes an inbox message through the configured idempotent receiver.

public ValueTask<IdempotentReceiverResult<TResult>> ProcessAsync(Message<TPayload> message, MessageContext? context = null, CancellationToken cancellationToken = default)

Parameters

message Message<TPayload>

context MessageContext

cancellationToken CancellationToken

Returns

ValueTask<IdempotentReceiverResult<TResult>>