Interface ISequenceWriter
- Namespace
- Silverback.Messaging.Sequences
- Assembly
- Silverback.Integration.dll
Can set the headers used to match the message with the sequence it belongs to. If needed it can also split a single message into multiple messages.
public interface ISequenceWriter
Methods
CanHandle(IOutboundEnvelope)
Checks whether this writer can and must handle the specified message.
bool CanHandle(IOutboundEnvelope envelope)
Parameters
envelopeIOutboundEnvelopeThe envelope containing the message to be handled.
Returns
- bool
A value indicating whether this writer can and must handle the message.
ProcessMessageAsync(IOutboundEnvelope)
Sets the headers used to match the message with the sequence it belongs to. If needed it can also split a single message into multiple messages.
IAsyncEnumerable<IOutboundEnvelope> ProcessMessageAsync(IOutboundEnvelope envelope)
Parameters
envelopeIOutboundEnvelopeThe envelope containing the message to be handled.
Returns
- IAsyncEnumerable<IOutboundEnvelope>
An IAsyncEnumerable<T> with the envelopes containing the messages to be produced.