Class ChunkSequenceReader

Creates a ChunkSequence containing all the chunks of the original message.

Inheritance
System.Object
SequenceReaderBase
ChunkSequenceReader
Implements
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 ChunkSequenceReader : SequenceReaderBase, ISequenceReader

Constructors

| Improve this doc View source

ChunkSequenceReader()

Initializes a new instance of the ChunkSequenceReader class.

Declaration
public ChunkSequenceReader()

Methods

| Improve this doc View source

CanHandleAsync(ConsumerPipelineContext)

Declaration
public override Task<bool> CanHandleAsync(ConsumerPipelineContext context)
Parameters
Type Name Description
ConsumerPipelineContext context
Returns
Type Description
System.Threading.Tasks.Task<System.Boolean>
Overrides
| Improve this doc View source

CreateNewSequenceCore(String, ConsumerPipelineContext)

Declaration
protected override ISequence CreateNewSequenceCore(string sequenceId, ConsumerPipelineContext context)
Parameters
Type Name Description
System.String sequenceId
ConsumerPipelineContext context
Returns
Type Description
ISequence
Overrides
| Improve this doc View source

IsNewSequenceAsync(String, ConsumerPipelineContext)

Declaration
protected override Task<bool> IsNewSequenceAsync(string sequenceId, ConsumerPipelineContext context)
Parameters
Type Name Description
System.String sequenceId
ConsumerPipelineContext context
Returns
Type Description
System.Threading.Tasks.Task<System.Boolean>
Overrides

Implements