Class RawSequence

Namespace

Silverback.Messaging.Sequences

Assembly

Silverback.Integration.dll

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

public abstract class RawSequence : SequenceBase<IRawInboundEnvelope>, ISequence, IDisposable

Inheritance

object

SequenceBase<IRawInboundEnvelope>

RawSequence

Implements

ISequence

IDisposable

Derived

ChunkSequence

IncompleteSequence

Inherited Members

SequenceBase<IRawInboundEnvelope>.CreateStream<TMessage>(IReadOnlyCollection<IMessageFilter>)

SequenceBase<IRawInboundEnvelope>.AddAsync(IRawInboundEnvelope, ISequence, bool)

SequenceBase<IRawInboundEnvelope>.AbortIfIncompleteAsync()

SequenceBase<IRawInboundEnvelope>.AbortAsync(SequenceAbortReason, Exception)

SequenceBase<IRawInboundEnvelope>.GetCommitIdentifiers()

SequenceBase<IRawInboundEnvelope>.GetRollbackIdentifiers()

SequenceBase<IRawInboundEnvelope>.Dispose()

SequenceBase<IRawInboundEnvelope>.AddCoreAsync(IRawInboundEnvelope, ISequence, bool)

SequenceBase<IRawInboundEnvelope>.IsLastMessage(IRawInboundEnvelope)

SequenceBase<IRawInboundEnvelope>.CompleteAsync(CancellationToken)

SequenceBase<IRawInboundEnvelope>.Dispose(bool)

SequenceBase<IRawInboundEnvelope>.OnTimeoutElapsedAsync()

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>.StreamProvider

SequenceBase<IRawInboundEnvelope>.ParentSequence

SequenceBase<IRawInboundEnvelope>.AbortException

SequenceBase<IRawInboundEnvelope>.Length

SequenceBase<IRawInboundEnvelope>.TotalLength

SequenceBase<IRawInboundEnvelope>.IsNew

SequenceBase<IRawInboundEnvelope>.IsCompleting

SequenceBase<IRawInboundEnvelope>.IsComplete

SequenceBase<IRawInboundEnvelope>.AbortReason

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

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

Initializes a new instance of the RawSequence class.

protected RawSequence(string sequenceId, ConsumerPipelineContext context, bool enforceTimeout = true, TimeSpan? timeout = null, IMessageStreamProvider? streamProvider = null)

Parameters

sequenceId string

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

context ConsumerPipelineContext

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

enforceTimeout bool

A value indicating whether the timeout has to be enforced.

timeout TimeSpan?

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

streamProvider IMessageStreamProvider

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