An introduction to MassTransit using RabbitMQ (In ASP.NET Core)

[@Anja5233]

FOR ANYONE WATCHING IN 2023: AddMassTransitHostedService() is not necessary anymore, if it throws an error just delete it

[@vinr]

Even after two years, this is the best explanation on the subject, and I wish you continue to produce quality content, subbed!

[@DotNetCoreCentral]

Thanks, will do!

[@letsoverengineer]

Wow, so simply - thank you for the first half of the video - it helped understanding the api a lot!

[@DotNetCoreCentral]

@Michal Bilinski, thanks for watching!

[@JohnDoe-xi6df]

Based on the example from this video, I couldn't understand the benefit of using MassTransit. If I understand correctly, one service published a message and the other one consumed it. Isn't that what RabbitMQ does? What did we get by using MassTransit here?

[@akashkarve1991]

Awesome!!! video. Very easy to understand and explained it very well. Looking forward more videos on Mass Transit & RabbitMQ. Best thing I liked about this video is that you have explained it in both ways normal as well as with extension methods which helps to understand things in better way. Keep it up mate. Appreciate your work. Thanks!!!

[@DotNetCoreCentral]

@aakash karve, thanks for watching the video!

[@kysondarren460]

you prolly dont give a damn but does anybody know a trick to get back into an Instagram account..? I was stupid lost the account password. I would love any tricks you can give me!

[@lyricmathew8077]

@Kyson Darren Instablaster :)

[@kysondarren460]

@Lyric Mathew I really appreciate your reply. I found the site on google and im waiting for the hacking stuff atm. Looks like it's gonna take a while so I will get back to you later with my results.

[@kysondarren460]

@Lyric Mathew It worked and I now got access to my account again. I am so happy! Thank you so much, you really help me out :D

[@alirashidi795]

Thank you It was the best example out there in internet

[@DotNetCoreCentral]

Thank you!

[@Acesteef]

How would i use this if the two services cannot share the same namespace and cannot have a reference to the same Order model? I implemented this into both my microservices but they are both in a different namespace. Right now it is not sending or receiving any messages in RMQ.

[@avtarsashia4897]

Concept cleared. Its good tutorial to understand from basics

[@DotNetCoreCentral]

Thanks!

[@jeganathperialwar7788]

Explained well. Thanks for the wonderful lecture.

[@DotNetCoreCentral]

Thanks for watching!

[@christophertanghare4884]

I would like to see your video on saga pattern, I am watching for it 😁

[@DotNetCoreCentral]

@Christopher Tanghare, thanks! Hopefully this weekend.

[@lalpj4856]

Thank you😀

[@oguzsisman9851]

Thank you mate, very helpful

[@SuperSagar55]

Thank you, Can you create a video on Distributed transaction with saga orch. pattern.

[@DotNetCoreCentral]

@Sagar Khairnar, thanks for watching! I will definitely do a video on the Orchestration saga pattern.

[@lismai9906]

Why your publisher app's Configure(x) is using "temp-queue" but in your Consumer app, u r using "order-queue", isnt that gonna be an issue catching the message ?

[@mahendranchinnaiah7593]

Great effort. Thank you so much

[@DotNetCoreCentral]

@Mahendran Chinnaiah, thanks for watching as always! Appreciate your support.

[@mahendranchinnaiah7593]

@@DotNetCoreCentral am a big fan of your videos also eagerly waiting for your videos at Sunday 7pm cst

[@DotNetCoreCentral]

@@mahendranchinnaiah7593 thanks!

[@user-sv9fe5qf5h]

You help me a lot, I like the video and I will be your subscriber

[@DotNetCoreCentral]

Thanks for watching!

[@Gimmiyimmy]

Thank you. Very well explained

[@DotNetCoreCentral]

@Atul Srivastava, thanks for watching!

[@codewithkashif]

I am still not able to figure out that what is the exact benefit of using mass transit...all these things we can do with rabbitmq without using this masstransit too...because adding also add extra complexity and required learning curve. So there must be something where it is making major impact....kindly help

[@DotNetCoreCentral]

@Kashif Reza, MassTransit by default implements the pattern of Exchange -> Queue, which mostly needs a thorough understanding to do it the right way. So that is one of the advantages. The other advantage, which I did not cover in my video yet is the ability to simplify the distributed transactions, which I intend to cover in future videos.

