diff --git a/lib/multiple_man/runner.rb b/lib/multiple_man/runner.rb index 67cb7fc..c1da680 100644 --- a/lib/multiple_man/runner.rb +++ b/lib/multiple_man/runner.rb @@ -48,7 +48,7 @@ def build_listener listener_class.new( queue: channel.queue(*queue_params), subscribers: listeners, - topic: topic_name + topic: topic ) end @@ -72,6 +72,10 @@ def channel @channel ||= Connection.connection.create_channel end + def topic + @topic ||= channel.topic(topic_name) + end + def config MultipleMan.configuration end diff --git a/lib/multiple_man/version.rb b/lib/multiple_man/version.rb index 2386a6e..5224815 100644 --- a/lib/multiple_man/version.rb +++ b/lib/multiple_man/version.rb @@ -1,3 +1,3 @@ module MultipleMan - VERSION = "1.1.1" + VERSION = "1.1.2" end