RabbitMQ UDP Exchange Plugin - 3.5.1-20150421

93 views
Skip to first unread message

Dwight Corley

unread,
Sep 5, 2018, 12:18:59 PM9/5/18
to rabbitmq-users
I would like to ask the core team for help with getting an old plugin working with the up to date RabbitMQ build.  Tony Garnock-Jones published a plugin for UDP exchange, https://github.com/tonyg/udp-exchange .

I am hoping this could simply be a rebuild of the plugin against the current RabbitMQ codebase? I am currently trying to use this plugin with  v3.7.7 / Erlang OTP 19.  I am getting errors when I try to declare the exchnage;

2018-09-05 09:41:36.464 [error] <0.23241.0> Error on AMQP connection <0.23241.0> (172.16.0.37:18001 -> 172.16.0.36:5672, vhost: '/', user:

'admin', state: running), channel 1:

  {function_clause,

     [{udp_exchange_sup,endpoint_params,

          [{exchange,

               {resource,<<"/">>,exchange,<<"X-UDP">>},

               'x-udp',false,false,false,

 

[{<<"port">>,short,10000},{<<"ip">>,longstr,<<"172.16.0.36">>}],

               undefined,undefined,undefined,

               {[],[]},

               #{user => <<"admin">>}}],

          []},

      {udp_exchange,validate,1,[]},

 

{rabbit_exchange,declare,7,[{file,"src/rabbit_exchange.erl"},{line,170}]},

      {rabbit_channel,handle_method,5,

          [{file,"src/rabbit_channel.erl"},{line,2285}]},

      {rabbit_channel,handle_method,3,

          [{file,"src/rabbit_channel.erl"},{line,1371}]},

      {rabbit_channel,handle_cast,2,

          [{file,"src/rabbit_channel.erl"},{line,527}]},

      {gen_server2,handle_msg,2,[{file,"src/gen_server2.erl"},{line,1050}]},

      {proc_lib,wake_up,3,[{file,"proc_lib.erl"},{line,257}]}]}

 

 

I suspect that the format of RabbitMQ's `exchange` record has changed since the plugin was compiled. Any help?



Karl Nilsson

unread,
Sep 5, 2018, 12:39:50 PM9/5/18
to rabbitm...@googlegroups.com
Hi,

I suspect you are right and that the exchange record has grown some additional fields since this was compiled. To rebuild you most likely you will need to update the plugin to the current build system (using a fork of erlang.mk).The best way to proceed would probably be to try to adapt the udp exchange plugin from sample RabbitMQ plugin: https://github.com/rabbitmq/rabbitmq-metronome

Cheers
Karl

--
You received this message because you are subscribed to the Google Groups "rabbitmq-users" group.
To unsubscribe from this group and stop receiving emails from it, send an email to rabbitmq-user...@googlegroups.com.
To post to this group, send email to rabbitm...@googlegroups.com.
For more options, visit https://groups.google.com/d/optout.
Reply all
Reply to author
Forward
0 new messages