Class BatchSequence

Represent an arbitrary sequence of messages created to consume unrelated messages in batch (see BatchSettings).

Inheritance
System.Object
SequenceBase<IInboundEnvelope>
Sequence
BatchSequence
Implements
System.IDisposable
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.Batch
Assembly: Silverback.Integration.dll
Syntax
public class BatchSequence : Sequence, ISequence, IDisposable

Constructors

| Improve this doc View source

BatchSequence(String, ConsumerPipelineContext)

Initializes a new instance of the BatchSequence class.

Declaration
public BatchSequence(string sequenceId, ConsumerPipelineContext context)
Parameters
Type Name Description
System.String sequenceId

The identifier that is used to match the consumed messages with their belonging sequence.
ConsumerPipelineContext context

The current ConsumerPipelineContext, assuming that it will be the one from which the sequence gets published to the internal bus.

Methods

| Improve this doc View source

OnTimeoutElapsedAsync()

Called when the timout is elapsed. In this special case the sequence is completed instead of aborted.

Declaration
protected override Task OnTimeoutElapsedAsync()
Returns
Type Description
System.Threading.Tasks.Task

A System.Threading.Tasks.Task representing the asynchronous operation.
Overrides
Silverback.Messaging.Sequences.SequenceBase<Silverback.Messaging.Messages.IInboundEnvelope>.OnTimeoutElapsedAsync()

Implements

System.IDisposable