diff --git a/lib/event_source/protocols/http/faraday_queue_proxy.rb b/lib/event_source/protocols/http/faraday_queue_proxy.rb index 646c2f7..6214696 100644 --- a/lib/event_source/protocols/http/faraday_queue_proxy.rb +++ b/lib/event_source/protocols/http/faraday_queue_proxy.rb @@ -52,7 +52,7 @@ def subscribe(subscriber_klass, _options) unique_key = [app_name, formatted_exchange_name].join(delimiter) logger.debug "FaradayQueueProxy#register_subscription Subscriber Class #{subscriber_klass}" logger.debug "FaradayQueueProxy#register_subscription Unique_key #{unique_key}" - @subject.register_action(subscriber_klass, action) + @subject.register_action(subscriber_klass, unique_key) end def consumer_proxy_for(operation_bindings)