Here's what I see for queues:
➜ ~ rabbitmqctl list_queues
Listing queues ...
work1 0
...done.
A bit weird. No pong, no ping, no ruote_workitems. But, perhaps I'm expecting
something that isn't supposed to be.
ping work does get to the Ping worker:
[daemon-kit]: DaemonKit (0.1.8.1) booting in development mode
[daemon-kit]: Setting up trap for USR1
[daemon-kit]: Setting up trap for USR2
[daemon-kit]: Setting up trap for HUP
[daemon-kit]: Setting up trap for INT
[daemon-kit]: Setting up trap for TERM
[daemon-kit]: DaemonKit (0.1.8.1) booted, now running ping
[daemon-kit]: AMQP.start({:vhost=>"ruote", :pass=>"ruote", :user=>"ruote",
:host=>"localhost"})
[daemon-kit]: Subscribing to ping for workitems
[daemon-kit]: Received workitem:
"{\"participant_name\":\"ping\",\"fields\":{\"count\":0,\"dispatched_at\":\"2011-05-27
14:45:31.516024
UTC\",\"__result__\":0,\"params\":{\"participant_options\":{\"forget\":false,\"queue\":\"ping\"},\"command\":\"/ping/ping\",\"reply_queue\":\"ruote_workitems\",\"ref\":\"ping\"},\"state\":\"alpha\"},\"fei\":{\"wfid\":\"20110527-bezarabuda\",\"engine_id\":\"engine\",\"expid\":\"0_1_0\",\"subid\":\"1e4efeabf54867e9b85f3c3db9a52cc2\"}}"
Processing!!!
[daemon-kit]: Replying to engine via AMQP with
#<DaemonKit::RuoteWorkitem:0x1015869f0 @workitem={"participant_name"=>"ping",
"fields"=>{"count"=>1, "success"=>true, "__result__"=>0,
"dispatched_at"=>"2011-05-27 14:45:31.516024 UTC",
"params"=>{"participant_options"=>{"forget"=>false, "queue"=>"ping"},
"command"=>"/ping/ping", "ref"=>"ping", "reply_queue"=>"ruote_workitems"},
"state"=>"ping"}, "fei"=>{"wfid"=>"20110527-bezarabuda", "engine_id"=>"engine",
"expid"=>"0_1_0", "subid"=>"1e4efeabf54867e9b85f3c3db9a52cc2"}}>
[daemon-kit]: Processed workitem.
But, that's where it stops. So, I guess I can second John's findings.
Kit
--
Kit Plummer :: MaestroDev :: 520.360.4729
On Friday, May 27, 2011 at 6:14 AM, John Mettraux wrote:
>
> On Fri, May 27, 2011 at 12:45:46PM +0000, Hartog C. de Mik wrote:
> >
> > The first questions that pop in to my mind are:
> > - what do the logs of the ping and pong daemon say
> > - what does `rabbitmqctl list_queues` say? (Perhaps you're listening
> > on the wrong queue)
>
> Hello Hartog,
>
> https://gist.github.com/raw/995206/f70a815f777578e393b85b61dc3bdd332d3904b3/ping.log
> https://gist.github.com/raw/995210/ffa1054f3be6308735812b5a1696699e77dbfdf1/pong.log
>
> and
>
> ---8<---
> jmettraux@sanma ~/w/ruote-amqp-ping-pong/pong (master) 円 rabbitmqctl
> list_queues
> Listing queues ...
> ...done.
> --->8---
>
>
> Thanks,
>
> --
> John Mettraux - http://jmettraux.wordpress.com
>
> --
> you received this message because you are subscribed to the "ruote users"
> group.
> to post : send email to [email protected]
> (mailto:[email protected])
> to unsubscribe : send email to [email protected]
> (mailto:[email protected])
> more options : http://groups.google.com/group/openwferu-users?hl=en
--
you received this message because you are subscribed to the "ruote users" group.
to post : send email to [email protected]
to unsubscribe : send email to [email protected]
more options : http://groups.google.com/group/openwferu-users?hl=en
