Contents

# frozen_string_literal: true

require "sneakers"

require "rabbit"
require "rabbit/receiving/receive"

class Rabbit::Receiving::Worker
  include Sneakers::Worker

  def work_with_params(message, delivery_info, arguments)
    # args and info have custom rabbit classes, have to convert them to hash
    receive_message(message, delivery_info.to_h, arguments.to_h)
    ack!
  rescue => error
    handle_error!(error)
  end

  def receive_message(message, delivery_info, arguments)
    Rabbit::Receiving::Receive.new(
      message: message.dup.force_encoding("UTF-8"),
      delivery_info: delivery_info,
      arguments: arguments,
    ).call
  end

  def handle_error!(error)
    raise if Rabbit.config.environment == :test
    Rabbit.config.exception_notifier.call(error)
    # wait to prevent queue overflow
    sleep 1
    requeue!
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
rabbit_messaging-1.1.0	lib/rabbit/receiving/worker.rb
rabbit_messaging-1.0.0	lib/rabbit/receiving/worker.rb
rabbit_messaging-0.15.0	lib/rabbit/receiving/worker.rb
rabbit_messaging-0.13.0	lib/rabbit/receiving/worker.rb