Skip to content

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

Header includes 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