Sha256: 661bbaa4af1e3f6c1f57fa3c4683d4253ac7a25664fd0f045e430af6850cac7d
Contents?: true
Size: 1.93 KB
Versions: 6
Compression:
Stored size: 1.93 KB
Contents
# tasque ActiveRecord based task queue. Task processing queue with states, history and priorities. Works with your favorite database. ## Installation Add this line to your application's `Gemfile`: gem 'tasque' And then execute: $ bundle Or install it manually: $ gem install tasque Then you need to generate initializer and migration: $ rails g tasque:install Don't forget to run migrations: $ rake db:migrate ## Usage Create a simple task: Tasque::Task.create! task: 'test', params: { text: 'This is the test!' } Or a task with priority: Tasque::Task.create! task: 'test', priority: 9000, params: { text: 'I will be processed first!!!' } Or add a tag to find this task easily: Tasque::Task.create! task: 'test', tag: 'user_123', params: { text: 'This task is property of User #123!' } Now to process the task: # create task processor processor = Tasque::Processor.new # register a handler for test tasks processor.add_handler('test') do |task| puts "Got task ##{task.id}. Task says: '#{task.params['text']}'" task.complete! { log: 'got task, printed text' } # returning task result end # start processor and wait processor.start ### Using with Insque Tasque can send task and worker state updates via [Insque](https://github.com/Gropher/insque). To enable this featute uncomment following lines in your tasque initializer: # Send task state updates and progress notifications via Insque config.notify = true # Send worker heartbeat via Insque config.heartbeat = true config.heartbeat_interval = 10 # seconds # Use RedisMutex instead of database transaction config.use_mutex = true ## Contributing 1. Fork it 2. Create your feature branch (`git checkout -b my-new-feature`) 3. Commit your changes (`git commit -am 'Added some feature'`) 4. Push to the branch (`git push origin my-new-feature`) 5. Create new Pull Request
Version data entries
6 entries across 6 versions & 1 rubygems
Version | Path |
---|---|
tasque-0.2.5 | README.md |
tasque-0.2.4 | README.md |
tasque-0.2.3 | README.md |
tasque-0.2.2 | README.md |
tasque-0.2.1 | README.md |
tasque-0.2.0 | README.md |