wip

lib/rabbit/daemon.rb

@@ -18,11 +18,23 @@ def run(logger: Sneakers.logger)
         Lamian.extend_logger(logger)
       end
 
+      self.logger = logger
+
       Sneakers.configure(**sneakers_config(logger: logger))
       Sneakers.server = true
 
       Rabbit.config.validate!
-      Receiving::Worker.from_queue(Rabbit.config.read_queue)
+
+      Receiving::Worker.from_queue(
+        "#{Rabbit.config.read_queue}.working",
+        handler: SneakersHandlers::ExponentialBackoffHandler,
+        max_retries: 6,
+        arguments: {
+          "x-dead-letter-exchange" => "#{Rabbit.config.read_queue}.dlx",
+          "x-dead-letter-routing-key" => "#{Rabbit.config.read_queue}.dlx",
+        },
+      )
+
       Sneakers::Runner.new([Receiving::Worker]).run
     end
 
@@ -32,11 +44,13 @@ def config
 
     def connection
       bunny_config = config.delete(:bunny_options).to_h.symbolize_keys
-      Bunny.new(bunny_config)
+      Bunny.new(**bunny_config, logger: logger)
     end
 
     private
 
+    attr_accessor :logger
+
     def sneakers_config(logger:)
       {
         connection: connection,