Sha256: 27e1f12ff9b94182df0ea7fc79c5dc5144faf1f5f6523ab805b0849638de6ac8
Contents?: true
Size: 445 Bytes
Versions: 12
Compression:
Stored size: 445 Bytes
Contents
module Shoryuken
class Launcher
include Util
def initialize
@manager = Shoryuken::Manager.new(Shoryuken::Fetcher.new,
Shoryuken.options[:polling_strategy].new(Shoryuken.queues))
end
def stop(options = {})
@manager.stop(shutdown: !options[:shutdown].nil?,
timeout: Shoryuken.options[:timeout])
end
def run
@manager.start
end
end
end
Version data entries
12 entries across 12 versions & 1 rubygems