Skip to content

Message Bus

We defined our own Message Bus to implement the worker reservation. The class FlowPrioritizingMessageBus implements MessageBusInterface and extends the way messages are stamped, i.e. equipped with a priority defining stamp.

The message bus will try to set to stamps to the message:

  • PriorityStamp - It will define the priority of the message, like high, mid or low.
  • TransportNamesStamp - This will set the name of the transport, for example job_low.