Hello,<div><br></div><div>we are playing with the udp exchange and found some problem.</div><div><br></div><div>On the receiving side, both with pika and ruby amqp we were</div><div>having problems, for instance, with ruby:</div>
<div><br></div><div><div>/Library/Ruby/Gems/1.8/gems/amq-protocol-0.9.0/lib/amq/protocol/table.rb:88:in `decode': NotImplementedError (NotImplementedError)</div><div><span class="Apple-tab-span" style="white-space:pre"> </span>from /Library/Ruby/Gems/1.8/gems/amq-protocol-0.9.0/lib/amq/protocol/client.rb:1482:in `decode_properties'</div>
<div><span class="Apple-tab-span" style="white-space:pre"> </span>from /Library/Ruby/Gems/1.8/gems/amq-protocol-0.9.0/lib/amq/protocol/client.rb:1465:in `each'</div><div><span class="Apple-tab-span" style="white-space:pre"> </span>from /Library/Ruby/Gems/1.8/gems/amq-protocol-0.9.0/lib/amq/protocol/client.rb:1465:in `decode_properties'</div>
<div><span class="Apple-tab-span" style="white-space:pre"> </span>from /Library/Ruby/Gems/1.8/gems/amq-protocol-0.9.0/lib/amq/protocol/frame.rb:142:in `decode_payload'</div><div><span class="Apple-tab-span" style="white-space:pre"> </span>from /Library/Ruby/Gems/1.8/gems/amq-protocol-0.9.0/lib/amq/protocol/frame.rb:115:in `body_size'</div>
<div><span class="Apple-tab-span" style="white-space:pre"> </span>from /Library/Ruby/Gems/1.8/gems/amq-client-0.9.2/lib/amq/client/async/adapter.rb:675:in `content_complete?'</div><div><span class="Apple-tab-span" style="white-space:pre"> </span>from /Library/Ruby/Gems/1.8/gems/amq-client-0.9.2/lib/amq/client/async/adapter.rb:667:in `frameset_complete?'</div>
<div><span class="Apple-tab-span" style="white-space:pre"> </span>from /Library/Ruby/Gems/1.8/gems/amq-client-0.9.2/lib/amq/client/async/adapter.rb:518:in `receive_frame'</div><div><span class="Apple-tab-span" style="white-space:pre"> </span>from /Library/Ruby/Gems/1.8/gems/amq-client-0.9.2/lib/amq/client/async/adapters/event_machine.rb:327:in `receive_data'</div>
<div><span class="Apple-tab-span" style="white-space:pre"> </span>from /Library/Ruby/Gems/1.8/gems/eventmachine-0.12.10/lib/eventmachine.rb:256:in `run_machine'</div><div><span class="Apple-tab-span" style="white-space:pre"> </span>from /Library/Ruby/Gems/1.8/gems/eventmachine-0.12.10/lib/eventmachine.rb:256:in `run'</div>
</div><div><br></div><div>with pika it gives a similar error on pika/data.py:128</div><div><br></div><div>The error obviously comes from the headers set by the udp plugin:</div><div><div>Headers = [{<<"source_ip">>, longstr, IpStr},</div>
<div> {<<"source_port">>, short, Port}],</div></div><div><br></div><div>Changing it to signedint fixed the problem:</div><div><span style>Headers = [{<<"source_ip">>, longstr, IpStr},</span><br style>
<span style> {<<"source_port">>, signedint, Port}],</span></div><div><span style><br></span></div><div><font color="#222222" face="arial, sans-serif">In the ruby client the type short int is explicitly rejected (</font>amq/protocol/table.rb:88<span style="color:rgb(34,34,34);font-family:arial,sans-serif">)</span></div>
<div><font color="#222222" face="arial, sans-serif"><br></font></div><div><font color="#222222" face="arial, sans-serif">Is this a problem in pika and amqp ruby clients or in the java one?</font></div><div><font color="#222222" face="arial, sans-serif"><br>
</font></div><div>Cheers,</div><div>---<br>Massimo Paladin<br><br>email: <a href="mailto:massimo.paladin@gmail.com" target="_blank">massimo.paladin@gmail.com</a><br>website: <a href="http://www.mpaladin.com/" target="_blank">http://www.mpaladin.com</a><br>
flickr's page: <a href="http://flickr.com/photos/massimop" target="_blank">http://flickr.com/photos/massimop</a><br>
</div>