* rescuing more exceptions

active_domain/lib/active_domain/command_routes.rb

@@ -14,7 +14,7 @@ def run_command(command)
       RELOADER.execute_if_updated
       processor, method = @@routes[command.class]
       processor_instance(processor).method(method).call(command)
-    rescue Exception => e
+    rescue => e
       LOGGER.error e.message
       LOGGER.error e.backtrace.join("\n")
       raise ActiveEvent::DomainExceptionCapture, ["#{e.class.name}: #{e.message}", e.backtrace].to_json, e.backtrace

active_domain/lib/active_domain/server.rb

@@ -19,7 +19,7 @@ def run
       DRb.thread.join
     rescue Interrupt
       LOGGER.info 'Catching Interrupt'
-    rescue Exception => e
+    rescue => e
       LOGGER.error e.message
       LOGGER.error e.backtrace.join("\n")
       raise e

active_event/lib/active_event/event_server.rb

@@ -19,7 +19,7 @@ def self.start(options)
     def start
       event_connection.start
       listen_for_resend_requests
-    rescue Exception => e
+    rescue => e
       LOGGER.error e.message
       LOGGER.error e.backtrace.join("\n")
       raise e

active_event/lib/active_event/replay_server.rb

@@ -19,7 +19,7 @@ def start(id)
       @last_id = id
       start_republishing
       send_done_message
-    rescue Exception => e
+    rescue => e
       LOGGER.error e.message
       LOGGER.error e.backtrace.join("\n")
       raise e

active_projection/lib/active_projection/event_client.rb

@@ -26,7 +26,7 @@ def start
       end
     rescue Interrupt
       LOGGER.info 'Catching Interrupt'
-    rescue Exception => e
+    rescue => e
       LOGGER.error e.message
       LOGGER.error e.backtrace.join("\n")
       raise
@@ -130,7 +130,7 @@ def process_event(headers, event)
             projection.invoke event, headers
           end
           send_projection_notification headers[:id], projection
-        rescue Exception => e
+        rescue => e
           send_projection_notification headers[:id], projection, e
         end
       end

active_projection/lib/active_projection/projection_type.rb

@@ -49,7 +49,7 @@ def invoke(event, headers)
           else
             send method, event, headers
           end
-        rescue Exception => e
+        rescue => e
           LOGGER.error "[#{self.class.name}]: error processing #{event_type}[#{event_id}]\n#{e.message}\n#{e.backtrace}"
           mark_broken
           raise

disco-railties/lib/generators/disco/app/app_generator.rb

@@ -82,7 +82,7 @@ def enable_rake_tasks
         content = "
 require 'rails-disco/tasks'"
         inject_into_file File.join('config/application.rb'), content, after: /require 'rails\/all'/
-      rescue Exception
+      rescue
         puts "Seems like you invoked it from an engine, so put\n
         require 'rails-disco/tasks'\n
         in your application.rb from the main application to have the rails disco rake tasks available"
@@ -92,7 +92,7 @@ def enable_concurrency
         return if behavior == :revoke
         application 'config.preload_frameworks = true'
         application 'config.allow_concurrency = true'
-      rescue Exception
+      rescue
         puts "Seems like you invoked it from an engine, so remember to put\n
         config.preload_frameworks = true
         config.allow_concurrency = true\n