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