How to work with correlationId in EasyNetQ about easynetq

[GeraldLx]

Basically when you send a message to RabbitMQ you have some properties for this message and a payload. One of the properties is the correlation_id.

EasyNetQ, as the name shows, tries to simplify your life. So when you send a message (via a class), then it creates a RabbitMQ message with the serialized message as payload. While doing this it also generates a CorrelationId to give this message some kind of unique identifier, (The default implemantion is just Guid.NewGuid().ToString(), but you can replace it)

More or less this happens behind the scenes without any interaction necessary:
bus.SendReceive.Send(myMessage)

[shashankvivek]

@GeraldLx : Many thanks for your reply. How can we create this CreateBasicProperties() of EasyNetQ so that I override the default behavior and our correlationId.

[GeraldLx]

EasyNetQ has now many years of development behind, so there are a view ways to achieve this.

There is an interface ICorrelationIdGenerationStrategy which has one method GetCorrelationId. Just make your own version and register it in the DI when creating the bus.

You can also go over the Advanced bus. By going this route you are on a way deeper level where you have full control about the generated message. This way you can generate the properties manually and set the CorrelationId while sending.

You can also combine these. The logic behind the scenes is that EasyNetQ checks, if the correlation id was set otherwise it fills the correlation id with the value provided by the generation strategy.