diff --git a/src/api/lib/rabbitmq_bus.rb b/src/api/lib/rabbitmq_bus.rb index 1d6d5ac2dd8..aedc9051480 100644 --- a/src/api/lib/rabbitmq_bus.rb +++ b/src/api/lib/rabbitmq_bus.rb @@ -3,18 +3,18 @@ def self.publish(event_queue_name, event_payload) return unless CONFIG['amqp_options'] start_connection - queue = $rabbitmq_channel.queue(event_queue_name, CONFIG['amqp_queue_options'].try(:with_indifferent_access) || {}) + queue = $rabbitmq_channel.queue(event_queue_name, CONFIG['amqp_queue_options'].try(:symbolize_keys) || {}) $rabbitmq_exchange.publish(event_payload, routing_key: queue.name) end # Start one connection, channel and exchange per rails process # and reuse them def self.start_connection - $rabbitmq_conn ||= Bunny.new(CONFIG['amqp_options'].with_indifferent_access) + $rabbitmq_conn ||= Bunny.new(CONFIG['amqp_options'].try(:symbolize_keys)) $rabbitmq_conn.start $rabbitmq_channel ||= $rabbitmq_conn.create_channel $rabbitmq_exchange = if CONFIG['amqp_exchange_name'] - $rabbitmq_channel.exchange(CONFIG['amqp_exchange_name'], CONFIG['amqp_exchange_options'].try(:with_indifferent_access) || {}) + $rabbitmq_channel.exchange(CONFIG['amqp_exchange_name'], CONFIG['amqp_exchange_options'].try(:symbolize_keys) || {}) else $rabbitmq_channel.default_exchange end