Class ChaparMessageConsumer

Consumes ParcelMessage events published by the outbox, deserializes the inner domain event, and dispatches it using Zamin's Zamin.Core.Contracts.ApplicationServices.Events.IEventDispatcher. Inbox idempotency is enforced via Zamin.Extensions.MessageBus.Abstractions.IMessageInboxItemRepository.

Inheritance

object

ChaparMessageConsumer

Implements

IMessageHandler<ParcelMessage>

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.ReferenceEquals(object, object)

object.ToString()

Namespace: Chapar.Zamin.Consumer

Assembly: Chapar.Zamin.dll

Syntax

public sealed class ChaparMessageConsumer : IMessageHandler<ParcelMessage>

Constructors

ChaparMessageConsumer(IEventDispatcher, IMessageInboxItemRepository, IJsonSerializer, ILogger<ChaparMessageConsumer>)

Declaration

public ChaparMessageConsumer(IEventDispatcher dispatcher, IMessageInboxItemRepository inbox, IJsonSerializer serializer, ILogger<ChaparMessageConsumer> logger)

Parameters

Type	Name	Description
IEventDispatcher	dispatcher
IMessageInboxItemRepository	inbox
IJsonSerializer	serializer
ILogger<ChaparMessageConsumer>	logger

Methods

HandleAsync(ParcelMessage, CancellationToken)

Handles the incoming message. If this method throws, the bus will apply its configured retry / error policies.

Declaration

public Task HandleAsync(ParcelMessage message, CancellationToken cancellationToken = default)

Parameters

Type	Name	Description
ParcelMessage	message	The received message.
CancellationToken	cancellationToken	Cancellation token.

Returns

Type	Description
Task

Implements

IMessageHandler<TMessage>