Show / Hide Table of Contents

    Class BatchSequence

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

    Inheritance
    object
    SequenceBase<IInboundEnvelope>
    Sequence
    BatchSequence
    Implements
    ISequence
    IDisposable
    Inherited Members
    SequenceBase<IInboundEnvelope>.SequenceId
    SequenceBase<IInboundEnvelope>.IsPending
    SequenceBase<IInboundEnvelope>.IsAborted
    SequenceBase<IInboundEnvelope>.IsBeingConsumed
    SequenceBase<IInboundEnvelope>.Sequences
    SequenceBase<IInboundEnvelope>.Context
    SequenceBase<IInboundEnvelope>.SequencerBehaviorsTask
    SequenceBase<IInboundEnvelope>.ProcessingCompletedTask
    SequenceBase<IInboundEnvelope>.ShouldCreateNewActivity
    SequenceBase<IInboundEnvelope>.StreamProvider
    SequenceBase<IInboundEnvelope>.Activity
    SequenceBase<IInboundEnvelope>.ParentSequence
    SequenceBase<IInboundEnvelope>.AbortException
    SequenceBase<IInboundEnvelope>.Length
    SequenceBase<IInboundEnvelope>.TotalLength
    SequenceBase<IInboundEnvelope>.IsNew
    SequenceBase<IInboundEnvelope>.IsCompleting
    SequenceBase<IInboundEnvelope>.IsComplete
    SequenceBase<IInboundEnvelope>.AbortReason
    SequenceBase<IInboundEnvelope>.CreateStream<TMessage>(IReadOnlyCollection<IMessageFilter>)
    SequenceBase<IInboundEnvelope>.AddAsync(IRawInboundEnvelope, ISequence, bool)
    SequenceBase<IInboundEnvelope>.AbortAsync(SequenceAbortReason, Exception)
    SequenceBase<IInboundEnvelope>.GetBrokerMessageIdentifiers()
    SequenceBase<IInboundEnvelope>.Dispose()
    SequenceBase<IInboundEnvelope>.AddCoreAsync(IInboundEnvelope, ISequence, bool)
    SequenceBase<IInboundEnvelope>.IsLastMessage(IInboundEnvelope)
    SequenceBase<IInboundEnvelope>.CompleteAsync(CancellationToken)
    SequenceBase<IInboundEnvelope>.Dispose(bool)
    object.Equals(object)
    object.Equals(object, object)
    object.GetHashCode()
    object.GetType()
    object.MemberwiseClone()
    object.ReferenceEquals(object, object)
    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
    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
    Task

    A Task representing the asynchronous operation.

    Overrides
    SequenceBase<IInboundEnvelope>.OnTimeoutElapsedAsync()

    Implements

    ISequence
    IDisposable
    • Improve this doc
    • View source
    GitHub E-Mail
    ↑ Back to top © 2020 Sergio Aquilini