class Emque::Consuming::Control::Workers

Constants

COMMANDS

Public Instance Methods

down(topic) click to toggle source
# File lib/emque/consuming/control/workers.rb, line 9
def down(topic)
  app.manager.worker(topic: topic.to_sym, command: :down)
end
respond_to?(method) click to toggle source
# File lib/emque/consuming/control/workers.rb, line 17
def respond_to?(method)
  COMMANDS.include?(method.to_sym)
end
up(topic) click to toggle source
# File lib/emque/consuming/control/workers.rb, line 13
def up(topic)
  app.manager.worker(topic: topic.to_sym, command: :up)
end