Sneakers RPC

sneakers_rpc_server.rb

require 'sneakers'
require 'sneakers/runner'
require 'byebug'
require 'oj'

class RpcServer
  include Sneakers::Worker
  from_queue 'downloads'

  def work_with_params(deserialized_msg, delivery_info, metadata)
    publish({ "a" => 1 }, {
      to_queue: metadata[:reply_to],
      correlation_id: metadata[:correlation_id],
      content_type: metadata[:content_type]
    })

    ack!
  end
end

# Werid that we need to do this, but this allows to use Oj
Sneakers::ContentType.register(
  content_type: 'application/json',
  deserializer: ->(payload) { Oj.load(payload) },
  serializer: ->(payload) { Oj.dump(payload) },
)

Sneakers.configure({
  threads: 1, # for easy debugging
  exchange: "" # USE default exchange instead of sneakers exchange
})

# Default is debug =X
Sneakers.logger.level = Logger::INFO

Sneakers::Runner.new([RpcServer]).run