Class NatsMessage

Provides a base class for NATS message operations, supporting asynchronous disposal and message serialization.

public abstract class NatsMessage : AsyncDisposable, IDisposable, IAsyncDisposable, IHealthCheckProvider<INatsConnection>

Implements: IDisposable

IAsyncDisposable

IHealthCheckProvider<INatsConnection>

Inherited Members: AsyncDisposable.OnDisposeManagedResources()

AsyncDisposable.DisposeAsync()

Disposable.OnDisposeUnmanagedResources()

Disposable.Dispose()

Disposable.Dispose(bool)

Disposable.Disposed

Constructors

Initializes a new instance of the NatsMessage class with the specified marshaller and options.

protected NatsMessage(IMarshaller marshaller, NatsMessageOptions options)

marshaller IMarshaller: The marshaller used for serializing and deserializing messages.
options NatsMessageOptions: The configuration options for the NATS message.

ArgumentNullException: marshaller cannot be null - or - options cannot be null.
ArgumentException: options are not in a valid state.

Gets the marshaller provided by the constructor for serializing and deserializing messages.

protected IMarshaller Marshaller { get; }

IMarshaller: The marshaller used for message serialization and deserialization.

Gets the NATS client provided by the constructor for communication with the NATS server.

protected NatsClient NatsClient { get; }

Gets the NATS.Client.Core.INatsConnection instance used for probing the health status of the NATS server.

public INatsConnection GetHealthCheckTarget()

INatsConnection: NATS.Client.Core.INatsConnection instance representing the active connection to the NATS server.

Releases the managed resources used by the NatsMessage asynchronously.

protected override ValueTask OnDisposeManagedResourcesAsync()