lib/msgr/channel.rb in msgr-1.3.2 vs lib/msgr/channel.rb in msgr-1.4.0

- old
+ new

@@ -20,21 +20,21 @@ def exchange @exchange ||= begin @channel.topic(prefix(EXCHANGE_NAME), durable: true).tap do |ex| log(:debug) do "Created exchange #{ex.name} (type: #{ex.type}, " \ - "durable: #{ex.durable?}, auto_delete: #{ex.auto_delete?})" + "durable: #{ex.durable?}, auto_delete: #{ex.auto_delete?})" end end end end 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?})" + "auto_delete: #{queue.auto_delete?})" end end end def prefix(name) @@ -51,14 +51,9 @@ end def nack(delivery_tag) @channel.nack delivery_tag, false, true log(:debug) { "Nacked message: #{delivery_tag}" } - end - - def reject(delivery_tag, requeue = true) - @channel.reject delivery_tag, requeue - log(:debug) { "Rejected message: #{delivery_tag}" } end def close @channel.close if @channel.open? end