publish_event.rb

def publish_event(event, prefix: '')
  routing_key = build_routing_key(event, prefix)
  payload = build_event_payload(event)

  channel_pool.with do |channel|
    channel.
      topic(eventbus_exchange, durable: true).
      publish(payload, routing_key: routing_key)
  end
end