Merge pull request #37 from vadshalamov/master

feature: move recreate_queues task from blizko
abak-press · Feb 16, 2017 · c6ae751 · c6ae751
2 parents 3940f5c + fb5f5a9
commit c6ae751
Show file tree

Hide file tree

Showing 3 changed files with 16 additions and 0 deletions.
diff --git a/app/models/treasury/models/queue.rb b/app/models/treasury/models/queue.rb
@@ -114,6 +114,15 @@ def pgq_queue_name
         "q_#{name}"
       end
 
+      # Public: Пересоздает очередь, триггер и переподписывает связанные
+      # обработчики.
+      #
+      # Returns nothing.
+      def recreate!
+        destroy_pgq_queue
+        processors.each(&:subscribe!)
+      end
+
       protected
 
       def lock_table!

diff --git a/lib/tasks/treasury.rake b/lib/tasks/treasury.rake
@@ -65,5 +65,10 @@ namespace :treasury do
     task drop_triggers: :environment do
       Apress::Utils::Triggers.drop_triggers(:trigger_pattern => "#{Treasury::Models::Queue::TRIGGER_PREFIX}*")
     end
+
+    desc 'Пересоздает очереди, триггеры и подписки для всех процессоров'
+    task recreate_queues: :environment do
+      Treasury::Models::Queue.all.each(&:recreate!)
+    end
   end
 end
diff --git a/lib/treasury/backwards.rb b/lib/treasury/backwards.rb
@@ -63,6 +63,7 @@ module Redis
   end
 
   ROOT_REDIS_KEY = ::Treasury::ROOT_REDIS_KEY
+  ROOT_LOGGER_DIR = ::Treasury::ROOT_LOGGER_DIR
   ReinitializeObjectJob = ::Treasury::ReinitializeObjectJob
 end
 
@@ -131,6 +132,7 @@ module Redis
   end
 
   ROOT_REDIS_KEY = ::Treasury::ROOT_REDIS_KEY
+  ROOT_LOGGER_DIR = ::Treasury::ROOT_LOGGER_DIR
 end
 
 Pgq = ::Treasury::Pgq