Class BatchSequenceReader

Enables the batch processing creating a BatchSequence containing the configured number of messages.

Inheritance
System.Object
SequenceReaderBase
BatchSequenceReader
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.Batch
Assembly: Silverback.Integration.dll
Syntax
public sealed class BatchSequenceReader : SequenceReaderBase, ISequenceReader, ISorted

Properties

| Improve this doc View source

SortIndex

Declaration
public int SortIndex { get; }
Property Value
Type Description
System.Int32

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

GetExistingSequenceAsync(ConsumerPipelineContext, String)

Declaration
protected override Task<ISequence> GetExistingSequenceAsync(ConsumerPipelineContext context, string sequenceId)
Parameters
Type Name Description
ConsumerPipelineContext context
System.String sequenceId
Returns
Type Description
System.Threading.Tasks.Task<ISequence>
Overrides
| Improve this doc View source

GetSequenceIdAsync(ConsumerPipelineContext)

Declaration
protected override Task<string> GetSequenceIdAsync(ConsumerPipelineContext context)
Parameters
Type Name Description
ConsumerPipelineContext context
Returns
Type Description
System.Threading.Tasks.Task<System.String>
Overrides
| Improve this doc View source

IsNewSequenceAsync(String, ConsumerPipelineContext)

Declaration
protected override async 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