Interface IProduceStrategyImplementation

Namespace

Silverback.Messaging.Producing

Assembly

Silverback.Integration.dll

The strategy used to produce the messages.

public interface IProduceStrategyImplementation

Methods

ProduceAsync(IOutboundEnvelope, CancellationToken)

Produces the message in the specified envelope.

Task ProduceAsync(IOutboundEnvelope envelope, CancellationToken cancellationToken)

Parameters

envelope IOutboundEnvelope

The IOutboundEnvelope containing the message to be produced.

cancellationToken CancellationToken

The CancellationToken that can be used to cancel the operation.

Returns

Task

A Task representing the asynchronous operation.

ProduceAsync(IAsyncEnumerable<IOutboundEnvelope>, CancellationToken)

Produces the messages in the specified envelopes.

Task ProduceAsync(IAsyncEnumerable<IOutboundEnvelope> envelopes, CancellationToken cancellationToken)

Parameters

envelopes IAsyncEnumerable<IOutboundEnvelope>

The IOutboundEnvelope containing the messages to be produced.

cancellationToken CancellationToken

The CancellationToken that can be used to cancel the operation.

Returns

Task

A Task representing the asynchronous operation.

ProduceAsync(IEnumerable<IOutboundEnvelope>, CancellationToken)

Produces the messages in the specified envelopes.

Task ProduceAsync(IEnumerable<IOutboundEnvelope> envelopes, CancellationToken cancellationToken)

Parameters

envelopes IEnumerable<IOutboundEnvelope>

The IOutboundEnvelope containing the messages to be produced.

cancellationToken CancellationToken

The CancellationToken that can be used to cancel the operation.

Returns

Task

A Task representing the asynchronous operation.