Class RawSequencerConsumerBehavior
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
Assembly: Silverback.Integration.dll
Syntax
public class RawSequencerConsumerBehavior : SequencerConsumerBehaviorBase, IConsumerBehavior, IBrokerBehavior, ISorted
Constructors
| Improve this doc View sourceRawSequencerConsumerBehavior(IEnumerable<ISequenceReader>, ISilverbackLogger<RawSequencerConsumerBehavior>)
Initializes a new instance of the RawSequencerConsumerBehavior class.
Declaration
public RawSequencerConsumerBehavior(IEnumerable<ISequenceReader> sequenceReaders, ISilverbackLogger<RawSequencerConsumerBehavior> logger)
Parameters
Type | Name | Description |
---|---|---|
System.Collections.Generic.IEnumerable<ISequenceReader> | sequenceReaders | The ISequenceReader implementations to be used. |
ISilverbackLogger<RawSequencerConsumerBehavior> | logger | The ISilverbackLogger. |
Properties
| Improve this doc View sourceSortIndex
Declaration
public override int SortIndex { get; }
Property Value
Type | Description |
---|---|
System.Int32 |
Overrides
Methods
| Improve this doc View sourceAwaitOtherBehaviorIfNeededAsync(ISequence)
Declaration
protected override async Task AwaitOtherBehaviorIfNeededAsync(ISequence sequence)
Parameters
Type | Name | Description |
---|---|---|
ISequence | sequence |
Returns
Type | Description |
---|---|
System.Threading.Tasks.Task |
Overrides
| Improve this doc View sourcePublishSequenceAsync(ConsumerPipelineContext, ConsumerBehaviorHandler)
Declaration
protected override Task PublishSequenceAsync(ConsumerPipelineContext context, ConsumerBehaviorHandler next)
Parameters
Type | Name | Description |
---|---|---|
ConsumerPipelineContext | context | |
ConsumerBehaviorHandler | next |
Returns
Type | Description |
---|---|
System.Threading.Tasks.Task |
Overrides
SequencerConsumerBehaviorBase.PublishSequenceAsync(ConsumerPipelineContext, ConsumerBehaviorHandler)