Class NatsCommandQueue.ReceivedNatsMessage

Namespace

Savvyio.Extensions.NATS.Commands

Assembly

Savvyio.Extensions.NATS.dll

Represents a NATS message received from JetStream.

protected sealed class NatsCommandQueue.ReceivedNatsMessage

Inheritance

object

NatsCommandQueue.ReceivedNatsMessage

Constructors

ReceivedNatsMessage(NatsHeaders, string, Func<CancellationToken, Task>)

Initializes a new instance of the NatsCommandQueue.ReceivedNatsMessage class.

public ReceivedNatsMessage(NatsHeaders headers, string data, Func<CancellationToken, Task> acknowledgeAsync)

Parameters

headers NatsHeaders

The NATS message headers.

data string

The NATS message payload.

acknowledgeAsync Func<CancellationToken, Task>

The delegate used to acknowledge the message.

Properties

Data

Gets the NATS message payload.

public string Data { get; }

Property Value

string

Headers

Gets the NATS message headers.

public NatsHeaders Headers { get; }

Property Value

NatsHeaders

Methods

AcknowledgeAsync(CancellationToken)

Acknowledges the message.

public Task AcknowledgeAsync(CancellationToken cancellationToken)

Parameters

cancellationToken CancellationToken

The cancellation token of the asynchronous operation.

Returns

Task

A task that represents the asynchronous operation.