Interface ILargePayloadStore

Namespace

AnyProtocol.Storage.Abstraction

Assembly

AnyProtocol.Storage.Abstraction.dll

Stores serialized message bodies outside a messaging transport.

public interface ILargePayloadStore

Properties

Name

Gets the logical provider registration name.

string Name { get; }

Property Value

string

Methods

DeleteAsync(StoredPayloadReference, CancellationToken)

Deletes a stored body for administrative cleanup.

ValueTask DeleteAsync(StoredPayloadReference reference, CancellationToken cancellationToken = default)

Parameters

reference StoredPayloadReference

cancellationToken CancellationToken

Returns

ValueTask

LoadAsync(StoredPayloadReference, CancellationToken)

Loads a previously stored body.

ValueTask<ReadOnlyMemory<byte>> LoadAsync(StoredPayloadReference reference, CancellationToken cancellationToken = default)

Parameters

reference StoredPayloadReference

cancellationToken CancellationToken

Returns

ValueTask<ReadOnlyMemory<byte>>

StoreAsync(string, ReadOnlyMemory<byte>, PayloadWriteOptions, CancellationToken)

Stores a body using the message identifier as the idempotency key.

ValueTask<StoredPayloadReference> StoreAsync(string messageId, ReadOnlyMemory<byte> payload, PayloadWriteOptions options, CancellationToken cancellationToken = default)

Parameters

messageId string

payload ReadOnlyMemory<byte>

options PayloadWriteOptions

cancellationToken CancellationToken

Returns

ValueTask<StoredPayloadReference>