Class ChunkSequenceReader

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

Inheritance

object

SequenceReaderBase

ChunkSequenceReader

Implements

ISequenceReader

Inherited Members

SequenceReaderBase.HandlesRawMessages

SequenceReaderBase.GetSequenceAsync(ConsumerPipelineContext)

SequenceReaderBase.GetSequenceIdAsync(ConsumerPipelineContext)

SequenceReaderBase.CreateNewSequenceAsync(string, ConsumerPipelineContext)

SequenceReaderBase.GetExistingSequenceAsync(ConsumerPipelineContext, string)

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Namespace: Silverback.Messaging.Sequences.Chunking

Assembly: Silverback.Integration.dll

Syntax

public class ChunkSequenceReader : SequenceReaderBase, ISequenceReader

Constructors

ChunkSequenceReader()

Initializes a new instance of the ChunkSequenceReader class.

Declaration

public ChunkSequenceReader()

Methods

CanHandleAsync(ConsumerPipelineContext)

Checks whether this reader can and must handle the message being processed in the specified context.

Declaration

public override Task<bool> CanHandleAsync(ConsumerPipelineContext context)

Parameters

Type	Name	Description
ConsumerPipelineContext	context	The current ConsumerPipelineContext.

Returns

Type	Description
Task<bool>	A Task<TResult> representing the asynchronous operation. The task result contains a value indicating whether this reader can and must handle the message.

Overrides

SequenceReaderBase.CanHandleAsync(ConsumerPipelineContext)

CreateNewSequenceCore(string, ConsumerPipelineContext)

Creates the new sequence object.

Declaration

protected override ISequence CreateNewSequenceCore(string sequenceId, ConsumerPipelineContext context)

Parameters

Type	Name	Description
string	sequenceId	The sequence identifier.
ConsumerPipelineContext	context	The current ConsumerPipelineContext.

Returns

Type	Description
ISequence	The new sequence.

Overrides

SequenceReaderBase.CreateNewSequenceCore(string, ConsumerPipelineContext)

IsNewSequenceAsync(string, ConsumerPipelineContext)

Determines if the current message correspond with the beginning of a new sequence.

Declaration

protected override Task<bool> IsNewSequenceAsync(string sequenceId, ConsumerPipelineContext context)

Parameters

Type	Name	Description
string	sequenceId	The sequence identifier.
ConsumerPipelineContext	context	The current ConsumerPipelineContext.

Returns

Type	Description
Task<bool>	A Task<TResult> representing the asynchronous operation. The task result contains true if a new sequence is starting; otherwise false.

Overrides

SequenceReaderBase.IsNewSequenceAsync(string, ConsumerPipelineContext)

Implements

ISequenceReader