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