[@codewithkashif]

​@@DotNetCoreCentral Thanks a lot for detailed answer! distributed transaction means, Does it helps in implementing SAGA? I heard it also helps in implementing Outbox pattern..please lemme know if you have any plan to post any video around that. also last question i.e. Is MassTransit also available for classic .net framework?

[@DotNetCoreCentral]

@@codewithkashif yes, by distributed transaction I mean the implementation of SAGA. I have a plan to do a video in the future on this. MassTransit works with classic .NET Framework also as I recollect.

[@shamilgurban6439]

Thanks for great tutorial. But i have a question. My models are seperated in different projects so i should create models in two places. How can i bind exchanges so exchange from one project can find exchange from another project. They have different namings by default :(

[@DotNetCoreCentral]

@Shamil Gurban, I am not sure I understand the question. Exchanges are used to publish messages, so any project can bind to the exchange to publish messages. If you are subscribing to an exchange, the same holds true, you can subscribe from any project. The filename does not matter for the data model, as long as both have the same property name when they are serialized in JSON.

[@lismai9906]

As long as your Contract class has the SAME NAMESPACE, it will trigger Consume(x) method. So ask your other dev for his namespace used in his "Order" class

[@andreicapi3535]

Thank you

[@DotNetCoreCentral]

@andrei capi, thanks for watching!

[@Gimmiyimmy]

I need to create topic exchange but don't know the syntex. Where I can find example and tutorials for this.

[@DotNetCoreCentral]

@Atul Srivastava, thanks for watching! You can do something like this: Host.ConnectReceiveEndpoint(yourqueue, x => { x.BindMessageExchanges = false; x.Consumer(); x.Bind(e => { e.RoutingKey = yourroutingkey; e.ExchangeType = ExchangeType.Topic; }); });

[@Gimmiyimmy]

Thank you so much. 🙏🙏

[@DotNetCoreCentral]

@@Gimmiyimmy you are welcome sir!

[@Gimmiyimmy]

@@DotNetCoreCentral Sir, Please don't call me sir. I am nothing in front of you. 😒

[@DotNetCoreCentral]

@@Gimmiyimmy we are all developers my friend, we all the same :)

[@sridharsathya8719]

Thanks.

[@DotNetCoreCentral]

@Sridhar Sathya, thanks for watching!

[@user-rp9iis1en6h]

Excellent tutorial. What if I deploy 2 consumers and in the queue there are many requests. Is there any chance that both consumers will pick the same message and create a conflict?

[@DotNetCoreCentral]

@S. Z., no it will never get the same message for 2 consumers for the same queue. And that's not a feature of Masstransit, it is how RabbitMQ or other underlying queuing engine works.

[@user-rp9iis1en6h]

@@DotNetCoreCentral in that case how multiple consumer will perform together? Suppose I have a queue called OrderPlaced. And there is two consumer, 1. PrepareDelivery 2. PrepareReceipt Whenever there is a item in order queue, these two consumer need to start their work. How this can be achieved with rabbitMq without using another new queue ?

[@DotNetCoreCentral]

@@user-rp9iis1en6h ​ for that each consumer have to have their dedicated queue, and connected from an exchange. I have covered this scenario in my RabbitMQ series.

[@user-rp9iis1en6h]

@@DotNetCoreCentral Yes I have already seen them but couldn't understand how to configure exchange using massTransit.

[@jelajahpasundanofficial]

Wow.. awesome. thank you dude. thank you so much

[@DotNetCoreCentral]

@risman afyandi, thanks for watching!

[@xxXAsuraXxx]

whats your preference between MassTransit and EasyNetQ?

[@DotNetCoreCentral]

@Kevin Wang, to be honest, MassTransit is a little advance and is very useful for managing complex workflow because it makes those easier. But if you have a very simple workflow, I will just use the default RabbitMQ client. I personally have never used EasyNetQ

[@xxXAsuraXxx]

Thank for the reply, does the masstransit saga only works only if you use their messaging api but not regular CQRS? I am still confused how their saga work and how does it work with dapper.

[@DotNetCoreCentral]

@@xxXAsuraXxx I have not used it yet, and the reason I have not used Masstransit with Saga because I like to keep more control of the code on my side instead of external packages where it makes sense. Saga is simple enough to do it yourself without using any framework, IMO.

[@kwiatu5]

JSON, is that you?