From 9c42e92737ad143c1a1557845cff876245e4fde3 Mon Sep 17 00:00:00 2001 From: vaughanbrittonsage Date: Wed, 17 Jan 2018 14:14:42 +0000 Subject: [PATCH] updated rabbitmq eventq client to remove namespace from event type in message args --- eventq_rabbitmq/Gemfile | 2 +- .../lib/eventq_rabbitmq/rabbitmq_eventq_client.rb | 8 ++++---- eventq_rabbitmq/lib/eventq_rabbitmq/version.rb | 2 +- 3 files changed, 6 insertions(+), 6 deletions(-) diff --git a/eventq_rabbitmq/Gemfile b/eventq_rabbitmq/Gemfile index 251cf1a..91c4440 100644 --- a/eventq_rabbitmq/Gemfile +++ b/eventq_rabbitmq/Gemfile @@ -7,7 +7,7 @@ gem 'json', '1.8.3' gem 'redlock' platforms :ruby do - gem 'openssl' + gem 'openssl', '2.0.4' gem 'oj', '2.15.0' gem 'pry' end diff --git a/eventq_rabbitmq/lib/eventq_rabbitmq/rabbitmq_eventq_client.rb b/eventq_rabbitmq/lib/eventq_rabbitmq/rabbitmq_eventq_client.rb index a237232..61bcbf9 100644 --- a/eventq_rabbitmq/lib/eventq_rabbitmq/rabbitmq_eventq_client.rb +++ b/eventq_rabbitmq/lib/eventq_rabbitmq/rabbitmq_eventq_client.rb @@ -45,12 +45,12 @@ def raise_event(event_type, event, context = {}) with_connection do |channel| exchange = @queue_manager.get_exchange(channel, @event_raised_exchange) - message = serialized_message(_event_type, event, context) + message = serialized_message(event_type, event, context) exchange.publish(message, routing_key: _event_type) EventQ.logger.debug do - "[#{self.class}] - Raised event to Exchange: #{_event_type} | Message: #{message}." + "[#{self.class}] - Raised event to Exchange. Routing Key: #{_event_type} | Message: #{message}." end end end @@ -73,12 +73,12 @@ def raise_event_in_queue(event_type, event, queue, delay, context = {}) q = channel.queue(_queue_name, durable: @queue_manager.durable) q.bind(exchange, routing_key: _event_type) - message = serialized_message(_event_type, event, context) + message = serialized_message(event_type, event, context) delay_exchange.publish(message, routing_key: _event_type) EventQ.logger.debug do - "[#{self.class}] - Raised event to Exchange: #{_event_type} | Message: #{message} | Delay: #{delay}." + "[#{self.class}] - Raised event to Queue: #{_queue_name} | Message: #{message} | Delay: #{delay}." end end end diff --git a/eventq_rabbitmq/lib/eventq_rabbitmq/version.rb b/eventq_rabbitmq/lib/eventq_rabbitmq/version.rb index 834d25c..cb94636 100644 --- a/eventq_rabbitmq/lib/eventq_rabbitmq/version.rb +++ b/eventq_rabbitmq/lib/eventq_rabbitmq/version.rb @@ -1,3 +1,3 @@ module EventqRabbitmq - VERSION = "1.17.0" + VERSION = "1.17.1" end