initiate garbage collection between each job in the worker

2017-06-08 10:15:31 +01:00
parent 724a6405a5
commit 48863dd6f4
1 changed files with 1 additions and 0 deletions
@@ -53,6 +53,7 @@ module Postal
          begin
            klass = message['class_name'].constantize.new(message['id'], message['params'])
            klass.perform
+            GC.start
          rescue => e
            klass.on_error(e) if defined?(klass)
            logger.warn "[#{message['id']}] \e[31m#{e.class}: #{e.message}\e[0m"