RuoteKit Config for my Rails application

gistfile1.rb

# make changes when needed
#
# you may use another persistent storage for example or include a worker so that
# you don't have to run it in a separate instance
#
# See http://ruote.rubyforge.org/configuration.html for configuration options of
# ruote.

require 'ruote/storage/fs_storage'

RUOTE_STORAGE = Ruote::FsStorage.new("ruote_work_#{Rails.env}")
AMQP.settings[:host] = 'localhost'
AMQP.settings[:vhost] = 'ping-pong'
AMQP.settings[:user] = 'guest'
AMQP.settings[:pass] = 'guest'
RuoteKit.engine = Ruote::Engine.new(RUOTE_STORAGE)
#RuoteKit.engine = Ruote::Engine.new(Ruote::Worker.new(RUOTE_STORAGE))

# By default, there is a running worker when you start the Rails server. That is
# convenient in development, but may be (or not) a problem in deployment.
#
# Please keep in mind that there should always be a running worker or schedules
# may get triggered to late. Some deployments (like Passenger) won't guarantee
# the Rails server process is running all the time, so that there's no always-on
# worker. Also beware that the Ruote::HashStorage only supports one worker.
#
# If you don't want to start a worker thread within your Rails server process,
# replace the line before this comment with the following:
#
# RuoteKit.engine = Ruote::Engine.new(RUOTE_STORAGE)
#
# To run a worker in its own process, there's a rake task available:
#
#     rake ruote:run_worker
#
# Stop the task by pressing Ctrl+C

RuoteAMQP::WorkitemListener.new(RuoteKit.engine,'ruote_workitems')

unless $RAKE_TASK # don't register participants in rake tasks

  RuoteKit.engine.register do
    participant :ping, RuoteAMQP::Participant, :queue => "ping", :reply_queue => 'ruote_workitems'
    participant :log_me, Ruote::BlockParticipant do |workitem|
      Rails.logger.debug('\033[0;31m HELLO ' + workitem.fields.inspect)
    end
    participant :pong, RuoteAMQP::Participant, :queue => "pong", :reply_queue => 'ruote_workitems'

    # register your own participants using the participant method
    #
    # Example: participant 'alice', Ruote::StorageParticipant see
    # http://ruote.rubyforge.org/participants.html for more info

    # register the catchall storage participant named '.+'
    catchall
  end
end

# when true, the engine will be very noisy (stdout)
#
RuoteKit.engine.context.logger.noisy = false