Class SequencerProducerBehavior

Uses the available implementations of ISequenceWriter to set the proper headers and split the published message or messages set to create the sequences.

Inheritance

object

SequencerProducerBehavior

Implements

IProducerBehavior

IBrokerBehavior

ISorted

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Namespace: Silverback.Messaging.Sequences

Assembly: Silverback.Integration.dll

Syntax

public class SequencerProducerBehavior : IProducerBehavior, IBrokerBehavior, ISorted

Remarks

A sequence is a set of messages that are handled as a single unit of work. A sequence could be used to group all chunks belonging to the same source message, all messages belonging to the same data set or to implement batch processing.

Constructors

SequencerProducerBehavior(IEnumerable<ISequenceWriter>)

Initializes a new instance of the SequencerProducerBehavior class.

Declaration

public SequencerProducerBehavior(IEnumerable<ISequenceWriter> sequenceWriters)

Parameters

Type	Name	Description
IEnumerable<ISequenceWriter>	sequenceWriters	The ISequenceWriter implementations to be used.

Remarks

A sequence is a set of messages that are handled as a single unit of work. A sequence could be used to group all chunks belonging to the same source message, all messages belonging to the same data set or to implement batch processing.

Properties

SortIndex

Gets the sort index.

Declaration

public int SortIndex { get; }

Property Value

Type	Description
int

Remarks

A sequence is a set of messages that are handled as a single unit of work. A sequence could be used to group all chunks belonging to the same source message, all messages belonging to the same data set or to implement batch processing.

Methods

HandleAsync(ProducerPipelineContext, ProducerBehaviorHandler, CancellationToken)

Process, handles or transforms the message being produced.

Declaration

public ValueTask HandleAsync(ProducerPipelineContext context, ProducerBehaviorHandler next, CancellationToken cancellationToken)

Parameters

Type	Name	Description
ProducerPipelineContext	context	The context that is passed along the behaviors pipeline.
ProducerBehaviorHandler	next	The next behavior in the pipeline.
CancellationToken	cancellationToken	The cancellation token that can be used to cancel the operation.

Returns

Type	Description
ValueTask	A ValueTask representing the asynchronous operation.

Remarks

A sequence is a set of messages that are handled as a single unit of work. A sequence could be used to group all chunks belonging to the same source message, all messages belonging to the same data set or to implement batch processing.

Implements

IProducerBehavior

IBrokerBehavior

ISorted