Show / Hide Table of Contents

    Class SequencerProducerBehavior

    Uses the available implementations of ISequenceWriter to set the proper headers and split the published message or messages set to create the sequences.

    Inheritance
    object
    SequencerProducerBehavior
    Implements
    IProducerBehavior
    IBrokerBehavior
    ISorted
    Inherited Members
    object.Equals(object)
    object.Equals(object, object)
    object.GetHashCode()
    object.GetType()
    object.MemberwiseClone()
    object.ReferenceEquals(object, object)
    object.ToString()
    Namespace: Silverback.Messaging.Sequences
    Assembly: Silverback.Integration.dll
    Syntax
    public class SequencerProducerBehavior : IProducerBehavior, IBrokerBehavior, ISorted
    Remarks

    A sequence is a set of messages that are handled as a single unit of work. A sequence could be used to group all chunks belonging to the same source message, all messages belonging to the same data set or to implement batch processing.

    Constructors

    | Improve this doc View source

    SequencerProducerBehavior(IEnumerable<ISequenceWriter>)

    Initializes a new instance of the SequencerProducerBehavior class.

    Declaration
    public SequencerProducerBehavior(IEnumerable<ISequenceWriter> sequenceWriters)
    Parameters
    Type Name Description
    IEnumerable<ISequenceWriter> sequenceWriters

    The ISequenceWriter implementations to be used.

    Remarks

    A sequence is a set of messages that are handled as a single unit of work. A sequence could be used to group all chunks belonging to the same source message, all messages belonging to the same data set or to implement batch processing.

    Properties

    | Improve this doc View source

    SortIndex

    Gets the sort index.

    Declaration
    public int SortIndex { get; }
    Property Value
    Type Description
    int
    Remarks

    A sequence is a set of messages that are handled as a single unit of work. A sequence could be used to group all chunks belonging to the same source message, all messages belonging to the same data set or to implement batch processing.

    Methods

    | Improve this doc View source

    HandleAsync(ProducerPipelineContext, ProducerBehaviorHandler)

    Process, handles or transforms the message being produced.

    Declaration
    public Task HandleAsync(ProducerPipelineContext context, ProducerBehaviorHandler next)
    Parameters
    Type Name Description
    ProducerPipelineContext context

    The context that is passed along the behaviors pipeline.

    ProducerBehaviorHandler next

    The next behavior in the pipeline.

    Returns
    Type Description
    Task

    A Task representing the asynchronous operation.

    Remarks

    A sequence is a set of messages that are handled as a single unit of work. A sequence could be used to group all chunks belonging to the same source message, all messages belonging to the same data set or to implement batch processing.

    Implements

    IProducerBehavior
    IBrokerBehavior
    ISorted
    • Improve this doc
    • View source
    GitHub E-Mail
    ↑ Back to top © 2020 Sergio Aquilini