lib/jackhammer/message_receiver.rb in jackhammer-1.3.3 vs lib/jackhammer/message_receiver.rb in jackhammer-1.3.4

@@ -13,8 +13,10 @@
       if handler.respond_to?(:perform_async)
         handler.perform_async message
       else
         handler.call message
       end
+    ensure
+      ActiveRecord::Base.clear_active_connections! if defined?(ActiveRecord::Base)
     end
   end
 end