small working concept

lib/sneakers.rb

@@ -16,6 +16,7 @@ module Concerns
 require 'sneakers/concerns/metrics'
 require 'sneakers/handlers/oneshot'
 require 'sneakers/worker'
+require 'sneakers/task'
 require 'sneakers/publisher'
 
 module Sneakers

lib/sneakers/task.rb

@@ -0,0 +1,21 @@
+module Sneakers
+  module Task
+
+    def initialize(hdr, props, msg)
+      @hdr = hdr
+      @props = props
+      @msg = msg
+
+      @status = :new
+    end
+
+    def ack!
+      @status = :ack
+    end
+
+    def status
+      @status
+    end
+
+  end
+end

lib/sneakers/worker.rb

@@ -53,7 +53,10 @@ def do_work(hdr, props, msg, handler)
           metrics.increment("work.#{self.class.name}.started")
           Timeout.timeout(@timeout_after) do
             metrics.timing("work.#{self.class.name}.time") do
-              res = work(msg)
+              klass = (self.class.name + '::Task').constantize
+              task = klass.new(hdr, props, msg)
+              task.call
+              res = task.status
             end
           end
         rescue Timeout::Error
@@ -62,7 +65,7 @@ def do_work(hdr, props, msg, handler)
         rescue => ex
           res = :error
           error = ex
-          logger.error(ex)
+          logger.error "\n\nEXCEPTION: #{ex.message}\nPAYLOAD:\n#{msg.inspect}\nBACKTRACE\n#{ex.message}\n#{ex.backtrace.join("\n")}"
         end
 
         if @should_ack