[rabbitmq-discuss] udp exchange and headers type

Massimo Paladin Massimo.Paladin at cern.ch
Fri Mar 23 13:30:17 GMT 2012


Hello,

we are playing with the udp exchange and found some problem.

On the receiving side, both with pika and ruby amqp we were
having problems, for instance, with ruby:

/Library/Ruby/Gems/1.8/gems/amq-protocol-0.9.0/lib/amq/protocol/table.rb:88:in
`decode': NotImplementedError (NotImplementedError)
from
/Library/Ruby/Gems/1.8/gems/amq-protocol-0.9.0/lib/amq/protocol/client.rb:1482:in
`decode_properties'
 from
/Library/Ruby/Gems/1.8/gems/amq-protocol-0.9.0/lib/amq/protocol/client.rb:1465:in
`each'
from
/Library/Ruby/Gems/1.8/gems/amq-protocol-0.9.0/lib/amq/protocol/client.rb:1465:in
`decode_properties'
 from
/Library/Ruby/Gems/1.8/gems/amq-protocol-0.9.0/lib/amq/protocol/frame.rb:142:in
`decode_payload'
from
/Library/Ruby/Gems/1.8/gems/amq-protocol-0.9.0/lib/amq/protocol/frame.rb:115:in
`body_size'
 from
/Library/Ruby/Gems/1.8/gems/amq-client-0.9.2/lib/amq/client/async/adapter.rb:675:in
`content_complete?'
from
/Library/Ruby/Gems/1.8/gems/amq-client-0.9.2/lib/amq/client/async/adapter.rb:667:in
`frameset_complete?'
 from
/Library/Ruby/Gems/1.8/gems/amq-client-0.9.2/lib/amq/client/async/adapter.rb:518:in
`receive_frame'
from
/Library/Ruby/Gems/1.8/gems/amq-client-0.9.2/lib/amq/client/async/adapters/event_machine.rb:327:in
`receive_data'
 from
/Library/Ruby/Gems/1.8/gems/eventmachine-0.12.10/lib/eventmachine.rb:256:in
`run_machine'
from
/Library/Ruby/Gems/1.8/gems/eventmachine-0.12.10/lib/eventmachine.rb:256:in
`run'

with pika it gives a similar error on pika/data.py:128

The error obviously comes from the headers set by the udp plugin:
Headers = [{<<"source_ip">>, longstr, IpStr},
              {<<"source_port">>, short, Port}],

Changing it to signedint fixed the problem:
Headers = [{<<"source_ip">>, longstr, IpStr},
              {<<"source_port">>, signedint, Port}],

In the ruby client the type short int is explicitly rejected (
amq/protocol/table.rb:88)

Is this a problem in pika and amqp ruby clients or in the java one?

Cheers,
---
Massimo Paladin

email: massimo.paladin at gmail.com
website: http://www.mpaladin.com
flickr's page: http://flickr.com/photos/massimop
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20120323/8b699954/attachment.htm>


More information about the rabbitmq-discuss mailing list