Interface IMessageDataRepository

Namespace

MassTransit

Assembly

MassTransit.Abstractions.dll

Storage of large message data that can be stored and retrieved separate of the message body. Implemented as a claim-check pattern when an identifier is stored in the message body which is used to retrieve the message data separately.

public interface IMessageDataRepository

Methods

Get(Uri, CancellationToken)

Returns a stream to read the message data for the specified address.

Task<Stream> Get(Uri address, CancellationToken cancellationToken = default)

Parameters

address Uri

The data address

cancellationToken CancellationToken

A cancellation token for the request

Returns

Task<Stream>

Put(Stream, TimeSpan?, CancellationToken)

Puts message data into the repository

Task<Uri> Put(Stream stream, TimeSpan? timeToLive = null, CancellationToken cancellationToken = default)

Parameters

stream Stream

The stream of data for the message

timeToLive TimeSpan?

cancellationToken CancellationToken

Returns

Task<Uri>