Queue crash - no function clause matching 'Elixir.RabbitMQ.MessageDeduplicationPlugin.Queue about rabbitmq-message-deduplication HOT 4 CLOSED

Yes it's the same issue #22. I will try to crack it over the WE if I have some spare time.

from rabbitmq-message-deduplication.

Hello,

I believe this was fixed in 8313990. I did not make a release yet as Issue #22 is still ongoing and wanted to make sure everything was fixed.

You can try grab an experimental build with that fix the issue here.

from rabbitmq-message-deduplication.

Hi tenks, but now I am getting:
2018-11-16 13:54:40.371 [info] <0.676.0> accepting AMQP connection <0.676.0> (10.241.5.1:60604 -> 10.241.5.10:5672) 2018-11-16 13:54:40.389 [info] <0.676.0> Connection <0.676.0> (10.241.5.1:60604 -> 10.241.5.10:5672) has a client-provided name: rabbitConnectionFactory#34a018d4:0 2018-11-16 13:54:40.397 [info] <0.676.0> connection <0.676.0> (10.241.5.1:60604 -> 10.241.5.10:5672 - rabbitConnectionFactory#34a018d4:0): user 'rabbit' authenticated and granted access to vhost '/' 2018-11-16 13:54:40.518 [error] <0.706.0> ** Generic server <0.706.0> terminating ** Last message in was {init,new} ** When Server state == {q,{amqqueue,{resource,<<"/">>,queue,<<"AE_DWH_MSG_QUEUE">>},true,false,none,[],<0.706.0>,[],[],[],undefined,undefined,[],[],live,0,[],<<"/">>,#{user => <<"rabbit">>}},none,false,undefined,undefined,{state,{queue,[],[],0},{active,-576460689904411,1.0}},undefined,undefined,undefined,undefined,{state,fine,5000,undefined},{0,nil},undefined,undefined,undefined,{state,{dict,0,16,16,8,80,48,{[],[],[],[],[],[],[],[],[],[],[],[],[],[],[],[]},{{[],[],[],[],[],[],[],[],[],[],[],[],[],[],[],[]}}},delegate},undefined,undefined,undefined,undefined,'drop-head',0,0,running} ** Reason for termination == ** {function_clause,[{'Elixir.RabbitMQ.MessageDeduplicationPlugin.Queue',init,[{amqqueue,{resource,<<"/">>,queue,<<"AE_DWH_MSG_QUEUE">>},true,false,none,[],<0.706.0>,[],[],[],undefined,undefined,[],[],live,0,[],<<"/">>,#{user => <<"rabbit">>}},new,#Fun<rabbit_amqqueue_process.11.129944743>],[{file,"lib/rabbit_message_deduplication_queue.ex"},{line,125}]},{rabbit_priority_queue,init,3,[{file,"src/rabbit_priority_queue.erl"},{line,151}]},{rabbit_amqqueue_process,init_it2,3,[{file,"src/rabbit_amqqueue_process.erl"},{line,207}]},{rabbit_amqqueue_process,handle_call,3,[{file,"src/rabbit_amqqueue_process.erl"},{line,1153}]},{gen_server2,handle_msg,2,[{file,"src/gen_server2.erl"},{line,1029}]},{proc_lib,init_p_do_apply,3,[{file,"proc_lib.erl"},{line,247}]}]} 2018-11-16 13:54:40.518 [error] <0.709.0> Restarting crashed queue 'AE_DWH_MSG_QUEUE' in vhost '/'. 2018-11-16 13:54:40.518 [error] <0.706.0> CRASH REPORT Process <0.706.0> with 0 neighbours exited with reason: no function clause matching 'Elixir.RabbitMQ.MessageDeduplicationPlugin.Queue':init({amqqueue,{resource,<<"/">>,queue,<<"AE_DWH_MSG_QUEUE">>},true,false,none,[],<0.706.0>,[],[],[],...}, new, #Fun<rabbit_amqqueue_process.11.129944743>) line 125 in gen_server2:terminate/3 line 1166 2018-11-16 13:54:40.519 [error] <0.705.0> Supervisor {<0.705.0>,rabbit_amqqueue_sup} had child rabbit_amqqueue started with rabbit_prequeue:start_link({amqqueue,{resource,<<"/">>,queue,<<"AE_DWH_MSG_QUEUE">>},true,false,none,[],none,[],[],[],undefined,...}, declare, <0.704.0>) at <0.706.0> exit with reason no function clause matching 'Elixir.RabbitMQ.MessageDeduplicationPlugin.Queue':init({amqqueue,{resource,<<"/">>,queue,<<"AE_DWH_MSG_QUEUE">>},true,false,none,[],<0.706.0>,[],[],[],...}, new, #Fun<rabbit_amqqueue_process.11.129944743>) line 125 in context child_terminated 2018-11-16 13:54:40.519 [error] <0.676.0> Error on AMQP connection <0.676.0> (10.241.5.1:60604 -> 10.241.5.10:5672 - rabbitConnectionFactory#34a018d4:0, vhost: '/', user: 'rabbit', state: running), channel 1: {{{function_clause, [{'Elixir.RabbitMQ.MessageDeduplicationPlugin.Queue',init, [{amqqueue, {resource,<<"/">>,queue,<<"AE_DWH_MSG_QUEUE">>}, true,false,none,[],<0.706.0>,[],[],[],undefined,undefined,[], [],live,0,[],<<"/">>, #{user => <<"rabbit">>}}, new,#Fun<rabbit_amqqueue_process.11.129944743>], [{file,"lib/rabbit_message_deduplication_queue.ex"},{line,125}]}, {rabbit_priority_queue,init,3, [{file,"src/rabbit_priority_queue.erl"},{line,151}]}, {rabbit_amqqueue_process,init_it2,3, [{file,"src/rabbit_amqqueue_process.erl"},{line,207}]}, {rabbit_amqqueue_process,handle_call,3, [{file,"src/rabbit_amqqueue_process.erl"},{line,1153}]}, {gen_server2,handle_msg,2,[{file,"src/gen_server2.erl"},{line,1029}]}, {proc_lib,init_p_do_apply,3,[{file,"proc_lib.erl"},{line,247}]}]}, {gen_server2,call,[<0.706.0>,{init,new},infinity]}}, [{gen_server2,call,3,[{file,"src/gen_server2.erl"},{line,329}]}, {rabbit_channel,handle_method,5, [{file,"src/rabbit_channel.erl"},{line,2167}]}, {rabbit_channel,handle_method,3, [{file,"src/rabbit_channel.erl"},{line,1404}]}, {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,init_p_do_apply,3,[{file,"proc_lib.erl"},{line,247}]}]} 2018-11-16 13:54:40.519 [error] <0.686.0> ** Generic server <0.686.0> terminating ** Last message in was {'$gen_cast',{method,{'queue.declare',0,<<"AE_DWH_MSG_QUEUE">>,false,true,false,false,false,[]},none,noflow}} ** When Server state == {ch,running,rabbit_framing_amqp_0_9_1,1,<0.676.0>,<0.684.0>,<0.676.0>,<<"10.241.5.1:60604 -> 10.241.5.10:5672">>,{lstate,<0.685.0>,false},none,1,{[],[]},{user,<<"rabbit">>,[administrator],[{rabbit_auth_backend_internal,none}]},<<"/">>,<<>>,#{},{state,{dict,0,16,16,8,80,48,{[],[],[],[],[],[],[],[],[],[],[],[],[],[],[],[]},{{[],[],[],[],[],[],[],[],[],[],[],[],[],[],[],[]}}},erlang},#{},#{},{set,0,16,16,8,80,48,{[],[],[],[],[],[],[],[],[],[],[],[],[],[],[],[]},{{[],[],[],[],[],[],[],[],[],[],[],[],[],[],[],[]}}},<0.678.0>,{state,fine,5000,#Ref<0.1163116236.3051356161.240880>},false,1,{{0,nil},{0,nil}},[],[],{{0,nil},{0,nil}},[{<<"exchange_exchange_bindings">>,bool,true},{<<"connection.blocked">>,bool,true},{<<"authentication_failure_close">>,bool,true},{<<"basic.nack">>,bool,true},{<<"publisher_confirms">>,bool,true},{<<"consumer_cancel_notify">>,bool,true}],none,0,none,flow,[]} ** Reason for termination ==

from rabbitmq-message-deduplication.

Closing this one as duplicate of #22.

from rabbitmq-message-deduplication.