Interface IMessageDistributor

Namespace

CarrotMQ.Core.MessageProcessing

Assembly

CarrotMQ.Core.dll

Represents a registry for processing CarrotMQ messages.

public interface IMessageDistributor

Remarks

The IMessageDistributor interface defines a contract for classes responsible for processing CarrotMQ messages.

Methods

DistributeAsync(CarrotMessage, CancellationToken)

Distributes the CarrotMQ message to all registered handlers and callback functions which are associated with the value of CalledMethod.

Task<DeliveryStatus> DistributeAsync(CarrotMessage carrotMessage, CancellationToken cancellationToken)

Parameters

carrotMessage CarrotMessage

The CarrotMQ message to be processed.

cancellationToken CancellationToken

CancellationToken

Returns

Task<DeliveryStatus>

A task representing the asynchronous operation and containing the result status of the message processing.