How to set Correlation ID

[Ajeeth]

Hi All,

 

How do I set a correlation Id in the MessageBus.Send method. I need a reference id for the messages in the Queue to check the outcome of the message

 

Thanks,

Ajeeth

[Rafal Gwizdala]

Use the 'fluent' API for sending messages

                MessageBus.NewMessage(new SomeMessage()).SetCorrelationId("correlation_id_1234").Send("sql://destination/queue")

R

--
You received this message because you are subscribed to the Google Groups "nginn-messagebus" group.
To unsubscribe from this group and stop receiving emails from it, send an email to nginn-messageb...@googlegroups.com.
To post to this group, send email to nginn-me...@googlegroups.com.
Visit this group at http://groups.google.com/group/nginn-messagebus.

[Ajeeth]

Thanks Rafal, That worked.

[Ajeeth]

Its works for Send, However how does it work for SendAt?

[Rafal Gwizdala]

there's no 'SendAt' method in the fluent interface.

Instead, you do

MessageBus.NewMessage(new SomeMessage()).SetCorrelationId("correlation_id_1234").SetDeliveryDate(some date).Send("sql://destination/queue")

R