Show / Hide Table of Contents

    Class RawSequence

    Represents a set of logically related messages, like the chunks belonging to the same message or the messages in a dataset.

    Inheritance
    object
    SequenceBase<IRawInboundEnvelope>
    RawSequence
    ChunkSequence
    IncompleteSequence
    Implements
    ISequence
    IDisposable
    Inherited Members
    SequenceBase<IRawInboundEnvelope>.SequenceId
    SequenceBase<IRawInboundEnvelope>.IsPending
    SequenceBase<IRawInboundEnvelope>.IsAborted
    SequenceBase<IRawInboundEnvelope>.IsBeingConsumed
    SequenceBase<IRawInboundEnvelope>.Sequences
    SequenceBase<IRawInboundEnvelope>.Context
    SequenceBase<IRawInboundEnvelope>.SequencerBehaviorsTask
    SequenceBase<IRawInboundEnvelope>.ProcessingCompletedTask
    SequenceBase<IRawInboundEnvelope>.ShouldCreateNewActivity
    SequenceBase<IRawInboundEnvelope>.StreamProvider
    SequenceBase<IRawInboundEnvelope>.Activity
    SequenceBase<IRawInboundEnvelope>.ParentSequence
    SequenceBase<IRawInboundEnvelope>.AbortException
    SequenceBase<IRawInboundEnvelope>.Length
    SequenceBase<IRawInboundEnvelope>.TotalLength
    SequenceBase<IRawInboundEnvelope>.IsNew
    SequenceBase<IRawInboundEnvelope>.IsCompleting
    SequenceBase<IRawInboundEnvelope>.IsComplete
    SequenceBase<IRawInboundEnvelope>.AbortReason
    SequenceBase<IRawInboundEnvelope>.CreateStream<TMessage>(IReadOnlyCollection<IMessageFilter>)
    SequenceBase<IRawInboundEnvelope>.AddAsync(IRawInboundEnvelope, ISequence, bool)
    SequenceBase<IRawInboundEnvelope>.AbortAsync(SequenceAbortReason, Exception)
    SequenceBase<IRawInboundEnvelope>.GetBrokerMessageIdentifiers()
    SequenceBase<IRawInboundEnvelope>.Dispose()
    SequenceBase<IRawInboundEnvelope>.AddCoreAsync(IRawInboundEnvelope, ISequence, bool)
    SequenceBase<IRawInboundEnvelope>.IsLastMessage(IRawInboundEnvelope)
    SequenceBase<IRawInboundEnvelope>.CompleteAsync(CancellationToken)
    SequenceBase<IRawInboundEnvelope>.Dispose(bool)
    SequenceBase<IRawInboundEnvelope>.OnTimeoutElapsedAsync()
    object.Equals(object)
    object.Equals(object, object)
    object.GetHashCode()
    object.GetType()
    object.MemberwiseClone()
    object.ReferenceEquals(object, object)
    object.ToString()
    Namespace: Silverback.Messaging.Sequences
    Assembly: Silverback.Integration.dll
    Syntax
    public abstract class RawSequence : SequenceBase<IRawInboundEnvelope>, ISequence, IDisposable

    Constructors

    | Improve this doc View source

    RawSequence(string, ConsumerPipelineContext, bool, TimeSpan?, IMessageStreamProvider?)

    Initializes a new instance of the RawSequence class.

    Declaration
    protected RawSequence(string sequenceId, ConsumerPipelineContext context, bool enforceTimeout = true, TimeSpan? timeout = null, IMessageStreamProvider? streamProvider = null)
    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.

    bool enforceTimeout

    A value indicating whether the timeout has to be enforced.

    TimeSpan? timeout

    The timeout to be applied. If not specified the value of Endpoint.Sequence.Timeout will be used.

    IMessageStreamProvider streamProvider

    The IMessageStreamProvider to be pushed. A new one will be created if not provided.

    Implements

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