class PikaQue::Handlers::DefaultHandler
Public Class Methods
new(opts = {})
click to toggle source
# File lib/pika_que/handlers/default_handler.rb, line 5 def initialize(opts = {}) # nothing to do here end
Public Instance Methods
bind_queue(queue, routing_key)
click to toggle source
# File lib/pika_que/handlers/default_handler.rb, line 9 def bind_queue(queue, routing_key) end
close()
click to toggle source
# File lib/pika_que/handlers/default_handler.rb, line 26 def close end
handle(response_code, channel, delivery_info, metadata, msg, error = nil)
click to toggle source
# File lib/pika_que/handlers/default_handler.rb, line 12 def handle(response_code, channel, delivery_info, metadata, msg, error = nil) case response_code when :ack PikaQue.logger.debug "DefaultHandler acknowledge <#{msg}>" channel.acknowledge(delivery_info.delivery_tag, false) when :requeue PikaQue.logger.debug "DefaultHandler requeue <#{msg}>" channel.reject(delivery_info.delivery_tag, true) else PikaQue.logger.debug "DefaultHandler reject <#{msg}>" channel.reject(delivery_info.delivery_tag, false) end end