ruote tmp/log_2011-01-13.html

2011-01-13 08:35:19 utc tosch_le jmettraux: unknown protocol handler "/usr/local/rvm/log/ruby-1.9.1-p378/rubygems.update.lo" ;-)
2011-01-13 08:35:29 utc tosch_le good morning anyway!
2011-01-13 08:35:54 utc jmettraux tosch_le: hello, thanks
2011-01-13 08:38:22 utc jmettraux tosch_le: sorry... I don't understand this protocol handler thing
2011-01-13 08:39:20 utc tosch_le the link in your last post to the ml had this protocoll handler. sorry, was to obscure.
2011-01-13 08:41:40 utc jmettraux aaah, fixed !
2011-01-13 08:50:37 utc tosch_le jmettraux: https://github.com/jmettraux/ruote/commit/801afe5c932c7b1e176f9e2a62d0546c79e09d14 shouldn't be necessary anymore
2011-01-13 08:51:33 utc jmettraux understood... I'd like to keep it anyway, for the next Kernel.set override
2011-01-13 08:51:53 utc tosch_le ok
2011-01-13 08:53:04 utc jmettraux thanks a lot !
2011-01-13 10:35:10 utc gonzalo hi john: thanks for the Engine#launch_single fix :)
2011-01-13 10:38:15 utc jmettraux hello Gonzalo, you're welcome, thanks for spotting that
2011-01-13 10:38:31 utc gonzalo ok, no prob :P
2011-01-13 11:44:31 utc jmettraux hery: hello and welcome to #ruote
2011-01-13 11:44:59 utc hery Hello John
2011-01-13 11:45:36 utc hery I have a question using ruote with rails, do you have time for that?
2011-01-13 11:46:02 utc jmettraux yes, please
2011-01-13 11:46:45 utc hery I have a say ping pong example using rails
2011-01-13 11:47:00 utc hery a participant named ping and another named pong
2011-01-13 11:47:17 utc hery I use AMQP as broker
2011-01-13 11:47:34 utc hery participants ping and pong are RuoteAMQP::Participant
2011-01-13 11:47:53 utc hery I have another BlockParticipant called log_me
2011-01-13 11:48:29 utc hery Just launch a sequential process process : ping -> log_me -> pong -> log_me
2011-01-13 11:48:33 utc hery but it stalled at ping
2011-01-13 11:48:53 utc jmettraux right after ping ?
2011-01-13 11:48:58 utc hery yes
2011-01-13 11:49:23 utc hery I use RuoteKit
2011-01-13 11:49:50 utc jmettraux are you following this http://simplic.it/blog/an-investigiation-into-ruote-and-amqp ?
2011-01-13 11:50:16 utc hery No I will read that
2011-01-13 11:50:22 utc hery get back to you later :)
2011-01-13 11:50:23 utc jmettraux ah ok
2011-01-13 11:50:28 utc hery thanks
2011-01-13 11:50:34 utc jmettraux is there an error logged ?
2011-01-13 11:50:42 utc hery No error at all
2011-01-13 11:51:05 utc hery My daemon kit received the workitem
2011-01-13 11:51:18 utc jmettraux did it reply ?
2011-01-13 11:51:23 utc hery Yes it replies
2011-01-13 11:51:44 utc hery but I don't know why the ruote_worker do not continue the process
2011-01-13 11:52:03 utc jmettraux maybe your ping participant doesn't reply to the right channel
2011-01-13 11:52:32 utc hery option reply_queue ?
2011-01-13 11:52:47 utc jmettraux in fact, I should let you read the blog post
2011-01-13 11:52:57 utc jmettraux it is exactly your use case 1:1
2011-01-13 11:53:22 utc hery Ok
2011-01-13 11:53:36 utc hery I will read and test
2011-01-13 11:53:53 utc jmettraux good luck
2011-01-13 11:54:32 utc hery thanks
2011-01-13 11:59:42 utc hery Ok thanks
2011-01-13 11:59:48 utc hery I had it resolved :)
2011-01-13 12:00:00 utc hery reply_queue must be set in process_definition
2011-01-13 12:00:08 utc jmettraux ah, ouch
2011-01-13 12:00:15 utc hery not in registration
2011-01-13 12:00:26 utc jmettraux can't it be set when registering the participant ? weird
2011-01-13 12:00:32 utc hery no
2011-01-13 12:01:12 utc hery I thought it could but no
2011-01-13 12:01:45 utc jmettraux and I thought I had changed that
2011-01-13 12:02:23 utc hery Thank for your help, I go to launch
2011-01-13 12:02:28 utc hery (french time)
2011-01-13 12:02:36 utc jmettraux launch time !
2011-01-13 12:02:44 utc jmettraux ;-)
2011-01-13 12:42:13 utc gonzalo one design question. i would like to notify via xmpp every time the engine gives a workitem to a certain participant. i thought that a good way to implement this could be with a listen expression. a process listens to that participant on event apply and when that happens, the listen receives a copy of the workitem and notifies
2011-01-13 12:42:19 utc gonzalo what do you think?
2011-01-13 12:42:36 utc jmettraux sounds reasonable
2011-01-13 12:43:17 utc gonzalo ok, i used to pass to that participant a username as paramerter but i need that info in the listen expression too.
2011-01-13 12:43:40 utc gonzalo i guess i will have to move the username from params (participant) to the fields payload
2011-01-13 12:44:01 utc gonzalo cause params are only visible for the participant
2011-01-13 12:44:06 utc gonzalo right?
2011-01-13 12:44:14 utc jmettraux it should be present in 'fields' => { 'params' => { 'username' => 'x' } }
2011-01-13 12:44:26 utc jmettraux well, not sure now
2011-01-13 12:44:32 utc jmettraux you are right
2011-01-13 12:44:48 utc gonzalo ok cool, just wanted to check this with you
2011-01-13 12:45:05 utc gonzalo i'll move that username to the payload with a :set expression
2011-01-13 12:45:33 utc jmettraux ok
2011-01-13 12:46:08 utc gonzalo ok john, thanks for your comments :P
2011-01-13 12:46:49 utc jmettraux you're welcome
2011-01-13 14:17:52 utc hery Hi it's me again
2011-01-13 14:18:29 utc jmettraux hello
2011-01-13 14:19:03 utc hery I have an error on a block participant, I think
2011-01-13 14:19:17 utc hery undefined method consume for NilClass
2011-01-13 14:19:17 utc jmettraux what does it say ?
2011-01-13 14:19:47 utc jmettraux how do your register the participant ?
2011-01-13 14:19:58 utc jmettraux could you gist that ?
2011-01-13 14:20:06 utc hery Ok
2011-01-13 14:21:04 utc hery https://gist.github.com/777917
2011-01-13 14:23:28 utc jmettraux sorry, this engine#register(&block) method doesn't support blocks
2011-01-13 14:23:46 utc jmettraux I can fix it now if you have 10 minutes
2011-01-13 14:25:14 utc hery Same error if I moved this upper
2011-01-13 14:25:28 utc hery out of the block with engine.register_participant
2011-01-13 14:26:28 utc jmettraux http://ruote.rubyforge.org/part/block_participant.html
2011-01-13 14:27:01 utc jmettraux there is http://groups.google.com/group/openwferu-users/browse_thread/thread/5cb41f958d91308b too
2011-01-13 14:38:21 utc jmettraux hery: pushed https://github.com/jmettraux/ruote/commit/3454e06181d1413e208b452b152ece654533ad9e many thanks !
2011-01-13 14:40:20 utc hery you're welcome :) (What have I done ? :D)
2011-01-13 14:40:36 utc jmettraux reporting an issue :-)
2011-01-13 14:44:23 utc hery Hmmm ok
2011-01-13 14:44:47 utc hery I understand te do_not_thread attribute
2011-01-13 14:45:24 utc hery but my issue is that in dispatch_pool there participant is nl
2011-01-13 14:45:26 utc hery nil
2011-01-13 14:45:41 utc jmettraux what's the error message ?
2011-01-13 14:46:07 utc hery /home/ruby/.rvm/gems/ruby-1.9.2-p136@ping-pong/gems/activesupport-3.0.3/lib/active_support/whiny_nil.rb:48:in `method_missing'
2011-01-13 14:46:07 utc hery /home/ruby/.rvm/gems/ruby-1.9.2-p136@ping-pong/bundler/gems/ruote-4331b13c4536/lib/ruote/svc/dispatch_pool.rb:93:in `do_dispatch'
2011-01-13 14:46:07 utc hery /home/ruby/.rvm/gems/ruby-1.9.2-p136@ping-pong/bundler/gems/ruote-4331b13c4536/lib/ruote/svc/dispatch_pool.rb:109:in `block in do_threaded_dispatch'
2011-01-13 14:46:34 utc jmettraux could you please gist the complete error message ?
2011-01-13 14:47:00 utc jmettraux and which participant has the do_not_thread on ?
2011-01-13 14:47:01 utc hery hmm this error was handled by ruote
2011-01-13 14:53:02 utc hery Excuse me to ask you that but I can't have the full backtrace
2011-01-13 14:53:26 utc jmettraux weird
2011-01-13 14:53:33 utc hery Here is my rails application
2011-01-13 14:53:33 utc hery https://github.com/hallelujah/rails-sample-ruote-amqp
2011-01-13 14:53:48 utc jmettraux what's eating the backtrace ?
2011-01-13 14:54:13 utc hery There is no error unless in ruote-kit management
2011-01-13 14:54:26 utc hery and only 3 lines as I pasted above
2011-01-13 14:54:34 utc jmettraux it's fine
2011-01-13 14:54:48 utc jmettraux don't look further it's enough now
2011-01-13 14:56:49 utc jmettraux hery: on top of this 3 line trace, what's the error message ?
2011-01-13 14:57:52 utc hery undefined method consume for nil NilClass
2011-01-13 14:58:05 utc jmettraux thanks
2011-01-13 14:58:06 utc hery It is that participant is nil
2011-01-13 14:58:11 utc hery in DispatchPool
2011-01-13 14:59:00 utc jmettraux does it work if you don't set the do_not_thread ?
2011-01-13 15:02:27 utc jmettraux hery : could you please gist the content of the file ruote_work_development/configurations/st/participant_list.json ?
2011-01-13 15:05:34 utc hery https://gist.github.com/777988
2011-01-13 15:06:47 utc jmettraux does it work if you don't set the do_not_thread ?
2011-01-13 15:06:54 utc hery Neither
2011-01-13 15:08:15 utc jmettraux wait
2011-01-13 15:08:45 utc jmettraux you can't use a block participant if your worker is separate from your "engine"
2011-01-13 15:09:25 utc jmettraux please wrap your "log_me" in a custom participant, then restart your rails app and your worker before trying again
2011-01-13 15:09:32 utc hery Ok
2011-01-13 15:09:57 utc jmettraux there is a bit of context in http://groups.google.com/group/openwferu-users/browse_thread/thread/5cb41f958d91308b
2011-01-13 15:10:09 utc jmettraux a block participant is currently a "stateful" participant
2011-01-13 15:10:17 utc jmettraux it can't be shared between workers
2011-01-13 15:13:34 utc hery yeah since it can not be serialized (binding etc ... )
2011-01-13 15:13:46 utc jmettraux exactly
2011-01-13 15:16:17 utc hery In order to implement my own participant I have to include LocalParticipant right?
2011-01-13 15:16:56 utc jmettraux exacty
2011-01-13 15:16:59 utc jmettraux ly
2011-01-13 15:17:08 utc hery Ok :)
2011-01-13 15:17:11 utc hery very welll
2011-01-13 15:17:36 utc hery Thanks for your help
2011-01-13 15:17:51 utc hery Now I must to dig into ruote :)
2011-01-13 15:17:54 utc jmettraux your're welcome
2011-01-13 15:46:06 utc jmettraux I have to leave now, have a good evening
2011-01-13 15:46:22 utc jmettraux if nobody answers here, feel free to ask on the mailing list
2011-01-13 15:46:23 utc jmettraux ciao