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
System.Object
SequencerProducerBehavior
Inherited Members
System.Object.Equals(System.Object)
System.Object.Equals(System.Object, System.Object)
System.Object.GetHashCode()
System.Object.GetType()
System.Object.MemberwiseClone()
System.Object.ReferenceEquals(System.Object, System.Object)
System.Object.ToString()
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

| Improve this doc View source

SequencerProducerBehavior(IEnumerable<ISequenceWriter>)

Initializes a new instance of the SequencerProducerBehavior class.

Declaration
public SequencerProducerBehavior(IEnumerable<ISequenceWriter> sequenceWriters)
Parameters
Type Name Description
System.Collections.Generic.IEnumerable<ISequenceWriter> sequenceWriters

The ISequenceWriter implementations to be used.

Properties

| Improve this doc View source

SortIndex

Declaration
public int SortIndex { get; }
Property Value
Type Description
System.Int32

Methods

| Improve this doc View source

HandleAsync(ProducerPipelineContext, ProducerBehaviorHandler)

Declaration
public async Task HandleAsync(ProducerPipelineContext context, ProducerBehaviorHandler next)
Parameters
Type Name Description
ProducerPipelineContext context
ProducerBehaviorHandler next
Returns
Type Description
System.Threading.Tasks.Task

Implements