Class ChunkSequence

Represents a sequence of chunks that belong to the same message.

Inheritance
System.Object
SequenceBase<IRawInboundEnvelope>
RawSequence
ChunkSequence
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.Chunking
Assembly: Silverback.Integration.dll
Syntax
public class ChunkSequence : RawSequence, ISequence, IDisposable

Constructors

| Improve this doc View source

ChunkSequence(String, Nullable<Int32>, ConsumerPipelineContext)

Initializes a new instance of the ChunkSequence class.

Declaration
public ChunkSequence(string sequenceId, int? totalLength, ConsumerPipelineContext context)
Parameters
Type Name Description
System.String sequenceId

The identifier that is used to match the consumed messages with their belonging sequence.
System.Nullable<System.Int32> totalLength

The expected total length of the 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

AddCoreAsync(IRawInboundEnvelope, ISequence, Boolean)

Declaration
protected override Task<AddToSequenceResult> AddCoreAsync(IRawInboundEnvelope envelope, ISequence sequence, bool throwIfUnhandled)
Parameters
Type Name Description
IRawInboundEnvelope envelope
ISequence sequence
System.Boolean throwIfUnhandled
Returns
Type Description
System.Threading.Tasks.Task<AddToSequenceResult>
Overrides
Silverback.Messaging.Sequences.SequenceBase<Silverback.Messaging.Messages.IRawInboundEnvelope>.AddCoreAsync(Silverback.Messaging.Messages.IRawInboundEnvelope, Silverback.Messaging.Sequences.ISequence, System.Boolean)
| Improve this doc View source

IsLastMessage(IRawInboundEnvelope)

Declaration
protected override bool IsLastMessage(IRawInboundEnvelope envelope)
Parameters
Type Name Description
IRawInboundEnvelope envelope
Returns
Type Description
System.Boolean
Overrides
Silverback.Messaging.Sequences.SequenceBase<Silverback.Messaging.Messages.IRawInboundEnvelope>.IsLastMessage(Silverback.Messaging.Messages.IRawInboundEnvelope)

Implements

System.IDisposable