lib/queue_bus/task_manager.rb in queue-bus-0.13.2 vs lib/queue_bus/task_manager.rb in queue-bus-0.13.3

@@ -29,9 +29,16 @@
       app = ::QueueBus::Application.new(app_key)
       app.unsubscribe_queue(queue)
       log "  ...done"
     end
 
+    def unsubscribe_app!(app_key)
+      log "Removing all subscriptions for #{app_key}"
+      app = ::QueueBus::Application.new(app_key)
+      app.unsubscribe
+      log "  ...done"
+    end
+
     def unsubscribe!
       count = 0
       ::QueueBus.dispatchers.each do |dispatcher|
         log "Unsubcribing from #{dispatcher.app_key}"
         app = ::QueueBus::Application.new(dispatcher.app_key)