Hi all
I'm trying to make some tests with RabbitMQ, ruote-amqp and a simple java amqp
consumer.
In java a consumer needs to know the exchange name, the routing key and the
queue name.
In ruote-kit config.ru I register an AMQP participant pointing to queue 'ruote'
> - - - - - - - - - - - - - - - - - - - - - - -
require 'ruote-amqp'
AMQP.settings[:host] = 'localhost'
AMQP.settings[:user] = 'guest'
AMQP.settings[:pass] = 'guest'
config.register do
participant :copper, RuoteAMQP::Participant, :default_queue => 'ruote'
catchall
end
> - - - - - - - - - - - - - - - - - - - - - - -
And with a process like
> - - - - - - - - - - - - - - - - - - - - - - -
<process-definition name="secuencia simple" revision="1_0">
<sequence>
<participant ref="copper" task="almacenamiento" queue="ruote" />
<participant ref="alice" task="aprobacion"/>
</sequence>
</process-definition>
> - - - - - - - - - - - - - - - - - - - - - - -
I expect to receive in my java consumer a workitem, but it doesn't receive
anything. Where can I define the routing key and the exchange name? Am I doing
something wrong or simply a missconcept (a RuoteAMQP::Participant produces
messages?)
Thanks
--
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
