Skip to content
Browse files

Fix reply :)

  • Loading branch information...
1 parent d88ed70 commit 4fa66bc18943ab33228fe162b06f492e6fc01ccb @hallelujah committed Jan 13, 2011
Showing with 17 additions and 226 deletions.
  1. +1 −0 .gitignore
  2. +14 −0 app/models/my_logger_participant.rb
  3. +1 −4 config/initializers/ruote-kit.rb
  4. +1 −0 daemon/.gitignore
  5. +0 −222 daemon/log/development.log
View
1 .gitignore
@@ -2,3 +2,4 @@
db/*.sqlite3
log/*.log
tmp/**/*
+ruote_*
View
14 app/models/my_logger_participant.rb
@@ -0,0 +1,14 @@
+class MyLoggerParticipant
+ include Ruote::LocalParticipant
+
+ def initialize(opts)
+ @opts = opts
+ @seen = []
+ end
+
+ def consume(workitem)
+ Rails.logger.debug('\033[0;31m HELLO ' + workitem.fields.inspect)
+ reply_to_engine(workitem)
+ end
+
+end
View
5 config/initializers/ruote-kit.rb
@@ -36,17 +36,14 @@
# Stop the task by pressing Ctrl+C
RuoteAMQP::WorkitemListener.new(RuoteKit.engine,'ruote_workitems')
-log_me = RuoteKit.engine.register_participant :log_me do |workitem|
- Rails.logger.debug('\033[0;31m HELLO ' + workitem.fields.inspect)
-end
-log_me.do_not_thread = true
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 :pong, RuoteAMQP::Participant, :queue => "pong", :reply_queue => 'ruote_workitems'
+ participant :log_me, MyLoggerParticipant
# register your own participants using the participant method
#
# Example: participant 'alice', Ruote::StorageParticipant see
View
1 daemon/.gitignore
@@ -0,0 +1 @@
+log/*
View
222 daemon/log/development.log
@@ -1,222 +0,0 @@
-# Logfile created on 2011-01-13 11:13:28 +0100 by logger.rb/25413
-2011-01-13 11:13:28.20253 ping(25802) [INFO] [daemon-kit]: DaemonKit (0.1.8.1) booting in development mode
-2011-01-13 11:13:28.20396 ping(25802) [INFO] [daemon-kit]: Setting up trap for USR1
-2011-01-13 11:13:28.20495 ping(25802) [INFO] [daemon-kit]: Setting up trap for USR2
-2011-01-13 11:13:28.20584 ping(25802) [INFO] [daemon-kit]: Setting up trap for HUP
-2011-01-13 11:13:28.20670 ping(25802) [INFO] [daemon-kit]: Setting up trap for INT
-2011-01-13 11:13:28.20754 ping(25802) [INFO] [daemon-kit]: Setting up trap for TERM
-2011-01-13 11:13:28.22512 ping(25802) [INFO] [daemon-kit]: DaemonKit (0.1.8.1) booted, now running ping
-2011-01-13 11:13:28.27664 ping(25802) [DEBUG] [daemon-kit]: AMQP.start({:user=>"guest", :pass=>"guest", :host=>"localhost", :vhost=>"ping-pong"})
-2011-01-13 11:13:28.30578 ping(25802) [DEBUG] [daemon-kit]: Subscribing to ping for workitems
-2011-01-13 11:13:28.30782 ping(25802) [DEBUG] [daemon-kit]: Subscribing to pong for workitems
-2011-01-13 11:19:40.835244 ping(25802) [DEBUG] [daemon-kit]: Received workitem: "{\"fields\":{\"params\":{\"command\":\"/ping_pong/ping\",\"ref\":\"ping\",\"participant_options\":{\"queue\":\"ping\",\"forget\":false},\"forget\":false},\"dispatched_at\":\"2011-01-13 10:19:40.758914 UTC\"},\"fei\":{\"engine_id\":\"engine\",\"wfid\":\"20110113-bigebiyupo\",\"sub_wfid\":null,\"expid\":\"0_0\"},\"participant_name\":\"ping\"}"
-2011-01-13 11:19:40.858958 ping(25802) [DEBUG] [daemon-kit]: Replying to engine via AMQP with #<DaemonKit::RuoteWorkitem:0x0000000122d638 @workitem={"fields"=>{"params"=>{"command"=>"/ping_pong/ping", "ref"=>"ping", "participant_options"=>{"queue"=>"ping", "forget"=>false}, "forget"=>false}, "dispatched_at"=>"2011-01-13 10:19:40.758914 UTC", "msg"=>"ping", "success"=>true}, "fei"=>{"engine_id"=>"engine", "wfid"=>"20110113-bigebiyupo", "sub_wfid"=>nil, "expid"=>"0_0"}, "participant_name"=>"ping"}>
-2011-01-13 11:19:40.859482 ping(25802) [DEBUG] [daemon-kit]: Processed workitem.
-2011-01-13 11:19:50.403737 ping(25802) [DEBUG] [daemon-kit]: Received workitem: "{\"fields\":{\"params\":{\"command\":\"/ping_pong/ping\",\"ref\":\"ping\",\"participant_options\":{\"queue\":\"ping\",\"forget\":false},\"forget\":false},\"dispatched_at\":\"2011-01-13 10:19:50.337952 UTC\"},\"fei\":{\"engine_id\":\"engine\",\"wfid\":\"20110113-bobaruduba\",\"sub_wfid\":null,\"expid\":\"0_0\"},\"participant_name\":\"ping\"}"
-2011-01-13 11:19:50.404431 ping(25802) [DEBUG] [daemon-kit]: Replying to engine via AMQP with #<DaemonKit::RuoteWorkitem:0x000000020de5d8 @workitem={"fields"=>{"params"=>{"command"=>"/ping_pong/ping", "ref"=>"ping", "participant_options"=>{"queue"=>"ping", "forget"=>false}, "forget"=>false}, "dispatched_at"=>"2011-01-13 10:19:50.337952 UTC", "msg"=>"ping", "success"=>true}, "fei"=>{"engine_id"=>"engine", "wfid"=>"20110113-bobaruduba", "sub_wfid"=>nil, "expid"=>"0_0"}, "participant_name"=>"ping"}>
-2011-01-13 11:19:50.405197 ping(25802) [DEBUG] [daemon-kit]: Processed workitem.
-2011-01-13 11:20:08.432596 ping(25802) [DEBUG] [daemon-kit]: Received workitem: "{\"fields\":{\"params\":{\"command\":\"/ping_pong/ping\",\"ref\":\"ping\",\"participant_options\":{\"queue\":\"ping\",\"forget\":false},\"forget\":false},\"dispatched_at\":\"2011-01-13 10:20:08.426111 UTC\"},\"fei\":{\"engine_id\":\"engine\",\"wfid\":\"20110113-muzepahi\",\"sub_wfid\":null,\"expid\":\"0_0\"},\"participant_name\":\"ping\"}"
-2011-01-13 11:20:08.433287 ping(25802) [DEBUG] [daemon-kit]: Replying to engine via AMQP with #<DaemonKit::RuoteWorkitem:0x000000020b7f50 @workitem={"fields"=>{"params"=>{"command"=>"/ping_pong/ping", "ref"=>"ping", "participant_options"=>{"queue"=>"ping", "forget"=>false}, "forget"=>false}, "dispatched_at"=>"2011-01-13 10:20:08.426111 UTC", "msg"=>"ping", "success"=>true}, "fei"=>{"engine_id"=>"engine", "wfid"=>"20110113-muzepahi", "sub_wfid"=>nil, "expid"=>"0_0"}, "participant_name"=>"ping"}>
-2011-01-13 11:20:08.434032 ping(25802) [DEBUG] [daemon-kit]: Processed workitem.
-2011-01-13 11:20:38.297671 ping(25802) [DEBUG] [daemon-kit]: Received workitem: "{\"fields\":{\"params\":{\"command\":\"/ping_pong/ping\",\"ref\":\"ping\",\"participant_options\":{\"queue\":\"ping\",\"forget\":false},\"forget\":false},\"dispatched_at\":\"2011-01-13 10:20:38.204801 UTC\"},\"fei\":{\"engine_id\":\"engine\",\"wfid\":\"20110113-bechijiyogu\",\"sub_wfid\":null,\"expid\":\"0_0\"},\"participant_name\":\"ping\"}"
-2011-01-13 11:20:38.298255 ping(25802) [DEBUG] [daemon-kit]: Replying to engine via AMQP with #<DaemonKit::RuoteWorkitem:0x0000000209a720 @workitem={"fields"=>{"params"=>{"command"=>"/ping_pong/ping", "ref"=>"ping", "participant_options"=>{"queue"=>"ping", "forget"=>false}, "forget"=>false}, "dispatched_at"=>"2011-01-13 10:20:38.204801 UTC", "msg"=>"ping", "success"=>true}, "fei"=>{"engine_id"=>"engine", "wfid"=>"20110113-bechijiyogu", "sub_wfid"=>nil, "expid"=>"0_0"}, "participant_name"=>"ping"}>
-2011-01-13 11:20:38.298721 ping(25802) [DEBUG] [daemon-kit]: Processed workitem.
-2011-01-13 11:20:38.299194 ping(25802) [DEBUG] [daemon-kit]: Received workitem: "{\"fields\":{\"params\":{\"command\":\"/ping_pong/ping\",\"ref\":\"ping\",\"participant_options\":{\"queue\":\"ping\",\"forget\":false},\"forget\":false},\"dispatched_at\":\"2011-01-13 10:20:38.206666 UTC\"},\"fei\":{\"engine_id\":\"engine\",\"wfid\":\"20110113-bihagehiha\",\"sub_wfid\":null,\"expid\":\"0_0\"},\"participant_name\":\"ping\"}"
-2011-01-13 11:20:38.304778 ping(25802) [DEBUG] [daemon-kit]: Replying to engine via AMQP with #<DaemonKit::RuoteWorkitem:0x0000000208d3e0 @workitem={"fields"=>{"params"=>{"command"=>"/ping_pong/ping", "ref"=>"ping", "participant_options"=>{"queue"=>"ping", "forget"=>false}, "forget"=>false}, "dispatched_at"=>"2011-01-13 10:20:38.206666 UTC", "msg"=>"ping", "success"=>true}, "fei"=>{"engine_id"=>"engine", "wfid"=>"20110113-bihagehiha", "sub_wfid"=>nil, "expid"=>"0_0"}, "participant_name"=>"ping"}>
-2011-01-13 11:20:38.305336 ping(25802) [DEBUG] [daemon-kit]: Processed workitem.
-2011-01-13 11:22:29.932491 ping(25802) [DEBUG] [daemon-kit]: Received workitem: "{\"fields\":{\"params\":{\"command\":\"/ping_pong/ping\",\"ref\":\"ping\",\"participant_options\":{\"queue\":\"ping\",\"forget\":false},\"forget\":false},\"dispatched_at\":\"2011-01-13 10:22:29.927022 UTC\"},\"fei\":{\"engine_id\":\"engine\",\"wfid\":\"20110113-betahitoki\",\"sub_wfid\":null,\"expid\":\"0_0\"},\"participant_name\":\"ping\"}"
-2011-01-13 11:22:29.932910 ping(25802) [DEBUG] [daemon-kit]: Replying to engine via AMQP with #<DaemonKit::RuoteWorkitem:0x0000000207f2e0 @workitem={"fields"=>{"params"=>{"command"=>"/ping_pong/ping", "ref"=>"ping", "participant_options"=>{"queue"=>"ping", "forget"=>false}, "forget"=>false}, "dispatched_at"=>"2011-01-13 10:22:29.927022 UTC", "msg"=>"ping", "success"=>true}, "fei"=>{"engine_id"=>"engine", "wfid"=>"20110113-betahitoki", "sub_wfid"=>nil, "expid"=>"0_0"}, "participant_name"=>"ping"}>
-2011-01-13 11:22:29.933296 ping(25802) [DEBUG] [daemon-kit]: Processed workitem.
-2011-01-13 11:25:09.760396 ping(25802) [INFO] [daemon-kit]: Running signal traps for INT
-2011-01-13 11:25:09.761028 ping(25802) [INFO] [daemon-kit]: Running shutdown hooks
-2011-01-13 11:25:09.761205 ping(25802) [WARN] [daemon-kit]: Shutting down ping
-2011-01-13 11:25:18.689428 ping(28064) [INFO] [daemon-kit]: DaemonKit (0.1.8.1) booting in development mode
-2011-01-13 11:25:18.689631 ping(28064) [INFO] [daemon-kit]: Setting up trap for USR1
-2011-01-13 11:25:18.689733 ping(28064) [INFO] [daemon-kit]: Setting up trap for USR2
-2011-01-13 11:25:18.689828 ping(28064) [INFO] [daemon-kit]: Setting up trap for HUP
-2011-01-13 11:25:18.689921 ping(28064) [INFO] [daemon-kit]: Setting up trap for INT
-2011-01-13 11:25:18.690008 ping(28064) [INFO] [daemon-kit]: Setting up trap for TERM
-2011-01-13 11:25:18.691751 ping(28064) [INFO] [daemon-kit]: DaemonKit (0.1.8.1) booted, now running ping
-2011-01-13 11:25:18.696844 ping(28064) [DEBUG] [daemon-kit]: AMQP.start({:user=>"guest", :pass=>"guest", :host=>"localhost", :vhost=>"ping-pong"})
-2011-01-13 11:25:18.699954 ping(28064) [DEBUG] [daemon-kit]: Subscribing to ping for workitems
-2011-01-13 11:25:18.700170 ping(28064) [DEBUG] [daemon-kit]: Subscribing to pong for workitems
-2011-01-13 11:25:29.600776 ping(28064) [DEBUG] [daemon-kit]: Received workitem: "{\"fields\":{\"params\":{\"command\":\"/ping_pong/ping\",\"ref\":\"ping\",\"participant_options\":{\"queue\":\"ping\",\"forget\":false},\"forget\":false},\"dispatched_at\":\"2011-01-13 10:25:29.513698 UTC\"},\"fei\":{\"engine_id\":\"engine\",\"wfid\":\"20110113-besorudori\",\"sub_wfid\":null,\"expid\":\"0_0\"},\"participant_name\":\"ping\"}"
-2011-01-13 11:25:29.605250 ping(28064) [DEBUG] [daemon-kit]: Replying to engine via AMQP with #<DaemonKit::RuoteWorkitem:0x0000000201caf0 @workitem={"fields"=>{"params"=>{"command"=>"/ping_pong/ping", "ref"=>"ping", "participant_options"=>{"queue"=>"ping", "forget"=>false}, "forget"=>false}, "dispatched_at"=>"2011-01-13 10:25:29.513698 UTC", "msg"=>"ping", "success"=>true}, "fei"=>{"engine_id"=>"engine", "wfid"=>"20110113-besorudori", "sub_wfid"=>nil, "expid"=>"0_0"}, "participant_name"=>"ping"}>
-2011-01-13 11:25:29.623663 ping(28064) [DEBUG] [daemon-kit]: Processed workitem.
-2011-01-13 11:28:12.89289 ping(28064) [DEBUG] [daemon-kit]: Received workitem: "{\"fields\":{\"params\":{\"command\":\"/ping_pong/ping\",\"ref\":\"ping\",\"participant_options\":{\"queue\":\"ping\",\"forget\":false},\"forget\":false},\"dispatched_at\":\"2011-01-13 10:28:12.031591 UTC\"},\"fei\":{\"engine_id\":\"engine\",\"wfid\":\"20110113-sajidudu\",\"sub_wfid\":null,\"expid\":\"0_0\"},\"participant_name\":\"ping\"}"
-2011-01-13 11:28:12.89913 ping(28064) [DEBUG] [daemon-kit]: Replying to engine via AMQP with #<DaemonKit::RuoteWorkitem:0x000000030e4130 @workitem={"fields"=>{"params"=>{"command"=>"/ping_pong/ping", "ref"=>"ping", "participant_options"=>{"queue"=>"ping", "forget"=>false}, "forget"=>false}, "dispatched_at"=>"2011-01-13 10:28:12.031591 UTC", "msg"=>"ping", "success"=>true}, "fei"=>{"engine_id"=>"engine", "wfid"=>"20110113-sajidudu", "sub_wfid"=>nil, "expid"=>"0_0"}, "participant_name"=>"ping"}>
-2011-01-13 11:28:12.90579 ping(28064) [DEBUG] [daemon-kit]: Processed workitem.
-2011-01-13 11:34:39.682394 ping(28064) [INFO] [daemon-kit]: Running signal traps for INT
-2011-01-13 11:34:39.683011 ping(28064) [INFO] [daemon-kit]: Running shutdown hooks
-2011-01-13 11:34:39.683182 ping(28064) [WARN] [daemon-kit]: Shutting down ping
-2011-01-13 11:34:41.758999 ping(28760) [INFO] [daemon-kit]: DaemonKit (0.1.8.1) booting in development mode
-2011-01-13 11:34:41.759197 ping(28760) [INFO] [daemon-kit]: Setting up trap for USR1
-2011-01-13 11:34:41.759299 ping(28760) [INFO] [daemon-kit]: Setting up trap for USR2
-2011-01-13 11:34:41.759398 ping(28760) [INFO] [daemon-kit]: Setting up trap for HUP
-2011-01-13 11:34:41.759487 ping(28760) [INFO] [daemon-kit]: Setting up trap for INT
-2011-01-13 11:34:41.759576 ping(28760) [INFO] [daemon-kit]: Setting up trap for TERM
-2011-01-13 11:34:41.761333 ping(28760) [INFO] [daemon-kit]: DaemonKit (0.1.8.1) booted, now running ping
-2011-01-13 11:34:41.766369 ping(28760) [DEBUG] [daemon-kit]: AMQP.start({:user=>"guest", :pass=>"guest", :host=>"localhost", :vhost=>"ping-pong"})
-2011-01-13 11:34:41.769163 ping(28760) [DEBUG] [daemon-kit]: Subscribing to ping for workitems
-2011-01-13 11:34:41.769363 ping(28760) [DEBUG] [daemon-kit]: Subscribing to pong for workitems
-2011-01-13 11:34:58.71618 ping(28760) [DEBUG] [daemon-kit]: Received workitem: "{\"fields\":{\"params\":{\"command\":\"/ping_pong/ping\",\"ref\":\"ping\",\"participant_options\":{\"queue\":\"ping\",\"forget\":false},\"forget\":false},\"dispatched_at\":\"2011-01-13 10:34:58.018086 UTC\"},\"fei\":{\"engine_id\":\"engine\",\"wfid\":\"20110113-bomogohima\",\"sub_wfid\":null,\"expid\":\"0_0\"},\"participant_name\":\"ping\"}"
-2011-01-13 11:34:58.91188 ping(28760) [DEBUG] [daemon-kit]: Replying to engine via AMQP with #<DaemonKit::RuoteWorkitem:0x000000012b4930 @workitem={"fields"=>{"params"=>{"command"=>"/ping_pong/ping", "ref"=>"ping", "participant_options"=>{"queue"=>"ping", "forget"=>false}, "forget"=>false}, "dispatched_at"=>"2011-01-13 10:34:58.018086 UTC", "msg"=>"ping", "success"=>true}, "fei"=>{"engine_id"=>"engine", "wfid"=>"20110113-bomogohima", "sub_wfid"=>nil, "expid"=>"0_0"}, "participant_name"=>"ping"}>
-2011-01-13 11:34:58.93858 ping(28760) [DEBUG] [daemon-kit]: Processed workitem.
-2011-01-13 11:37:33.731192 ping(28760) [DEBUG] [daemon-kit]: Received workitem: "{\"fields\":{\"params\":{\"command\":\"/ping_pong/ping\",\"ref\":\"ping\",\"participant_options\":{\"queue\":\"ping\",\"forget\":false},\"forget\":false},\"dispatched_at\":\"2011-01-13 10:37:33.643111 UTC\"},\"fei\":{\"engine_id\":\"engine\",\"wfid\":\"20110113-bewopameza\",\"sub_wfid\":null,\"expid\":\"0_0\"},\"participant_name\":\"ping\"}"
-2011-01-13 11:37:33.731831 ping(28760) [DEBUG] [daemon-kit]: Replying to engine via AMQP with #<DaemonKit::RuoteWorkitem:0x0000000237d5f0 @workitem={"fields"=>{"params"=>{"command"=>"/ping_pong/ping", "ref"=>"ping", "participant_options"=>{"queue"=>"ping", "forget"=>false}, "forget"=>false}, "dispatched_at"=>"2011-01-13 10:37:33.643111 UTC", "msg"=>"ping", "success"=>true}, "fei"=>{"engine_id"=>"engine", "wfid"=>"20110113-bewopameza", "sub_wfid"=>nil, "expid"=>"0_0"}, "participant_name"=>"ping"}>
-2011-01-13 11:37:33.732548 ping(28760) [DEBUG] [daemon-kit]: Processed workitem.
-2011-01-13 11:56:34.721560 ping(28760) [DEBUG] [daemon-kit]: Received workitem: "{\"fields\":{\"params\":{\"command\":\"/ping_pong/ping\",\"ref\":\"ping\",\"participant_options\":{\"queue\":\"ping\",\"forget\":false},\"forget\":false},\"dispatched_at\":\"2011-01-13 10:56:34.708762 UTC\"},\"fei\":{\"engine_id\":\"engine\",\"wfid\":\"20110113-bidapadubu\",\"sub_wfid\":null,\"expid\":\"0_0\"},\"participant_name\":\"ping\"}"
-2011-01-13 11:56:34.722039 ping(28760) [DEBUG] [daemon-kit]: Replying to engine via AMQP with #<DaemonKit::RuoteWorkitem:0x0000000235dd68 @workitem={"fields"=>{"params"=>{"command"=>"/ping_pong/ping", "ref"=>"ping", "participant_options"=>{"queue"=>"ping", "forget"=>false}, "forget"=>false}, "dispatched_at"=>"2011-01-13 10:56:34.708762 UTC", "msg"=>"ping", "success"=>true}, "fei"=>{"engine_id"=>"engine", "wfid"=>"20110113-bidapadubu", "sub_wfid"=>nil, "expid"=>"0_0"}, "participant_name"=>"ping"}>
-2011-01-13 11:56:34.722487 ping(28760) [DEBUG] [daemon-kit]: Processed workitem.
-2011-01-13 11:57:22.489768 ping(28760) [DEBUG] [daemon-kit]: Received workitem: "{\"fields\":{\"params\":{\"command\":\"/ping_pong/ping\",\"ref\":\"ping\",\"participant_options\":{\"queue\":\"ping\",\"forget\":false},\"forget\":false},\"dispatched_at\":\"2011-01-13 10:57:22.458129 UTC\"},\"fei\":{\"engine_id\":\"engine\",\"wfid\":\"20110113-bejugodenu\",\"sub_wfid\":null,\"expid\":\"0_0\"},\"participant_name\":\"ping\"}"
-2011-01-13 11:57:22.490404 ping(28760) [DEBUG] [daemon-kit]: Replying to engine via AMQP with #<DaemonKit::RuoteWorkitem:0x000000023366a0 @workitem={"fields"=>{"params"=>{"command"=>"/ping_pong/ping", "ref"=>"ping", "participant_options"=>{"queue"=>"ping", "forget"=>false}, "forget"=>false}, "dispatched_at"=>"2011-01-13 10:57:22.458129 UTC", "msg"=>"ping", "success"=>true}, "fei"=>{"engine_id"=>"engine", "wfid"=>"20110113-bejugodenu", "sub_wfid"=>nil, "expid"=>"0_0"}, "participant_name"=>"ping"}>
-2011-01-13 11:57:22.491058 ping(28760) [DEBUG] [daemon-kit]: Processed workitem.
-2011-01-13 11:57:39.708568 ping(28760) [DEBUG] [daemon-kit]: Received workitem: "{\"fields\":{\"params\":{\"command\":\"/ping_pong/ping\",\"ref\":\"ping\",\"participant_options\":{\"queue\":\"ping\",\"forget\":false},\"forget\":false},\"dispatched_at\":\"2011-01-13 10:57:39.660285 UTC\"},\"fei\":{\"engine_id\":\"engine\",\"wfid\":\"20110113-bikazapimi\",\"sub_wfid\":null,\"expid\":\"0_0\"},\"participant_name\":\"ping\"}"
-2011-01-13 11:57:39.709205 ping(28760) [DEBUG] [daemon-kit]: Replying to engine via AMQP with #<DaemonKit::RuoteWorkitem:0x000000023269a8 @workitem={"fields"=>{"params"=>{"command"=>"/ping_pong/ping", "ref"=>"ping", "participant_options"=>{"queue"=>"ping", "forget"=>false}, "forget"=>false}, "dispatched_at"=>"2011-01-13 10:57:39.660285 UTC", "msg"=>"ping", "success"=>true}, "fei"=>{"engine_id"=>"engine", "wfid"=>"20110113-bikazapimi", "sub_wfid"=>nil, "expid"=>"0_0"}, "participant_name"=>"ping"}>
-2011-01-13 11:57:39.709889 ping(28760) [DEBUG] [daemon-kit]: Processed workitem.
-2011-01-13 12:00:31.487908 ping(28760) [DEBUG] [daemon-kit]: Received workitem: "{\"fields\":{\"params\":{\"command\":\"/ping_pong/ping\",\"ref\":\"ping\",\"participant_options\":{\"queue\":\"ping\",\"forget\":false},\"forget\":false},\"dispatched_at\":\"2011-01-13 11:00:31.399058 UTC\"},\"fei\":{\"engine_id\":\"engine\",\"wfid\":\"20110113-bezepikore\",\"sub_wfid\":null,\"expid\":\"0_0\"},\"participant_name\":\"ping\"}"
-2011-01-13 12:00:31.488560 ping(28760) [DEBUG] [daemon-kit]: Replying to engine via AMQP with #<DaemonKit::RuoteWorkitem:0x00000002317bb0 @workitem={"fields"=>{"params"=>{"command"=>"/ping_pong/ping", "ref"=>"ping", "participant_options"=>{"queue"=>"ping", "forget"=>false}, "forget"=>false}, "dispatched_at"=>"2011-01-13 11:00:31.399058 UTC", "msg"=>"ping", "success"=>true}, "fei"=>{"engine_id"=>"engine", "wfid"=>"20110113-bezepikore", "sub_wfid"=>nil, "expid"=>"0_0"}, "participant_name"=>"ping"}>
-2011-01-13 12:00:31.489254 ping(28760) [DEBUG] [daemon-kit]: Processed workitem.
-2011-01-13 12:00:48.623763 ping(28760) [DEBUG] [daemon-kit]: Received workitem: "{\"fields\":{\"params\":{\"command\":\"/ping_pong/ping\",\"ref\":\"ping\",\"participant_options\":{\"queue\":\"ping\",\"forget\":false},\"forget\":false},\"dispatched_at\":\"2011-01-13 11:00:48.557836 UTC\"},\"fei\":{\"engine_id\":\"engine\",\"wfid\":\"20110113-bizosogashi\",\"sub_wfid\":null,\"expid\":\"0_0\"},\"participant_name\":\"ping\"}"
-2011-01-13 12:00:48.624397 ping(28760) [DEBUG] [daemon-kit]: Replying to engine via AMQP with #<DaemonKit::RuoteWorkitem:0x00000002308610 @workitem={"fields"=>{"params"=>{"command"=>"/ping_pong/ping", "ref"=>"ping", "participant_options"=>{"queue"=>"ping", "forget"=>false}, "forget"=>false}, "dispatched_at"=>"2011-01-13 11:00:48.557836 UTC", "msg"=>"ping", "success"=>true}, "fei"=>{"engine_id"=>"engine", "wfid"=>"20110113-bizosogashi", "sub_wfid"=>nil, "expid"=>"0_0"}, "participant_name"=>"ping"}>
-2011-01-13 12:00:48.625045 ping(28760) [DEBUG] [daemon-kit]: Processed workitem.
-2011-01-13 12:27:46.848605 ping(28760) [INFO] [daemon-kit]: Running signal traps for INT
-2011-01-13 12:27:46.849238 ping(28760) [INFO] [daemon-kit]: Running shutdown hooks
-2011-01-13 12:27:46.849410 ping(28760) [WARN] [daemon-kit]: Shutting down ping
-2011-01-13 12:27:52.491453 ping(565) [INFO] [daemon-kit]: DaemonKit (0.1.8.1) booting in development mode
-2011-01-13 12:27:52.491663 ping(565) [INFO] [daemon-kit]: Setting up trap for USR1
-2011-01-13 12:27:52.491765 ping(565) [INFO] [daemon-kit]: Setting up trap for USR2
-2011-01-13 12:27:52.491855 ping(565) [INFO] [daemon-kit]: Setting up trap for HUP
-2011-01-13 12:27:52.491949 ping(565) [INFO] [daemon-kit]: Setting up trap for INT
-2011-01-13 12:27:52.492032 ping(565) [INFO] [daemon-kit]: Setting up trap for TERM
-2011-01-13 12:27:52.493787 ping(565) [INFO] [daemon-kit]: DaemonKit (0.1.8.1) booted, now running ping
-2011-01-13 12:27:52.499537 ping(565) [DEBUG] [daemon-kit]: AMQP.start({:user=>"guest", :pass=>"guest", :host=>"localhost", :vhost=>"ping-pong"})
-2011-01-13 12:27:52.502276 ping(565) [DEBUG] [daemon-kit]: Subscribing to ping for workitems
-2011-01-13 12:27:52.502475 ping(565) [DEBUG] [daemon-kit]: Subscribing to pong for workitems
-2011-01-13 12:28:19.508558 ping(565) [DEBUG] [daemon-kit]: Received workitem: "{\"fields\":{\"params\":{\"command\":\"/ping_pong/ping\",\"ref\":\"ping\",\"participant_options\":{\"queue\":\"ping\",\"forget\":false},\"forget\":false},\"dispatched_at\":\"2011-01-13 11:28:19.450864 UTC\"},\"fei\":{\"engine_id\":\"engine\",\"wfid\":\"20110113-begegihozo\",\"sub_wfid\":null,\"expid\":\"0_0\"},\"participant_name\":\"ping\"}"
-2011-01-13 12:28:19.521478 ping(565) [DEBUG] [daemon-kit]: Replying to engine via AMQP with #<DaemonKit::RuoteWorkitem:0x000000007fa670 @workitem={"fields"=>{"params"=>{"command"=>"/ping_pong/ping", "ref"=>"ping", "participant_options"=>{"queue"=>"ping", "forget"=>false}, "forget"=>false}, "dispatched_at"=>"2011-01-13 11:28:19.450864 UTC", "msg"=>"ping", "success"=>true}, "fei"=>{"engine_id"=>"engine", "wfid"=>"20110113-begegihozo", "sub_wfid"=>nil, "expid"=>"0_0"}, "participant_name"=>"ping"}>
-2011-01-13 12:28:19.539227 ping(565) [DEBUG] [daemon-kit]: Processed workitem.
-2011-01-13 12:30:30.850173 ping(565) [INFO] [daemon-kit]: Running signal traps for INT
-2011-01-13 12:30:30.850802 ping(565) [INFO] [daemon-kit]: Running shutdown hooks
-2011-01-13 12:30:30.850975 ping(565) [WARN] [daemon-kit]: Shutting down ping
-2011-01-13 12:30:32.46990 ping(958) [INFO] [daemon-kit]: DaemonKit (0.1.8.1) booting in development mode
-2011-01-13 12:30:32.47194 ping(958) [INFO] [daemon-kit]: Setting up trap for USR1
-2011-01-13 12:30:32.47295 ping(958) [INFO] [daemon-kit]: Setting up trap for USR2
-2011-01-13 12:30:32.47389 ping(958) [INFO] [daemon-kit]: Setting up trap for HUP
-2011-01-13 12:30:32.47481 ping(958) [INFO] [daemon-kit]: Setting up trap for INT
-2011-01-13 12:30:32.47569 ping(958) [INFO] [daemon-kit]: Setting up trap for TERM
-2011-01-13 12:30:32.49341 ping(958) [INFO] [daemon-kit]: DaemonKit (0.1.8.1) booted, now running ping
-2011-01-13 12:30:32.55191 ping(958) [DEBUG] [daemon-kit]: AMQP.start({:user=>"guest", :pass=>"guest", :host=>"localhost", :vhost=>"ping-pong"})
-2011-01-13 12:30:32.58018 ping(958) [DEBUG] [daemon-kit]: Subscribing to ping for workitems
-2011-01-13 12:30:32.58217 ping(958) [DEBUG] [daemon-kit]: Subscribing to pong for workitems
-2011-01-13 12:31:23.290838 ping(958) [DEBUG] [daemon-kit]: Received workitem: "{\"fields\":{\"params\":{\"command\":\"/ping_pong/ping\",\"ref\":\"ping\",\"participant_options\":{\"queue\":\"ping\",\"forget\":false},\"forget\":false},\"dispatched_at\":\"2011-01-13 11:31:23.206860 UTC\"},\"fei\":{\"engine_id\":\"engine\",\"wfid\":\"20110113-bekigupone\",\"sub_wfid\":null,\"expid\":\"0_0\"},\"participant_name\":\"ping\"}"
-2011-01-13 12:31:23.299721 ping(958) [DEBUG] [daemon-kit]: Replying to engine via AMQP with #<DaemonKit::RuoteWorkitem:0x000000008fddb0 @workitem={"fields"=>{"params"=>{"command"=>"/ping_pong/ping", "ref"=>"ping", "participant_options"=>{"queue"=>"ping", "forget"=>false}, "forget"=>false}, "dispatched_at"=>"2011-01-13 11:31:23.206860 UTC", "msg"=>"ping", "success"=>true}, "fei"=>{"engine_id"=>"engine", "wfid"=>"20110113-bekigupone", "sub_wfid"=>nil, "expid"=>"0_0"}, "participant_name"=>"ping"}>
-2011-01-13 12:31:23.325440 ping(958) [DEBUG] [daemon-kit]: Processed workitem.
-2011-01-13 12:32:05.435547 ping(958) [DEBUG] [daemon-kit]: Received workitem: "{\"fields\":{\"params\":{\"command\":\"/ping_pong/ping\",\"ref\":\"ping\",\"participant_options\":{\"queue\":\"ping\",\"forget\":false},\"forget\":false},\"dispatched_at\":\"2011-01-13 11:32:05.428034 UTC\"},\"fei\":{\"engine_id\":\"engine\",\"wfid\":\"20110113-jimedeni\",\"sub_wfid\":null,\"expid\":\"0_0\"},\"participant_name\":\"ping\"}"
-2011-01-13 12:32:05.436051 ping(958) [DEBUG] [daemon-kit]: Replying to engine via AMQP with #<DaemonKit::RuoteWorkitem:0x000000019c4c70 @workitem={"fields"=>{"params"=>{"command"=>"/ping_pong/ping", "ref"=>"ping", "participant_options"=>{"queue"=>"ping", "forget"=>false}, "forget"=>false}, "dispatched_at"=>"2011-01-13 11:32:05.428034 UTC", "msg"=>"ping", "success"=>true}, "fei"=>{"engine_id"=>"engine", "wfid"=>"20110113-jimedeni", "sub_wfid"=>nil, "expid"=>"0_0"}, "participant_name"=>"ping"}>
-2011-01-13 12:32:05.436553 ping(958) [DEBUG] [daemon-kit]: Processed workitem.
-2011-01-13 12:32:42.699395 ping(958) [INFO] [daemon-kit]: Running signal traps for TERM
-2011-01-13 12:32:42.699857 ping(958) [INFO] [daemon-kit]: Running shutdown hooks
-2011-01-13 12:32:42.699996 ping(958) [WARN] [daemon-kit]: Shutting down ping
-2011-01-13 12:53:19.225275 ping(4269) [INFO] [daemon-kit]: DaemonKit (0.1.8.1) booting in development mode
-2011-01-13 12:53:19.225504 ping(4269) [INFO] [daemon-kit]: Setting up trap for USR1
-2011-01-13 12:53:19.225609 ping(4269) [INFO] [daemon-kit]: Setting up trap for USR2
-2011-01-13 12:53:19.225706 ping(4269) [INFO] [daemon-kit]: Setting up trap for HUP
-2011-01-13 12:53:19.225822 ping(4269) [INFO] [daemon-kit]: Setting up trap for INT
-2011-01-13 12:53:19.225914 ping(4269) [INFO] [daemon-kit]: Setting up trap for TERM
-2011-01-13 12:53:19.227875 ping(4269) [INFO] [daemon-kit]: DaemonKit (0.1.8.1) booted, now running ping
-2011-01-13 12:53:19.233046 ping(4269) [DEBUG] [daemon-kit]: AMQP.start({:user=>"guest", :pass=>"guest", :host=>"localhost", :vhost=>"ping-pong"})
-2011-01-13 12:53:19.235822 ping(4269) [DEBUG] [daemon-kit]: Subscribing to ping for workitems
-2011-01-13 12:53:19.236018 ping(4269) [DEBUG] [daemon-kit]: Subscribing to pong for workitems
-2011-01-13 12:53:21.629261 ping(4269) [DEBUG] [daemon-kit]: Received workitem: "{\"fields\":{\"params\":{\"command\":\"/ping_pong/ping\",\"ref\":\"ping\",\"participant_options\":{\"queue\":\"ping\",\"forget\":false,\"reply_queue\":\"ruote_workitems\"},\"forget\":false},\"dispatched_at\":\"2011-01-13 11:53:21.605319 UTC\"},\"fei\":{\"engine_id\":\"engine\",\"wfid\":\"20110113-bejapiyashi\",\"sub_wfid\":null,\"expid\":\"0_0\"},\"participant_name\":\"ping\"}"
-2011-01-13 12:53:21.633860 ping(4269) [DEBUG] [daemon-kit]: Replying to engine via AMQP with #<DaemonKit::RuoteWorkitem:0x00000000f043f8 @workitem={"fields"=>{"params"=>{"command"=>"/ping_pong/ping", "ref"=>"ping", "participant_options"=>{"queue"=>"ping", "forget"=>false, "reply_queue"=>"ruote_workitems"}, "forget"=>false}, "dispatched_at"=>"2011-01-13 11:53:21.605319 UTC", "msg"=>"ping", "success"=>true}, "fei"=>{"engine_id"=>"engine", "wfid"=>"20110113-bejapiyashi", "sub_wfid"=>nil, "expid"=>"0_0"}, "participant_name"=>"ping"}>
-2011-01-13 12:53:21.649980 ping(4269) [DEBUG] [daemon-kit]: Processed workitem.
-2011-01-13 12:57:17.70992 ping(4269) [DEBUG] [daemon-kit]: Received workitem: "{\"fields\":{\"params\":{\"command\":\"/ping_pong/ping\",\"ref\":\"ping\",\"participant_options\":{\"queue\":\"ping\",\"forget\":false,\"reply_queue\":\"ruote_workitems\"},\"forget\":false},\"dispatched_at\":\"2011-01-13 11:57:17.013409 UTC\"},\"fei\":{\"engine_id\":\"engine\",\"wfid\":\"20110113-bebedumeri\",\"sub_wfid\":null,\"expid\":\"0_0\"},\"participant_name\":\"ping\"}"
-2011-01-13 12:57:17.71635 ping(4269) [DEBUG] [daemon-kit]: Replying to engine via AMQP with #<DaemonKit::RuoteWorkitem:0x00000001fd2d88 @workitem={"fields"=>{"params"=>{"command"=>"/ping_pong/ping", "ref"=>"ping", "participant_options"=>{"queue"=>"ping", "forget"=>false, "reply_queue"=>"ruote_workitems"}, "forget"=>false}, "dispatched_at"=>"2011-01-13 11:57:17.013409 UTC", "msg"=>"ping", "success"=>true}, "fei"=>{"engine_id"=>"engine", "wfid"=>"20110113-bebedumeri", "sub_wfid"=>nil, "expid"=>"0_0"}, "participant_name"=>"ping"}>
-2011-01-13 12:57:17.72347 ping(4269) [DEBUG] [daemon-kit]: Processed workitem.
-2011-01-13 12:58:29.254768 ping(4269) [DEBUG] [daemon-kit]: Received workitem: "{\"fields\":{\"params\":{\"command\":\"/ping_pong/ping\",\"reply_queue\":\"ruote_workitems\",\"queue\":\"ping\",\"ref\":\"ping\",\"participant_options\":{\"queue\":\"ping\",\"forget\":false,\"reply_queue\":\"ruote_workitems\"},\"forget\":false},\"dispatched_at\":\"2011-01-13 11:58:29.225245 UTC\"},\"fei\":{\"engine_id\":\"engine\",\"wfid\":\"20110113-beshinuniwo\",\"sub_wfid\":null,\"expid\":\"0_0\"},\"participant_name\":\"ping\"}"
-2011-01-13 12:58:29.255421 ping(4269) [DEBUG] [daemon-kit]: Replying to engine via AMQP with #<DaemonKit::RuoteWorkitem:0x00000001fac7a0 @workitem={"fields"=>{"params"=>{"command"=>"/ping_pong/ping", "reply_queue"=>"ruote_workitems", "queue"=>"ping", "ref"=>"ping", "participant_options"=>{"queue"=>"ping", "forget"=>false, "reply_queue"=>"ruote_workitems"}, "forget"=>false}, "dispatched_at"=>"2011-01-13 11:58:29.225245 UTC", "msg"=>"ping", "success"=>true}, "fei"=>{"engine_id"=>"engine", "wfid"=>"20110113-beshinuniwo", "sub_wfid"=>nil, "expid"=>"0_0"}, "participant_name"=>"ping"}>
-2011-01-13 12:58:29.256307 ping(4269) [DEBUG] [daemon-kit]: Processed workitem.
-2011-01-13 12:58:29.346868 ping(4269) [DEBUG] [daemon-kit]: Received workitem: "{\"fields\":{\"msg\":\"ping\",\"success\":true,\"params\":{\"command\":\"/ping_pong/pong\",\"reply_queue\":\"ruote_workitems\",\"queue\":\"pong\",\"ref\":\"pong\",\"participant_options\":{\"queue\":\"pong\",\"forget\":false,\"reply_queue\":\"ruote_workitems\"},\"forget\":false},\"dispatched_at\":\"2011-01-13 11:58:29.283438 UTC\"},\"fei\":{\"engine_id\":\"engine\",\"wfid\":\"20110113-beshinuniwo\",\"sub_wfid\":null,\"expid\":\"0_1\"},\"participant_name\":\"pong\"}"
-2011-01-13 12:58:29.347609 ping(4269) [DEBUG] [daemon-kit]: Replying to engine via AMQP with #<DaemonKit::RuoteWorkitem:0x00000001f7d860 @workitem={"fields"=>{"msg"=>"pong", "success"=>true, "params"=>{"command"=>"/ping_pong/pong", "reply_queue"=>"ruote_workitems", "queue"=>"pong", "ref"=>"pong", "participant_options"=>{"queue"=>"pong", "forget"=>false, "reply_queue"=>"ruote_workitems"}, "forget"=>false}, "dispatched_at"=>"2011-01-13 11:58:29.283438 UTC"}, "fei"=>{"engine_id"=>"engine", "wfid"=>"20110113-beshinuniwo", "sub_wfid"=>nil, "expid"=>"0_1"}, "participant_name"=>"pong"}>
-2011-01-13 12:58:29.348289 ping(4269) [DEBUG] [daemon-kit]: Processed workitem.
-2011-01-13 12:58:35.388761 ping(4269) [DEBUG] [daemon-kit]: Received workitem: "{\"fields\":{\"params\":{\"command\":\"/ping_pong/ping\",\"reply_queue\":\"ruote_workitems\",\"queue\":\"ping\",\"ref\":\"ping\",\"participant_options\":{\"queue\":\"ping\",\"forget\":false,\"reply_queue\":\"ruote_workitems\"},\"forget\":false},\"dispatched_at\":\"2011-01-13 11:58:35.368636 UTC\"},\"fei\":{\"engine_id\":\"engine\",\"wfid\":\"20110113-bidokohahi\",\"sub_wfid\":null,\"expid\":\"0_0\"},\"participant_name\":\"ping\"}"
-2011-01-13 12:58:35.389419 ping(4269) [DEBUG] [daemon-kit]: Replying to engine via AMQP with #<DaemonKit::RuoteWorkitem:0x00000001f705e8 @workitem={"fields"=>{"params"=>{"command"=>"/ping_pong/ping", "reply_queue"=>"ruote_workitems", "queue"=>"ping", "ref"=>"ping", "participant_options"=>{"queue"=>"ping", "forget"=>false, "reply_queue"=>"ruote_workitems"}, "forget"=>false}, "dispatched_at"=>"2011-01-13 11:58:35.368636 UTC", "msg"=>"ping", "success"=>true}, "fei"=>{"engine_id"=>"engine", "wfid"=>"20110113-bidokohahi", "sub_wfid"=>nil, "expid"=>"0_0"}, "participant_name"=>"ping"}>
-2011-01-13 12:58:35.390092 ping(4269) [DEBUG] [daemon-kit]: Processed workitem.
-2011-01-13 12:58:35.486322 ping(4269) [DEBUG] [daemon-kit]: Received workitem: "{\"fields\":{\"msg\":\"ping\",\"success\":true,\"params\":{\"command\":\"/ping_pong/pong\",\"reply_queue\":\"ruote_workitems\",\"queue\":\"pong\",\"ref\":\"pong\",\"participant_options\":{\"queue\":\"pong\",\"forget\":false,\"reply_queue\":\"ruote_workitems\"},\"forget\":false},\"dispatched_at\":\"2011-01-13 11:58:35.444283 UTC\"},\"fei\":{\"engine_id\":\"engine\",\"wfid\":\"20110113-bidokohahi\",\"sub_wfid\":null,\"expid\":\"0_1\"},\"participant_name\":\"pong\"}"
-2011-01-13 12:58:35.487033 ping(4269) [DEBUG] [daemon-kit]: Replying to engine via AMQP with #<DaemonKit::RuoteWorkitem:0x00000001f61ac0 @workitem={"fields"=>{"msg"=>"pong", "success"=>true, "params"=>{"command"=>"/ping_pong/pong", "reply_queue"=>"ruote_workitems", "queue"=>"pong", "ref"=>"pong", "participant_options"=>{"queue"=>"pong", "forget"=>false, "reply_queue"=>"ruote_workitems"}, "forget"=>false}, "dispatched_at"=>"2011-01-13 11:58:35.444283 UTC"}, "fei"=>{"engine_id"=>"engine", "wfid"=>"20110113-bidokohahi", "sub_wfid"=>nil, "expid"=>"0_1"}, "participant_name"=>"pong"}>
-2011-01-13 12:58:35.487738 ping(4269) [DEBUG] [daemon-kit]: Processed workitem.
-2011-01-13 14:41:02.855769 ping(4269) [INFO] [daemon-kit]: Running signal traps for INT
-2011-01-13 14:41:02.856386 ping(4269) [INFO] [daemon-kit]: Running shutdown hooks
-2011-01-13 14:41:02.856560 ping(4269) [WARN] [daemon-kit]: Shutting down ping
-2011-01-13 14:59:12.562201 ping(14579) [INFO] [daemon-kit]: DaemonKit (0.1.8.1) booting in development mode
-2011-01-13 14:59:12.562410 ping(14579) [INFO] [daemon-kit]: Setting up trap for USR1
-2011-01-13 14:59:12.562511 ping(14579) [INFO] [daemon-kit]: Setting up trap for USR2
-2011-01-13 14:59:12.562604 ping(14579) [INFO] [daemon-kit]: Setting up trap for HUP
-2011-01-13 14:59:12.562692 ping(14579) [INFO] [daemon-kit]: Setting up trap for INT
-2011-01-13 14:59:12.562794 ping(14579) [INFO] [daemon-kit]: Setting up trap for TERM
-2011-01-13 14:59:12.564548 ping(14579) [INFO] [daemon-kit]: DaemonKit (0.1.8.1) booted, now running ping
-2011-01-13 14:59:12.569680 ping(14579) [DEBUG] [daemon-kit]: AMQP.start({:user=>"guest", :pass=>"guest", :host=>"localhost", :vhost=>"ping-pong"})
-2011-01-13 14:59:12.572858 ping(14579) [DEBUG] [daemon-kit]: Subscribing to ping for workitems
-2011-01-13 14:59:12.573065 ping(14579) [DEBUG] [daemon-kit]: Subscribing to pong for workitems
-2011-01-13 14:59:12.576523 ping(14579) [INFO] [daemon-kit]: Running shutdown hooks
-2011-01-13 14:59:12.576666 ping(14579) [WARN] [daemon-kit]: Shutting down ping
-2011-01-13 15:00:02.929409 ping(14625) [INFO] [daemon-kit]: DaemonKit (0.1.8.1) booting in development mode
-2011-01-13 15:00:02.929612 ping(14625) [INFO] [daemon-kit]: Setting up trap for USR1
-2011-01-13 15:00:02.929720 ping(14625) [INFO] [daemon-kit]: Setting up trap for USR2
-2011-01-13 15:00:02.929810 ping(14625) [INFO] [daemon-kit]: Setting up trap for HUP
-2011-01-13 15:00:02.929905 ping(14625) [INFO] [daemon-kit]: Setting up trap for INT
-2011-01-13 15:00:02.929989 ping(14625) [INFO] [daemon-kit]: Setting up trap for TERM
-2011-01-13 15:00:02.931748 ping(14625) [INFO] [daemon-kit]: DaemonKit (0.1.8.1) booted, now running ping
-2011-01-13 15:00:02.936856 ping(14625) [DEBUG] [daemon-kit]: AMQP.start({:user=>"guest", :pass=>"guest", :host=>"localhost", :vhost=>"ping-pong"})
-2011-01-13 15:00:02.939969 ping(14625) [DEBUG] [daemon-kit]: Subscribing to ping for workitems
-2011-01-13 15:00:02.940177 ping(14625) [DEBUG] [daemon-kit]: Subscribing to pong for workitems
-2011-01-13 15:02:29.579095 ping(14625) [DEBUG] [daemon-kit]: Received workitem: "{\"fields\":{\"params\":{\"command\":\"/ping_pong/ping\",\"reply_queue\":\"ruote_workitems\",\"queue\":\"ping\",\"ref\":\"ping\",\"participant_options\":{\"queue\":\"ping\",\"forget\":false,\"reply_queue\":\"ruote_workitems\"},\"forget\":false},\"dispatched_at\":\"2011-01-13 14:02:29.557858 UTC\"},\"fei\":{\"engine_id\":\"engine\",\"wfid\":\"20110113-bodinutame\",\"sub_wfid\":null,\"expid\":\"0_0\"},\"participant_name\":\"ping\"}"
-2011-01-13 15:02:29.583565 ping(14625) [DEBUG] [daemon-kit]: Replying to engine via AMQP with #<DaemonKit::RuoteWorkitem:0x0000000177e510 @workitem={"fields"=>{"params"=>{"command"=>"/ping_pong/ping", "reply_queue"=>"ruote_workitems", "queue"=>"ping", "ref"=>"ping", "participant_options"=>{"queue"=>"ping", "forget"=>false, "reply_queue"=>"ruote_workitems"}, "forget"=>false}, "dispatched_at"=>"2011-01-13 14:02:29.557858 UTC", "msg"=>"ping", "success"=>true}, "fei"=>{"engine_id"=>"engine", "wfid"=>"20110113-bodinutame", "sub_wfid"=>nil, "expid"=>"0_0"}, "participant_name"=>"ping"}>
-2011-01-13 15:02:29.599567 ping(14625) [DEBUG] [daemon-kit]: Processed workitem.
-2011-01-13 15:06:01.79928 ping(14625) [DEBUG] [daemon-kit]: Received workitem: "{\"fields\":{\"params\":{\"command\":\"/ping_pong/ping\",\"reply_queue\":\"ruote_workitems\",\"queue\":\"ping\",\"ref\":\"ping\",\"participant_options\":{\"queue\":\"ping\",\"forget\":false,\"reply_queue\":\"ruote_workitems\"},\"forget\":false},\"dispatched_at\":\"2011-01-13 14:06:01.073015 UTC\"},\"fei\":{\"engine_id\":\"engine\",\"wfid\":\"20110113-bujosobe\",\"sub_wfid\":null,\"expid\":\"0_0\"},\"participant_name\":\"ping\"}"
-2011-01-13 15:06:01.80621 ping(14625) [DEBUG] [daemon-kit]: Replying to engine via AMQP with #<DaemonKit::RuoteWorkitem:0x0000000284cc98 @workitem={"fields"=>{"params"=>{"command"=>"/ping_pong/ping", "reply_queue"=>"ruote_workitems", "queue"=>"ping", "ref"=>"ping", "participant_options"=>{"queue"=>"ping", "forget"=>false, "reply_queue"=>"ruote_workitems"}, "forget"=>false}, "dispatched_at"=>"2011-01-13 14:06:01.073015 UTC", "msg"=>"ping", "success"=>true}, "fei"=>{"engine_id"=>"engine", "wfid"=>"20110113-bujosobe", "sub_wfid"=>nil, "expid"=>"0_0"}, "participant_name"=>"ping"}>
-2011-01-13 15:06:01.83846 ping(14625) [DEBUG] [daemon-kit]: Processed workitem.
-2011-01-13 15:13:54.848683 ping(14625) [INFO] [daemon-kit]: Running signal traps for INT
-2011-01-13 15:13:54.849317 ping(14625) [INFO] [daemon-kit]: Running shutdown hooks
-2011-01-13 15:13:54.849488 ping(14625) [WARN] [daemon-kit]: Shutting down ping
-2011-01-13 15:13:56.891369 ping(17287) [INFO] [daemon-kit]: DaemonKit (0.1.8.1) booting in development mode
-2011-01-13 15:13:56.891563 ping(17287) [INFO] [daemon-kit]: Setting up trap for USR1
-2011-01-13 15:13:56.891674 ping(17287) [INFO] [daemon-kit]: Setting up trap for USR2
-2011-01-13 15:13:56.891764 ping(17287) [INFO] [daemon-kit]: Setting up trap for HUP
-2011-01-13 15:13:56.891857 ping(17287) [INFO] [daemon-kit]: Setting up trap for INT
-2011-01-13 15:13:56.891942 ping(17287) [INFO] [daemon-kit]: Setting up trap for TERM
-2011-01-13 15:13:56.893730 ping(17287) [INFO] [daemon-kit]: DaemonKit (0.1.8.1) booted, now running ping
-2011-01-13 15:13:56.898889 ping(17287) [DEBUG] [daemon-kit]: AMQP.start({:user=>"guest", :pass=>"guest", :host=>"localhost", :vhost=>"ping-pong"})
-2011-01-13 15:13:56.901827 ping(17287) [DEBUG] [daemon-kit]: Subscribing to ping for workitems
-2011-01-13 15:13:56.902027 ping(17287) [DEBUG] [daemon-kit]: Subscribing to pong for workitems
-2011-01-13 15:14:01.196252 ping(17287) [DEBUG] [daemon-kit]: Received workitem: "{\"fields\":{\"params\":{\"command\":\"/ping_pong/ping\",\"reply_queue\":\"ruote_workitems\",\"queue\":\"ping\",\"ref\":\"ping\",\"participant_options\":{\"queue\":\"ping\",\"forget\":false,\"reply_queue\":\"ruote_workitems\"},\"forget\":false},\"dispatched_at\":\"2011-01-13 14:14:01.118144 UTC\"},\"fei\":{\"engine_id\":\"engine\",\"wfid\":\"20110113-bujubaho\",\"subid\":\"67a0aa6eca7f50e9c67fcb2ee5f85162\",\"expid\":\"0_0\"},\"participant_name\":\"ping\"}"
-2011-01-13 15:14:01.200823 ping(17287) [DEBUG] [daemon-kit]: Replying to engine via AMQP with #<DaemonKit::RuoteWorkitem:0x0000000230c260 @workitem={"fields"=>{"params"=>{"command"=>"/ping_pong/ping", "reply_queue"=>"ruote_workitems", "queue"=>"ping", "ref"=>"ping", "participant_options"=>{"queue"=>"ping", "forget"=>false, "reply_queue"=>"ruote_workitems"}, "forget"=>false}, "dispatched_at"=>"2011-01-13 14:14:01.118144 UTC", "msg"=>"ping", "success"=>true}, "fei"=>{"engine_id"=>"engine", "wfid"=>"20110113-bujubaho", "subid"=>"67a0aa6eca7f50e9c67fcb2ee5f85162", "expid"=>"0_0"}, "participant_name"=>"ping"}>
-2011-01-13 15:14:01.219361 ping(17287) [DEBUG] [daemon-kit]: Processed workitem.
-2011-01-13 15:24:00.374006 ping(17287) [DEBUG] [daemon-kit]: Received workitem: "{\"fields\":{\"params\":{\"command\":\"/ping_pong/ping\",\"reply_queue\":\"ruote_workitems\",\"queue\":\"ping\",\"ref\":\"ping\",\"participant_options\":{\"queue\":\"ping\",\"forget\":false,\"reply_queue\":\"ruote_workitems\"},\"forget\":false},\"dispatched_at\":\"2011-01-13 14:24:00.355516 UTC\"},\"fei\":{\"engine_id\":\"engine\",\"wfid\":\"20110113-bekaduwa\",\"subid\":\"46ff2956199eab172388dbd55abdc1a3\",\"expid\":\"0_0\"},\"participant_name\":\"ping\"}"
-2011-01-13 15:24:00.374746 ping(17287) [DEBUG] [daemon-kit]: Replying to engine via AMQP with #<DaemonKit::RuoteWorkitem:0x000000033da830 @workitem={"fields"=>{"params"=>{"command"=>"/ping_pong/ping", "reply_queue"=>"ruote_workitems", "queue"=>"ping", "ref"=>"ping", "participant_options"=>{"queue"=>"ping", "forget"=>false, "reply_queue"=>"ruote_workitems"}, "forget"=>false}, "dispatched_at"=>"2011-01-13 14:24:00.355516 UTC", "msg"=>"ping", "success"=>true}, "fei"=>{"engine_id"=>"engine", "wfid"=>"20110113-bekaduwa", "subid"=>"46ff2956199eab172388dbd55abdc1a3", "expid"=>"0_0"}, "participant_name"=>"ping"}>
-2011-01-13 15:24:00.375445 ping(17287) [DEBUG] [daemon-kit]: Processed workitem.
-2011-01-13 15:25:14.357027 ping(17287) [DEBUG] [daemon-kit]: Received workitem: "{\"fields\":{\"params\":{\"command\":\"/ping_pong/ping\",\"reply_queue\":\"ruote_workitems\",\"queue\":\"ping\",\"ref\":\"ping\",\"participant_options\":{\"queue\":\"ping\",\"forget\":false,\"reply_queue\":\"ruote_workitems\"},\"forget\":false},\"dispatched_at\":\"2011-01-13 14:25:14.306386 UTC\"},\"fei\":{\"engine_id\":\"engine\",\"wfid\":\"20110113-tsutazomi\",\"subid\":\"962878c670f1eaa49a346b3a22c23105\",\"expid\":\"0_0\"},\"participant_name\":\"ping\"}"
-2011-01-13 15:25:14.357707 ping(17287) [DEBUG] [daemon-kit]: Replying to engine via AMQP with #<DaemonKit::RuoteWorkitem:0x000000033b4630 @workitem={"fields"=>{"params"=>{"command"=>"/ping_pong/ping", "reply_queue"=>"ruote_workitems", "queue"=>"ping", "ref"=>"ping", "participant_options"=>{"queue"=>"ping", "forget"=>false, "reply_queue"=>"ruote_workitems"}, "forget"=>false}, "dispatched_at"=>"2011-01-13 14:25:14.306386 UTC", "msg"=>"ping", "success"=>true}, "fei"=>{"engine_id"=>"engine", "wfid"=>"20110113-tsutazomi", "subid"=>"962878c670f1eaa49a346b3a22c23105", "expid"=>"0_0"}, "participant_name"=>"ping"}>
-2011-01-13 15:25:14.358363 ping(17287) [DEBUG] [daemon-kit]: Processed workitem.
-2011-01-13 15:29:20.456690 ping(17287) [DEBUG] [daemon-kit]: Received workitem: "{\"fields\":{\"params\":{\"command\":\"/ping_pong/ping\",\"reply_queue\":\"ruote_workitems\",\"queue\":\"ping\",\"ref\":\"ping\",\"participant_options\":{\"queue\":\"ping\",\"forget\":false,\"reply_queue\":\"ruote_workitems\"},\"forget\":false},\"dispatched_at\":\"2011-01-13 14:29:20.368001 UTC\"},\"fei\":{\"engine_id\":\"engine\",\"wfid\":\"20110113-behadazadu\",\"subid\":\"d236727135ca013195a2505ada2e96c9\",\"expid\":\"0_0\"},\"participant_name\":\"ping\"}"
-2011-01-13 15:29:20.457399 ping(17287) [DEBUG] [daemon-kit]: Replying to engine via AMQP with #<DaemonKit::RuoteWorkitem:0x0000000338d490 @workitem={"fields"=>{"params"=>{"command"=>"/ping_pong/ping", "reply_queue"=>"ruote_workitems", "queue"=>"ping", "ref"=>"ping", "participant_options"=>{"queue"=>"ping", "forget"=>false, "reply_queue"=>"ruote_workitems"}, "forget"=>false}, "dispatched_at"=>"2011-01-13 14:29:20.368001 UTC", "msg"=>"ping", "success"=>true}, "fei"=>{"engine_id"=>"engine", "wfid"=>"20110113-behadazadu", "subid"=>"d236727135ca013195a2505ada2e96c9", "expid"=>"0_0"}, "participant_name"=>"ping"}>
-2011-01-13 15:29:20.458113 ping(17287) [DEBUG] [daemon-kit]: Processed workitem.
-2011-01-13 15:31:41.553039 ping(17287) [DEBUG] [daemon-kit]: Received workitem: "{\"fields\":{\"params\":{\"command\":\"/ping_pong/ping\",\"reply_queue\":\"ruote_workitems\",\"queue\":\"ping\",\"ref\":\"ping\",\"participant_options\":{\"queue\":\"ping\",\"forget\":false,\"reply_queue\":\"ruote_workitems\"},\"forget\":false},\"dispatched_at\":\"2011-01-13 14:31:41.459609 UTC\"},\"fei\":{\"engine_id\":\"engine\",\"wfid\":\"20110113-bimomekare\",\"subid\":\"2d8818d47b7858d33d225836b46fc217\",\"expid\":\"0_0\"},\"participant_name\":\"ping\"}"
-2011-01-13 15:31:41.553705 ping(17287) [DEBUG] [daemon-kit]: Replying to engine via AMQP with #<DaemonKit::RuoteWorkitem:0x000000033792d8 @workitem={"fields"=>{"params"=>{"command"=>"/ping_pong/ping", "reply_queue"=>"ruote_workitems", "queue"=>"ping", "ref"=>"ping", "participant_options"=>{"queue"=>"ping", "forget"=>false, "reply_queue"=>"ruote_workitems"}, "forget"=>false}, "dispatched_at"=>"2011-01-13 14:31:41.459609 UTC", "msg"=>"ping", "success"=>true}, "fei"=>{"engine_id"=>"engine", "wfid"=>"20110113-bimomekare", "subid"=>"2d8818d47b7858d33d225836b46fc217", "expid"=>"0_0"}, "participant_name"=>"ping"}>
-2011-01-13 15:31:41.554367 ping(17287) [DEBUG] [daemon-kit]: Processed workitem.
-2011-01-13 15:33:50.886506 ping(17287) [DEBUG] [daemon-kit]: Received workitem: "{\"fields\":{\"params\":{\"command\":\"/ping_pong/ping\",\"reply_queue\":\"ruote_workitems\",\"queue\":\"ping\",\"ref\":\"ping\",\"participant_options\":{\"queue\":\"ping\",\"forget\":false,\"reply_queue\":\"ruote_workitems\"},\"forget\":false},\"dispatched_at\":\"2011-01-13 14:33:50.798499 UTC\"},\"fei\":{\"engine_id\":\"engine\",\"wfid\":\"20110113-bobobipotsu\",\"subid\":\"a99d792999fce0cbfc0a5bcac31210d4\",\"expid\":\"0_0\"},\"participant_name\":\"ping\"}"
-2011-01-13 15:33:50.887209 ping(17287) [DEBUG] [daemon-kit]: Replying to engine via AMQP with #<DaemonKit::RuoteWorkitem:0x0000000336a940 @workitem={"fields"=>{"params"=>{"command"=>"/ping_pong/ping", "reply_queue"=>"ruote_workitems", "queue"=>"ping", "ref"=>"ping", "participant_options"=>{"queue"=>"ping", "forget"=>false, "reply_queue"=>"ruote_workitems"}, "forget"=>false}, "dispatched_at"=>"2011-01-13 14:33:50.798499 UTC", "msg"=>"ping", "success"=>true}, "fei"=>{"engine_id"=>"engine", "wfid"=>"20110113-bobobipotsu", "subid"=>"a99d792999fce0cbfc0a5bcac31210d4", "expid"=>"0_0"}, "participant_name"=>"ping"}>
-2011-01-13 15:33:50.887951 ping(17287) [DEBUG] [daemon-kit]: Processed workitem.
-2011-01-13 15:39:56.732006 ping(17287) [DEBUG] [daemon-kit]: Received workitem: "{\"fields\":{\"params\":{\"command\":\"/ping_pong/ping\",\"reply_queue\":\"ruote_workitems\",\"queue\":\"ping\",\"ref\":\"ping\",\"participant_options\":{\"queue\":\"ping\",\"forget\":false,\"reply_queue\":\"ruote_workitems\"},\"forget\":false},\"dispatched_at\":\"2011-01-13 14:39:56.680587 UTC\"},\"fei\":{\"engine_id\":\"engine\",\"wfid\":\"20110113-bohisapiko\",\"subid\":\"bf9e2569800126eb6264999246da0960\",\"expid\":\"0_0\"},\"participant_name\":\"ping\"}"
-2011-01-13 15:39:56.732735 ping(17287) [DEBUG] [daemon-kit]: Replying to engine via AMQP with #<DaemonKit::RuoteWorkitem:0x0000000335a860 @workitem={"fields"=>{"params"=>{"command"=>"/ping_pong/ping", "reply_queue"=>"ruote_workitems", "queue"=>"ping", "ref"=>"ping", "participant_options"=>{"queue"=>"ping", "forget"=>false, "reply_queue"=>"ruote_workitems"}, "forget"=>false}, "dispatched_at"=>"2011-01-13 14:39:56.680587 UTC", "msg"=>"ping", "success"=>true}, "fei"=>{"engine_id"=>"engine", "wfid"=>"20110113-bohisapiko", "subid"=>"bf9e2569800126eb6264999246da0960", "expid"=>"0_0"}, "participant_name"=>"ping"}>
-2011-01-13 15:39:56.733479 ping(17287) [DEBUG] [daemon-kit]: Processed workitem.
-2011-01-13 15:40:48.291014 ping(17287) [DEBUG] [daemon-kit]: Received workitem: "{\"fields\":{\"params\":{\"command\":\"/ping_pong/ping\",\"reply_queue\":\"ruote_workitems\",\"queue\":\"ping\",\"ref\":\"ping\",\"participant_options\":{\"queue\":\"ping\",\"forget\":false,\"reply_queue\":\"ruote_workitems\"},\"forget\":false},\"dispatched_at\":\"2011-01-13 14:40:48.282082 UTC\"},\"fei\":{\"engine_id\":\"engine\",\"wfid\":\"20110113-bitzupazomo\",\"subid\":\"d9a42d830f321073f81775545c79284e\",\"expid\":\"0_0\"},\"participant_name\":\"ping\"}"
-2011-01-13 15:40:48.291661 ping(17287) [DEBUG] [daemon-kit]: Replying to engine via AMQP with #<DaemonKit::RuoteWorkitem:0x00000003339368 @workitem={"fields"=>{"params"=>{"command"=>"/ping_pong/ping", "reply_queue"=>"ruote_workitems", "queue"=>"ping", "ref"=>"ping", "participant_options"=>{"queue"=>"ping", "forget"=>false, "reply_queue"=>"ruote_workitems"}, "forget"=>false}, "dispatched_at"=>"2011-01-13 14:40:48.282082 UTC", "msg"=>"ping", "success"=>true}, "fei"=>{"engine_id"=>"engine", "wfid"=>"20110113-bitzupazomo", "subid"=>"d9a42d830f321073f81775545c79284e", "expid"=>"0_0"}, "participant_name"=>"ping"}>
-2011-01-13 15:40:48.292343 ping(17287) [DEBUG] [daemon-kit]: Processed workitem.
-2011-01-13 15:43:05.446419 ping(17287) [DEBUG] [daemon-kit]: Received workitem: "{\"fields\":{\"params\":{\"command\":\"/ping_pong/ping\",\"reply_queue\":\"ruote_workitems\",\"queue\":\"ping\",\"ref\":\"ping\",\"participant_options\":{\"queue\":\"ping\",\"forget\":false,\"reply_queue\":\"ruote_workitems\"},\"forget\":false},\"dispatched_at\":\"2011-01-13 14:43:05.363289 UTC\"},\"fei\":{\"engine_id\":\"engine\",\"wfid\":\"20110113-biwamomuza\",\"subid\":\"1101ee4ae1ee77533d1b2942038324e2\",\"expid\":\"0_0\"},\"participant_name\":\"ping\"}"
-2011-01-13 15:43:05.447109 ping(17287) [DEBUG] [daemon-kit]: Replying to engine via AMQP with #<DaemonKit::RuoteWorkitem:0x00000003304c08 @workitem={"fields"=>{"params"=>{"command"=>"/ping_pong/ping", "reply_queue"=>"ruote_workitems", "queue"=>"ping", "ref"=>"ping", "participant_options"=>{"queue"=>"ping", "forget"=>false, "reply_queue"=>"ruote_workitems"}, "forget"=>false}, "dispatched_at"=>"2011-01-13 14:43:05.363289 UTC", "msg"=>"ping", "success"=>true}, "fei"=>{"engine_id"=>"engine", "wfid"=>"20110113-biwamomuza", "subid"=>"1101ee4ae1ee77533d1b2942038324e2", "expid"=>"0_0"}, "participant_name"=>"ping"}>
-2011-01-13 15:43:05.447832 ping(17287) [DEBUG] [daemon-kit]: Processed workitem.
-2011-01-13 15:47:31.520944 ping(17287) [INFO] [daemon-kit]: Running signal traps for INT
-2011-01-13 15:47:31.521568 ping(17287) [INFO] [daemon-kit]: Running shutdown hooks
-2011-01-13 15:47:31.521743 ping(17287) [WARN] [daemon-kit]: Shutting down ping

0 comments on commit 4fa66bc

Please sign in to comment.
Something went wrong with that request. Please try again.