Integration Events¶

Integration events inform other contexts and systems of activities of a bounded context.

We currently have these scenarios:

PCS -> PCS: MassTransit with RMQ as the broker
WSO2 -> Firefly: Spring AMQP with RMQ as the broker

Correlation Ids¶

RabbitMq Client¶

Messages published to Rabbit should contain CorrelationId, WorkflowCorrelationid, BusinessCorrelationId in the header. One possibility is headers.put("CorrelationId", Correlationid) from Java Client API Guide — RabbitMQ.

MassTransit¶

Integration events published via MassTransit are configured with CorrelationId, BusinessCorrelationId, WorkflowCorrelationId Likely we would set:

context.CorrelationId = X-Correlation-ID
context.Headers.BusinessCorrelationId = X-BusinessCorrelationId
context.Headers.WorkflowCorrelationId = X-WorkflowCorrelationId

See https://masstransit-project.com/usage/messages.html#message-headers