MassTransit - Middleware, Pipes and Filters

In this episode, creating middleware filters for the consume, send, and publish pipes are explained, along with the standard receive pipeline. The same sample created last time, Trashlantis, is used to keep it simple and show how to create filters, add filters to the pipeline, and also access container providers to resolve components.

Sample Repository

MassTransit

Connect with me on Twitter:

[wihannel]

Where do these lovely pipeline images (flow charts) now live? This would be so helpful to view as we are integrating MassTransit at our org now

[mdx]

Brilliant! Helped me a lot! Thanks Chris.

[userrandomius]

Hello Chris, thanks for the video!
I don't understand how to filter a message, what if I don't want that some message does not get to consumer ?
I have implemented my filter which is executed as shown on video, so if I want to skip message then how do I do that within Send method of my filter, please ?

[codingstyle]

Hi Chris. Love the intro. Thank you very much also for these series. I have one question though. Is there a ready way of sending an oauth2 access token via publishing and then decoding it in the consumer end?

[plamenyovchev]

Chris, I have a case where I'm sending access token when publishing a message to the queue like so:

await endpoint.Publish(heartbeat, c => c.Headers.Set(HeaderNames.Authorization, AccessToken));

I'm wondering is the CustomFilter a good place to validate the access token and if the token is invalid to skip calling next.Send(...) ?

[jhonjairosuarezgomez]

can I add a filter using MassTransit mediator?

[shlomiassaf]

Great work!
For me it looks very similar to reactive extensions (Observables world, Rx.NET) which I work with a lot.
Maybe there's a way to hook up the two, gaining the power of LINQ and the various RX operators.

Thank you!