Namespace Silverback.Messaging.Sequences

Classes

AddToSequenceResult

Encapsulates the result of the AddAsync(IRawInboundEnvelope, ISequence?, bool) method.

IncompleteSequence

Represent an incomplete sequence (missing the first message) and is used to signal the pipeline to ignore the message.

RawSequence

Represents a set of logically related messages, like the chunks belonging to the same message or the messages in a dataset.

RawSequencerConsumerBehavior

Uses the available implementations of ISequenceReader to assign the incoming message to the right sequence.

Sequence

Represents a set of logically related messages, like the chunks belonging to the same message or the messages in a dataset.

SequenceBase<TEnvelope>

Represents a set of logically related messages, like the chunks belonging to the same message or the messages in a dataset.

SequenceException

The exception that is thrown when a sequence cannot be properly recreated (e.g. because of bad ordering or similar).

SequenceReaderBase

The base class for the ISequenceReader implementations. It encapsulates the logic to deal with the ISequenceStore.

SequenceSettings

The sequence handling settings.

SequencerConsumerBehavior

Uses the available implementations of ISequenceReader to assign the incoming message to the right sequence.

SequencerConsumerBehaviorBase

Uses the available implementations of ISequenceReader to assign the incoming message to the right sequence.

SequencerProducerBehavior

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

Interfaces

ISequence

Represents a set of logically related messages, like the chunks belonging to the same message or the messages in a dataset.

ISequenceReader

Can recognize a message that belongs to a sequence and match it with the proper ISequence instance.

ISequenceStore

The temporary store for the sequences being consumed.

ISequenceWriter

Can set the headers used to match the message with the sequence it belongs to. If needed it can also split a single message into multiple messages.

Enums

SequenceAbortReason

The possible reasons for a sequence to be aborted.