lib/msgr/channel.rb in msgr-1.2.0 vs lib/msgr/channel.rb in msgr-1.3.0
- old
+ new
@@ -1,5 +1,7 @@
+# frozen_string_literal: true
+
module Msgr
class Channel
include Logging
EXCHANGE_NAME = 'msgr'
@@ -24,12 +26,12 @@
end
end
end
end
- def queue(name)
- @channel.queue(prefix(name), durable: true).tap do |queue|
+ def queue(name, **opts)
+ @channel.queue(prefix(name), durable: true, **opts).tap do |queue|
log(:debug) do
"Create queue #{queue.name} (durable: #{queue.durable?}, " \
"auto_delete: #{queue.auto_delete?})"
end
end
@@ -60,6 +62,6 @@
def close
@channel.close if @channel.open?
end
end
-end
\ No newline at end of file
+end