diff --git a/examples/application-example/lib/foobar/ping_consumer.rb b/examples/application-example/lib/foobar/ping_consumer.rb index 1f6a862..1ce9983 100644 --- a/examples/application-example/lib/foobar/ping_consumer.rb +++ b/examples/application-example/lib/foobar/ping_consumer.rb @@ -19,6 +19,7 @@ module Foobar message.ack return unless options.success_message + logger.info("#{self.class}: #{options.success_message}") end end diff --git a/examples/application-example/lib/foobar/pong_consumer.rb b/examples/application-example/lib/foobar/pong_consumer.rb index b353be8..2b94821 100644 --- a/examples/application-example/lib/foobar/pong_consumer.rb +++ b/examples/application-example/lib/foobar/pong_consumer.rb @@ -19,6 +19,7 @@ module Foobar message.ack return unless options.success_message + logger.info("#{self.class}: #{options.success_message}") end end diff --git a/lib/bunnyrun/consumer.rb b/lib/bunnyrun/consumer.rb index 4a591a6..11d45bf 100644 --- a/lib/bunnyrun/consumer.rb +++ b/lib/bunnyrun/consumer.rb @@ -21,6 +21,7 @@ module BunnyRun def queue(name = nil, attrs = {}) return @queue if name.nil? + @queue = { name: name, attrs: attrs } end @@ -34,11 +35,13 @@ module BunnyRun def manual_ack(value = nil) return @manual_ack || false if value.nil? + @manual_ack = value end def prefetch(count = nil) return @prefetch if count.nil? + @prefetch = count end diff --git a/lib/bunnyrun/message.rb b/lib/bunnyrun/message.rb index dd4c594..74d5646 100644 --- a/lib/bunnyrun/message.rb +++ b/lib/bunnyrun/message.rb @@ -19,6 +19,7 @@ module BunnyRun def acked? return unless manual_ack? + @acked end