Class RawSequencerConsumerBehavior
Uses the available implementations of ISequenceReader to assign the incoming message to the right sequence.
Inherited Members
Namespace: Silverback.Messaging.Sequences
Assembly: Silverback.Integration.dll
Syntax
public class RawSequencerConsumerBehavior : SequencerConsumerBehaviorBase, IConsumerBehavior, IBrokerBehavior, ISortedRemarks
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 sourceRawSequencerConsumerBehavior(IEnumerable<ISequenceReader>, ISilverbackLogger<RawSequencerConsumerBehavior>)
Initializes a new instance of the RawSequencerConsumerBehavior class.
Declaration
public RawSequencerConsumerBehavior(IEnumerable<ISequenceReader> sequenceReaders, ISilverbackLogger<RawSequencerConsumerBehavior> logger)Parameters
| Type | Name | Description |
|---|---|---|
| IEnumerable<ISequenceReader> | sequenceReaders | The ISequenceReader implementations to be used. |
| ISilverbackLogger<RawSequencerConsumerBehavior> | logger | The ISilverbackLogger. |
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
| Improve this doc View sourceSortIndex
Gets the sort index.
Declaration
public override int SortIndex { get; }Property Value
| Type | Description |
|---|---|
| int |
Overrides
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
| Improve this doc View sourceAwaitOtherBehaviorIfNeededAsync(ISequence)
When overridden in a derived class awaits for the sequence to be processed by the other twin behavior. This is used to have the RawSequencerConsumerBehavior wait for the processing by the SequencerConsumerBehavior and it's needed to be able to properly determine the sequence end in the case where a ChunkSequence is added into another sequence (e.g. BatchSequence).
Declaration
protected override Task AwaitOtherBehaviorIfNeededAsync(ISequence sequence)Parameters
| Type | Name | Description |
|---|---|---|
| ISequence | sequence | The current sequence. |
Returns
| Type | Description |
|---|---|
| Task | A Task representing the asynchronous operation. |
Overrides
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.
PublishSequenceAsync(ConsumerPipelineContext, ConsumerBehaviorHandler)
Forwards the new sequence to the next behavior in the pipeline.
Declaration
protected override Task PublishSequenceAsync(ConsumerPipelineContext context, ConsumerBehaviorHandler next)Parameters
| Type | Name | Description |
|---|---|---|
| ConsumerPipelineContext | context | The context that is passed along the behaviors pipeline. |
| ConsumerBehaviorHandler | next | The next behavior in the pipeline. |
Returns
| Type | Description |
|---|---|
| Task | A Task representing the asynchronous operation. |
Overrides
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.