Class SequencerConsumerBehavior

Namespace

Silverback.Messaging.Sequences

Assembly

Silverback.Integration.dll

Uses the available implementations of ISequenceReader to assign the incoming message to the right sequence.

public class SequencerConsumerBehavior : SequencerConsumerBehaviorBase, IConsumerBehavior, IBrokerBehavior, ISorted

Inheritance

object

SequencerConsumerBehaviorBase

SequencerConsumerBehavior

Implements

IConsumerBehavior

IBrokerBehavior

ISorted

Inherited Members

SequencerConsumerBehaviorBase.AwaitOtherBehaviorIfNeededAsync(ISequence)

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

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

SequencerConsumerBehavior(IEnumerable<ISequenceReader>, ISilverbackLogger<SequencerConsumerBehavior>)

Initializes a new instance of the SequencerConsumerBehavior class.

public SequencerConsumerBehavior(IEnumerable<ISequenceReader> sequenceReaders, ISilverbackLogger<SequencerConsumerBehavior> logger)

Parameters

sequenceReaders IEnumerable<ISequenceReader>

The ISequenceReader implementations to be used.

logger ISilverbackLogger<SequencerConsumerBehavior>

The ISilverbackLogger.

Properties

SortIndex

Gets the sort index.

public override int SortIndex { get; }

Property Value

int

Methods

HandleAsync(ConsumerPipelineContext, ConsumerBehaviorHandler, CancellationToken)

Process, handles or transforms the message being consumed.

public override ValueTask HandleAsync(ConsumerPipelineContext context, ConsumerBehaviorHandler next, CancellationToken cancellationToken)

Parameters

context ConsumerPipelineContext

The context that is passed along the behaviors pipeline.

next ConsumerBehaviorHandler

The next behavior in the pipeline.

cancellationToken CancellationToken

The cancellation token that can be used to cancel the operation.

Returns

ValueTask

A ValueTask representing the asynchronous operation.

PublishSequenceAsync(ConsumerPipelineContext, ConsumerBehaviorHandler, CancellationToken)

Forwards the new sequence to the next behavior in the pipeline.

protected override ValueTask PublishSequenceAsync(ConsumerPipelineContext context, ConsumerBehaviorHandler next, CancellationToken cancellationToken)

Parameters

context ConsumerPipelineContext

The context that is passed along the behaviors pipeline.

next ConsumerBehaviorHandler

The next behavior in the pipeline.

cancellationToken CancellationToken

The cancellation token that can be used to cancel the operation.

Returns

ValueTask

A Task representing the asynchronous operation.