[openamq-dev] Fwd: Ruby QPID libraries
Carl Bourne
cbourne at intellect.co.uk
Wed Apr 30 01:12:21 CEST 2008
Thanks Rob,
That worked a treat!
One other question:
Do you have to create a new content object that contains the message contents before you can publish it? The following works fairly well up to about 1000 messages but then seriously slows down when you start to go above that. Is it not possible to create the content (at least the text part of it) as the message is published?
10000.times {|i|
content = Qpid::Content.new({}, "Test Message# #{i}")
ch.basic_publish(:routing_key => "test-queue", :content => content )}
Regards,
Carl
On 29/04/2008 23:07, "Robert Godfrey" <rob.j.godfrey at gmail.com> wrote:
Hi Carl,
which amqp 0-8 xml spec file did you use?
Don't use the one in Qpid ... that spec file is actually somewhere
between 0-8 and 0-9 for historical reasons (sorry!)... If you find the
spec file in Rabbit's distribution or just download from the AMQP
website then the consumer *should* work...
-- Rob
2008/4/29 Carl Bourne <cbourne at intellect.co.uk>:
>
> Hi Gordon,
>
> I tried your example against OpenAMQ and RabbitMQ.
>
> It worked fine with OpenAMQ but though this error with RabbitMQ:-
>
> ruby simple_test.rb ../specs/amqp.0-8.xml
> CONNECTION CLOSED: 501, FRAME_ERROR, 60, 20
> writer Qpid::Closed
> ./qpid/queue.rb:41:in `pop': Qpid::Closed (Qpid::Closed)
> from ./qpid/peer.rb:208:in `invoke'
> from ./qpid/peer.rb:190:in `method_missing'
> from qpidruby.rb:13
>
> However, the publish part of the script worked OK - a message was produced
> and sent to the RabbitMQ broker. The error seems to relate to the consumer
> part failing.
>
> Would you know what might be causing this?
>
> Regards,
>
> Carl
>
>
> On 29/04/2008 17:25, "Gordon Sim" <gsim at redhat.com> wrote:
>
>
>
> Hello OpenAMQers!
>
> In response to Carl's query I tested the attached example using the
> latest Qpid ruby client (M2.1 will also work) and OpenAMQ/1.2c4. Its
> very basic but shows a simple send & receive working[*]. (My response
> got bounced first time round).
>
> We (Qpid project) are very keen to do whatever we can to ensure we
> interoperate with any other implementations so please don't hesitate to
> shout if you come across any issues.
>
> --Gordon.
>
> [1] You can pass in any 0-9 spec file as an argument, but the following
> has the WIP removed which prevents an odd warning from the qpid ruby
> client:
>
>
> http://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1-release/specs/amqp.0-9.no-wip.xml
>
>
> _______________________________________________
> openamq-dev mailing list
> openamq-dev at lists.openamq.org
> http://lists.openamq.org/mailman/listinfo/openamq-dev
>
>
_______________________________________________
openamq-dev mailing list
openamq-dev at lists.openamq.org
http://lists.openamq.org/mailman/listinfo/openamq-dev
-------------- next part --------------
An HTML attachment was scrubbed...
URL: http://lists.openamq.org/pipermail/openamq-dev/attachments/20080430/3992e883/attachment-0001.htm
More information about the openamq-dev
mailing list