search

wework / grabbit

A lightweight transactional message bus on top of RabbitMQ
Apache License 2.0
98 stars 20 forks source link

Correlation Ids are wrongly set on outgoing commands #219

Closed rhinof closed 5 years ago

rhinof commented 5 years ago

When a saga sends a command grabbit wrongly sets the saga correlation id on the outgoing saga.

Expected result: a command being sent by a saga via invocation.Bus().Send(...) should not contain a value in the SagaCorrelationID header.

Actual: the SagaCorrelationID header is set with the value of the SagaID