Class ChunkSequenceWriter
Creates the chunks sequence according to the ChunkSettings.
Implements
Inherited Members
Namespace: Silverback.Messaging.Sequences.Chunking
Assembly: Silverback.Integration.dll
Syntax
public class ChunkSequenceWriter : ISequenceWriterConstructors
ChunkSequenceWriter(IChunkEnricherFactory, IServiceProvider)
Initializes a new instance of the ChunkSequenceWriter class.
Declaration
public ChunkSequenceWriter(IChunkEnricherFactory chunkEnricherFactory, IServiceProvider serviceProvider)Parameters
| Type | Name | Description |
|---|---|---|
| IChunkEnricherFactory | chunkEnricherFactory | |
| IServiceProvider | serviceProvider | The IServiceProvider. |
Methods
CanHandle(IOutboundEnvelope)
Checks whether this writer can and must handle the specified message.
Declaration
public bool CanHandle(IOutboundEnvelope envelope)Parameters
| Type | Name | Description |
|---|---|---|
| IOutboundEnvelope | envelope | The envelope containing the message to be handled. |
Returns
| Type | Description |
|---|---|
| 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.
Declaration
public IAsyncEnumerable<IOutboundEnvelope> ProcessMessageAsync(IOutboundEnvelope envelope)Parameters
| Type | Name | Description |
|---|---|---|
| IOutboundEnvelope | envelope | The envelope containing the message to be handled. |
Returns
| Type | Description |
|---|---|
| IAsyncEnumerable<IOutboundEnvelope> | An IAsyncEnumerable<T> with the envelopes containing the messages to be produced. |