A RabbitMQ background processing framework for Ruby with built-in support for Rails integration.
PikaQue is inspired by Sneakers, Hutch, and Sidekiq. It is intended to implement more support for Rails a la Sidekiq. It supports retry (both constant and exponential backoffs) and delayed/scheduled execution.
Add this line to your application's Gemfile:
gem 'pika_que'
Or install it yourself as:
$ gem install pika_que
To create a worker:
class PokeWorker
include PikaQue::Worker
from_queue "poke"
def perform(msg)
# do something with msg["greeting"]
ack!
end
end
To enqueue a job:
PokeWorker.enqueue({ greeting: "I Challenge You!" })
To run server:
$ bundle exec pika_que
Create workers(not required for ActiveJob) in:
app/workers
Create a config file pika_que.yml
in config:
config/pika_que.yml
# pika_que.yml
processors:
- workers:
- queue: default
- queue: mailers
- queue: your-active-job-queue-name
- workers:
- worker: PokeWorker
Set the backend for active job in config/application.rb
:
config.active_job.queue_adapter = :pika_que
Then run the server.
For more details, see wiki.
See examples for more usage reference.
After checking out the repo, run bin/setup
to install dependencies. Then, run rake spec
to run the tests. You can also run bin/console
for an interactive prompt that will allow you to experiment. Run bundle exec pika_que
to use the gem in this directory, ignoring other installed copies of this gem.
To install this gem onto your local machine, run bundle exec rake install
. To release a new version, update the version number in version.rb
, and then run bundle exec rake release
, which will create a git tag for the version, push git commits and tags, and push the .gem
file to rubygems.org.
Bug reports and pull requests are welcome on GitHub at https://github.com/dwkoogt/pika_que. 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.
The gem is available as open source under the terms of the MIT License.