configure sneakers to use maxretry handler

app/workers/plum_event_handler.rb

@@ -1,6 +1,9 @@
 class PlumEventHandler
   include Sneakers::Worker
-  from_queue :pomegranate
+  from_queue :pomegranate,
+             WORKER_OPTIONS.merge(
+               arguments: { 'x-dead-letter-exchange': 'pomegranate-retry' }
+             )
 
   def work(msg)
     msg = JSON.parse(msg)

config/initializers/sneakers.rb

@@ -1,8 +1,20 @@
 require 'sneakers'
+require 'sneakers/handlers/maxretry'
 require_relative 'pom_config'
 Sneakers.configure(
   amqp: Pomegranate.config["events"]["server"],
   exchange: Pomegranate.config["events"]["exchange"],
-  exchange_type: :fanout
+  exchange_type: :fanout,
+  handler: Sneakers::Handlers::Maxretry
 )
 Sneakers.logger.level = Logger::INFO
+
+WORKER_OPTIONS = {
+  ack: true,
+  threads: 10,
+  prefetch: 10,
+  timeout_job_after: 60,
+  heartbeat: 5,
+  amqp_heartbeat: 10,
+  retry_timeout: 60 * 1000 # 60 seconds
+}.freeze