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 |