Discobolo (WIP)

Ruby worker system for disque

Usage:

Setup application:

# Configure Discobolo 

Discobolo::Config.setup do |config|
  config.client = ["127.0.0.1:7711"]
  config.queues = ["default", "important", "bogus"]
  config.fetch_options = {count: 10, timeout: 2000}
  config.actor_concurrency = 5
  config.logger = $stdout # or filepath.log
end

# Run Application:

Discobolo::Application.run

Implement a Worker:

class MyWorker < Discobolo::Worker
  set_queue "bogus"

  def perform(*args)
    # Do the hard work here
  end
end

Enqueue

DefaultWorker.enqueue({foo:bar})

Web interface:

#config.ru

require 'discobolo/web'

require "./your_disque_app"

map '/disque' do
  run Discobolo::Web
end

Run rack appplication:

bundle exec rackup

visit http://localhost:4567

Contributing

Bug reports and pull requests are welcome on GitHub at https://github.com/michelson/discobolo. This project is intended to be a safe, welcoming space for collaboration, and contributors are expected to adhere to the Contributor Covenant code of conduct.

License

The gem is available as open source under the terms of the MIT License.