lib/queue_bus/task_manager.rb in queue-bus-0.9.1 vs lib/queue_bus/task_manager.rb in queue-bus-0.10.0

@@ -22,9 +22,16 @@
         log '  ...done'
       end
       count
     end
 
+    def unsubscribe_queue!(app_key, queue)
+      log "Unsubcribing #{queue} from #{app_key}"
+      app = ::QueueBus::Application.new(app_key)
+      app.unsubscribe_queue(queue)
+      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)