WIP

examples/default_worker.rb

@@ -1,13 +1,9 @@
 class DefaultWorker
   include Shoryuken::Worker
 
-  shoryuken_options queue: 'test.fifo', auto_delete: true
+  shoryuken_options queue: 'default', auto_delete: true
 
   def perform(sqs_msg, body)
     Shoryuken.logger.info("Received message: '#{body}'")
-
-    raise body
   end
 end
-
-10.times { |i| DefaultWorker.perform_async("#{rand(1000)}-#{i}}") }

lib/shoryuken/cli.rb

@@ -7,7 +7,6 @@
 require 'shoryuken'
 require 'concurrent-edge'
 
-
 module Shoryuken
   # See: https://github.com/mperham/sidekiq/blob/33f5d6b2b6c0dfaab11e5d39688cab7ebadc83ae/lib/sidekiq/cli.rb#L20
   class Shutdown < Interrupt; end

lib/shoryuken/environment_loader.rb

@@ -56,7 +56,6 @@ def initialize_aws
       unless Shoryuken.options[:aws].to_h.empty?
         Shoryuken.logger.warn { '[DEPRECATION] aws in shoryuken.yml is deprecated. Please use configure_server and configure_client in your initializer' }
       end
-
       Shoryuken::AwsConfig.setup(Shoryuken.options[:aws])
     end
 

lib/shoryuken/fetcher.rb

@@ -4,11 +4,6 @@ class Fetcher < Concurrent::Actor::RestartingContext
 
     FETCH_LIMIT = 10
 
-    def on_message(msg)
-      method, *args = msg
-      send(method, *args)
-    end
-
     def initialize(manager)
       @manager = manager
     end

lib/shoryuken/manager.rb

@@ -5,11 +5,6 @@ module Shoryuken
   class Manager < Concurrent::Actor::RestartingContext
     include Util
 
-    def on_message(msg)
-      method, *args = msg
-      send(method, *args)
-    end
-
     def initialize
       @count = Shoryuken.options[:concurrency] || 25
 
@@ -140,13 +135,6 @@ def dispatch
       end
     end
 
-
-    def on_event(event)
-      if event == :reset
-      end
-      logger.info(event.inspect)
-    end
-
     private
 
     def dispatch_later

lib/shoryuken/processor.rb

@@ -8,11 +8,6 @@ def initialize(manager)
       @manager = manager
     end
 
-    def on_message(msg)
-      method, *args = msg
-      send(method, *args)
-    end
-
     def process(queue, sqs_msg)
       worker = Shoryuken.worker_registry.fetch_worker(queue, sqs_msg)
 

lib/shoryuken/util.rb

@@ -1,5 +1,10 @@
 module Shoryuken
   module Util
+    def on_message(msg)
+      method, *args = msg
+      send(method, *args)
+    end
+
     def watchdog(last_words)
       yield
     rescue => ex