Pipeline Samples

Samples

Add feature toggles to handlers
Checks feature toggles to determine whether or not a handler should be executed for a given message.
Add handler timing pipeline
Wraps handlers in a Stopwatch and logs a warning if a handler exceeds a given threshold.
Audit Filter Pipeline Extension
Extending the pipeline to stop certain messages from being audited.
Consuming MassTransit messages with NServiceBus
Use the NServiceBus pipeline to consume messages sent by MassTransit.
Control of serialization via the pipeline
Support for attribute-based message serialization.
Dispatch notification pipeline extension
Extending the pipeline to fire a notification when messages are dispatched.
Handling Stream Properties Via the Pipeline
Add support for writing streams to a file share that can be accessed by multiple endpoints.
Header propagation using the pipeline
How to use the pipeline to copy a header from incoming messages to outgoing messages.
Message signing using the pipeline
Shows how to implement message signing and verification using NServiceBus pipeline behaviors.
Message Throughput Throttling
Repair malformed messages using pipeline behavior
A sample showing how repair malformed messages by implementing a pipeline behavior.
Session filter pipeline extension
How to extend the pipeline to filter out messages from older sessions.
Unit of work using the pipeline
Shows how to use IoC and the pipeline to create a unit of work implementation.

Last modified 2022 May 26 22:02