Comments (7)
noxdafox
commented on July 19, 2024
Hello,
thanks for reporting the issue. Can you please provide the RabbitMQ logs as well?
from rabbitmq-message-deduplication.
ryanermita
commented on July 19, 2024
I hope this is enough,
i try to read the plugin codebase hoping i can get additional details for debugging, but it is written in elixir which i dont have experience. :)
2018-09-19 15:22:58.224 [info] <0.23268.0> accepting AMQP connection <0.23268.0> i(127.0.0.1:59490 -> 127.0.0.1:5672)
2018-09-19 15:22:58.231 [info] <0.23268.0> connection <0.23268.0> (127.0.0.1:59490 -> 127.0.0.1:5672): user 'guest' authenticated and granted access to vhost '/'
2018-09-19 15:22:58.246 [error] <0.23279.0> ** Generic server <0.23279.0> terminating
** Last message in was {init,new}
** When Server state == {q,{amqqueue,{resource,<<"/">>,queue,<<"updated_user">>},true,false,none,[{<<"x-message-deduplication">>,bool,true}],<0.23279.0>,[],[],[],undefined,undefined,[],[],live,0,[],<<"/">>,#{user => <<"guest">>}},none,false,undefined,undefined,{state,{queue,[],[],0},{active,-576342243435123,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 ==
** {noproc,{'Elixir.GenServer',call,['Elixir.RabbitMQ.MessageDeduplicationPlugin.Supervisor',{start_child,{{'Elixir.RabbitMQ.MessageDeduplicationPlugin.Cache',start_link,[cache_queue__updated_user,[{ttl,nil},{persistence,memory}]]},permanent,5000,worker,['Elixir.RabbitMQ.MessageDeduplicationPlugin.Cache']}},infinity]}}
2018-09-19 15:22:58.246 [error] <0.23283.0> Restarting crashed queue 'updated_user' in vhost '/'.
2018-09-19 15:22:58.247 [error] <0.23279.0> CRASH REPORT Process <0.23279.0> with 0 neighbours exited with reason: no such process or port in call to 'Elixir.GenServer':call('Elixir.RabbitMQ.MessageDeduplicationPlugin.Supervisor', {start_child,{{'Elixir.RabbitMQ.MessageDeduplicationPlugin.Cache',start_link,[cache_queue__updated_user,...]},...}}, infinity) in gen_server2:terminate/3 line 1166
2018-09-19 15:22:58.247 [error] <0.23278.0> Supervisor {<0.23278.0>,rabbit_amqqueue_sup} had child rabbit_amqqueue started with rabbit_prequeue:start_link({amqqueue,{resource,<<"/">>,queue,<<"updated_user">>},true,false,none,[{<<"x-message-deduplicati...">>,...}],...}, declare, <0.23277.0>) at <0.23279.0> exit with reason no such process or port in call to 'Elixir.GenServer':call('Elixir.RabbitMQ.MessageDeduplicationPlugin.Supervisor', {start_child,{{'Elixir.RabbitMQ.MessageDeduplicationPlugin.Cache',start_link,[cache_queue__updated_user,...]},...}}, infinity) in context child_terminated
2018-09-19 15:22:58.248 [error] <0.23275.0> ** Generic server <0.23275.0> terminating
** Last message in was {'$gen_cast',{method,{'queue.declare',0,<<"updated_user">>,false,true,false,false,false,[{<<"x-message-deduplication">>,bool,true}]},none,noflow}}
** When Server state == {ch,running,rabbit_framing_amqp_0_9_1,1,<0.23268.0>,<0.23273.0>,<0.23268.0>,<<"127.0.0.1:59490 -> 127.0.0.1:5672">>,{lstate,<0.23274.0>,false},none,1,{[],[]},{user,<<"guest">>,[administrator],[{rabbit_auth_backend_internal,none}]},<<"/">>,<<>>,#{},{state,{dict,0,16,16,8,80,48,{[],[],[],[],[],[],[],[],[],[],[],[],[],[],[],[]},{{[],[],[],[],[],[],[],[],[],[],[],[],[],[],[],[]}}},erlang},#{},#{},{set,0,16,16,8,80,48,{[],[],[],[],[],[],[],[],[],[],[],[],[],[],[],[]},{{[],[],[],[],[],[],[],[],[],[],[],[],[],[],[],[]}}},<0.23269.0>,{state,fine,5000,#Ref<0.8763481.59768833.74291>},false,1,{{0,nil},{0,nil}},[],[],{{0,nil},{0,nil}},[{<<"consumer_cancel_notify">>,bool,true},{<<"authentication_failure_close">>,bool,true},{<<"connection.blocked">>,bool,true}],none,0,none,flow,[]}
** Reason for termination ==
** {{{noproc,{'Elixir.GenServer',call,['Elixir.RabbitMQ.MessageDeduplicationPlugin.Supervisor',{start_child,{{'Elixir.RabbitMQ.MessageDeduplicationPlugin.Cache',start_link,[cache_queue__updated_user,[{ttl,nil},{persistence,memory}]]},permanent,5000,worker,['Elixir.RabbitMQ.MessageDeduplicationPlugin.Cache']}},infinity]}},{gen_server2,call,[<0.23279.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,249}]}]}
2018-09-19 15:22:58.249 [error] <0.23275.0> CRASH REPORT Process <0.23275.0> with 0 neighbours exited with reason: {{noproc,{'Elixir.GenServer',call,['Elixir.RabbitMQ.MessageDeduplicationPlugin.Supervisor',{start_child,{{'Elixir.RabbitMQ.MessageDeduplicationPlugin.Cache',start_link,[cache_queue__updated_user,[{ttl,nil},{persistence,memory}]]},permanent,5000,worker,['Elixir.RabbitMQ.MessageDeduplicationPlugin.Cache']}},infinity]}},{gen_server2,call,[<0.23279.0>,{init,new},infinity]}} in gen_server2:call/3 line 329 in gen_server2:terminate/3 line 1166
2018-09-19 15:22:58.248 [error] <0.23268.0> Error on AMQP connection <0.23268.0> (127.0.0.1:59490 -> 127.0.0.1:5672, vhost: '/', user: 'guest', state: running), channel 1:
{{{noproc,
{'Elixir.GenServer',call,
['Elixir.RabbitMQ.MessageDeduplicationPlugin.Supervisor',
{start_child,
{{'Elixir.RabbitMQ.MessageDeduplicationPlugin.Cache',
start_link,
[cache_queue__updated_user,
[{ttl,nil},{persistence,memory}]]},
permanent,5000,worker,
['Elixir.RabbitMQ.MessageDeduplicationPlugin.Cache']}},
infinity]}},
{gen_server2,call,[<0.23279.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,249}]}]}
2018-09-19 15:22:58.249 [warning] <0.23268.0> Non-AMQP exit reason '{{{noproc,{'Elixir.GenServer',call,['Elixir.RabbitMQ.MessageDeduplicationPlugin.Supervisor',{start_child,{{'Elixir.RabbitMQ.MessageDeduplicationPlugin.Cache',start_link,[cache_queue__updated_user,[{ttl,nil},{persistence,memory}]]},permanent,5000,worker,['Elixir.RabbitMQ.MessageDeduplicationPlugin.Cache']}},infinity]}},{gen_server2,call,[<0.23279.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,249}]}]}'
2018-09-19 15:22:58.250 [error] <0.23272.0> Supervisor {<0.23272.0>,rabbit_channel_sup} had child channel started with rabbit_channel:start_link(1, <0.23268.0>, <0.23273.0>, <0.23268.0>, <<"127.0.0.1:59490 -> 127.0.0.1:5672">>, rabbit_framing_amqp_0_9_1, {user,<<"guest">>,[administrator],[{rabbit_auth_backend_internal,none}]}, <<"/">>, [{<<"consumer_cancel_notify">>,bool,true},{<<"authentication_failure_close">>,bool,true},{<<"conn...">>,...}], <0.23269.0>, <0.23274.0>) at <0.23275.0> exit with reason {{noproc,{'Elixir.GenServer',call,['Elixir.RabbitMQ.MessageDeduplicationPlugin.Supervisor',{start_child,{{'Elixir.RabbitMQ.MessageDeduplicationPlugin.Cache',start_link,[cache_queue__updated_user,[{ttl,nil},{persistence,memory}]]},permanent,5000,worker,['Elixir.RabbitMQ.MessageDeduplicationPlugin.Cache']}},infinity]}},{gen_server2,call,[<0.23279.0>,{init,new},infinity]}} in gen_server2:call/3 line 329 in context child_terminated
2018-09-19 15:22:58.250 [error] <0.23272.0> Supervisor {<0.23272.0>,rabbit_channel_sup} had child channel started with rabbit_channel:start_link(1, <0.23268.0>, <0.23273.0>, <0.23268.0>, <<"127.0.0.1:59490 -> 127.0.0.1:5672">>, rabbit_framing_amqp_0_9_1, {user,<<"guest">>,[administrator],[{rabbit_auth_backend_internal,none}]}, <<"/">>, [{<<"consumer_cancel_notify">>,bool,true},{<<"authentication_failure_close">>,bool,true},{<<"conn...">>,...}], <0.23269.0>, <0.23274.0>) at <0.23275.0> exit with reason reached_max_restart_intensity in context shutdown
2018-09-19 15:22:58.255 [info] <0.23268.0> closing AMQP connection <0.23268.0> (127.0.0.1:59490 -> 127.0.0.1:5672, vhost: '/', user: 'guest')
2018-09-19 15:22:58.256 [error] <0.23283.0> ** Generic server <0.23283.0> terminating
** Last message in was {'$gen_cast',init}
** When Server state == {q,{amqqueue,{resource,<<"/">>,queue,<<"updated_user">>},true,false,none,[{<<"x-message-deduplication">>,bool,true}],<0.23283.0>,[],[],[],undefined,undefined,[],[],live,0,[],<<"/">>,#{user => <<"guest">>}},none,false,undefined,undefined,{state,{queue,[],[],0},{active,-576342243426231,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 ==
** {noproc,{'Elixir.GenServer',call,['Elixir.RabbitMQ.MessageDeduplicationPlugin.Supervisor',{start_child,{{'Elixir.RabbitMQ.MessageDeduplicationPlugin.Cache',start_link,[cache_queue__updated_user,[{ttl,nil},{persistence,memory}]]},permanent,5000,worker,['Elixir.RabbitMQ.MessageDeduplicationPlugin.Cache']}},infinity]}}
2018-09-19 15:22:58.256 [error] <0.23283.0> CRASH REPORT Process <0.23283.0> with 0 neighbours exited with reason: no such process or port in call to 'Elixir.GenServer':call('Elixir.RabbitMQ.MessageDeduplicationPlugin.Supervisor', {start_child,{{'Elixir.RabbitMQ.MessageDeduplicationPlugin.Cache',start_link,[cache_queue__updated_user,...]},...}}, infinity) in gen_server2:terminate/3 line 1166
2018-09-19 15:22:58.257 [error] <0.23278.0> Supervisor {<0.23278.0>,rabbit_amqqueue_sup} had child rabbit_amqqueue started with rabbit_prequeue:start_link({amqqueue,{resource,<<"/">>,queue,<<"updated_user">>},true,false,none,[{<<"x-message-deduplicati...">>,...}],...}, declare, <0.23277.0>) at <0.23283.0> exit with reason no such process or port in call to 'Elixir.GenServer':call('Elixir.RabbitMQ.MessageDeduplicationPlugin.Supervisor', {start_child,{{'Elixir.RabbitMQ.MessageDeduplicationPlugin.Cache',start_link,[cache_queue__updated_user,...]},...}}, infinity) in context child_terminated
2018-09-19 15:22:58.257 [error] <0.23285.0> Restarting crashed queue 'updated_user' in vhost '/'.
2018-09-19 15:22:58.272 [error] <0.23288.0> Restarting crashed queue 'updated_user' in vhost '/'.
2018-09-19 15:22:58.271 [error] <0.23285.0> ** Generic server <0.23285.0> terminating
** Last message in was {'$gen_cast',init}
** When Server state == {q,{amqqueue,{resource,<<"/">>,queue,<<"updated_user">>},true,false,none,[{<<"x-message-deduplication">>,bool,true}],<0.23285.0>,[],[],[],undefined,undefined,[],[],live,0,[],<<"/">>,#{user => <<"guest">>}},none,false,undefined,undefined,{state,{queue,[],[],0},{active,-576342243415789,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 ==
** {noproc,{'Elixir.GenServer',call,['Elixir.RabbitMQ.MessageDeduplicationPlugin.Supervisor',{start_child,{{'Elixir.RabbitMQ.MessageDeduplicationPlugin.Cache',start_link,[cache_queue__updated_user,[{ttl,nil},{persistence,memory}]]},permanent,5000,worker,['Elixir.RabbitMQ.MessageDeduplicationPlugin.Cache']}},infinity]}}
2018-09-19 15:22:58.272 [error] <0.23285.0> CRASH REPORT Process <0.23285.0> with 0 neighbours exited with reason: no such process or port in call to 'Elixir.GenServer':call('Elixir.RabbitMQ.MessageDeduplicationPlugin.Supervisor', {start_child,{{'Elixir.RabbitMQ.MessageDeduplicationPlugin.Cache',start_link,[cache_queue__updated_user,...]},...}}, infinity) in gen_server2:terminate/3 line 1166
2018-09-19 15:22:58.273 [error] <0.23278.0> Supervisor {<0.23278.0>,rabbit_amqqueue_sup} had child rabbit_amqqueue started with rabbit_prequeue:start_link({amqqueue,{resource,<<"/">>,queue,<<"updated_user">>},true,false,none,[{<<"x-message-deduplicati...">>,...}],...}, declare, <0.23277.0>) at <0.23285.0> exit with reason no such process or port in call to 'Elixir.GenServer':call('Elixir.RabbitMQ.MessageDeduplicationPlugin.Supervisor', {start_child,{{'Elixir.RabbitMQ.MessageDeduplicationPlugin.Cache',start_link,[cache_queue__updated_user,...]},...}}, infinity) in context child_terminated
2018-09-19 15:22:58.287 [error] <0.23288.0> ** Generic server <0.23288.0> terminating
** Last message in was {'$gen_cast',init}
** When Server state == {q,{amqqueue,{resource,<<"/">>,queue,<<"updated_user">>},true,false,none,[{<<"x-message-deduplication">>,bool,true}],<0.23288.0>,[],[],[],undefined,undefined,[],[],live,0,[],<<"/">>,#{user => <<"guest">>}},none,false,undefined,undefined,{state,{queue,[],[],0},{active,-576342243401101,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 ==
** {noproc,{'Elixir.GenServer',call,['Elixir.RabbitMQ.MessageDeduplicationPlugin.Supervisor',{start_child,{{'Elixir.RabbitMQ.MessageDeduplicationPlugin.Cache',start_link,[cache_queue__updated_user,[{ttl,nil},{persistence,memory}]]},permanent,5000,worker,['Elixir.RabbitMQ.MessageDeduplicationPlugin.Cache']}},infinity]}}
2018-09-19 15:22:58.287 [error] <0.23290.0> Restarting crashed queue 'updated_user' in vhost '/'.
2018-09-19 15:22:58.288 [error] <0.23288.0> CRASH REPORT Process <0.23288.0> with 0 neighbours exited with reason: no such process or port in call to 'Elixir.GenServer':call('Elixir.RabbitMQ.MessageDeduplicationPlugin.Supervisor', {start_child,{{'Elixir.RabbitMQ.MessageDeduplicationPlugin.Cache',start_link,[cache_queue__updated_user,...]},...}}, infinity) in gen_server2:terminate/3 line 1166
2018-09-19 15:22:58.288 [error] <0.23278.0> Supervisor {<0.23278.0>,rabbit_amqqueue_sup} had child rabbit_amqqueue started with rabbit_prequeue:start_link({amqqueue,{resource,<<"/">>,queue,<<"updated_user">>},true,false,none,[{<<"x-message-deduplicati...">>,...}],...}, declare, <0.23277.0>) at <0.23288.0> exit with reason no such process or port in call to 'Elixir.GenServer':call('Elixir.RabbitMQ.MessageDeduplicationPlugin.Supervisor', {start_child,{{'Elixir.RabbitMQ.MessageDeduplicationPlugin.Cache',start_link,[cache_queue__updated_user,...]},...}}, infinity) in context child_terminated
2018-09-19 15:22:58.295 [error] <0.23290.0> ** Generic server <0.23290.0> terminating
** Last message in was {'$gen_cast',init}
** When Server state == {q,{amqqueue,{resource,<<"/">>,queue,<<"updated_user">>},true,false,none,[{<<"x-message-deduplication">>,bool,true}],<0.23290.0>,[],[],[],undefined,undefined,[],[],live,0,[],<<"/">>,#{user => <<"guest">>}},none,false,undefined,undefined,{state,{queue,[],[],0},{active,-576342243385126,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 ==
** {noproc,{'Elixir.GenServer',call,['Elixir.RabbitMQ.MessageDeduplicationPlugin.Supervisor',{start_child,{{'Elixir.RabbitMQ.MessageDeduplicationPlugin.Cache',start_link,[cache_queue__updated_user,[{ttl,nil},{persistence,memory}]]},permanent,5000,worker,['Elixir.RabbitMQ.MessageDeduplicationPlugin.Cache']}},infinity]}}
2018-09-19 15:22:58.296 [error] <0.23292.0> Restarting crashed queue 'updated_user' in vhost '/'.
2018-09-19 15:22:58.296 [error] <0.23290.0> CRASH REPORT Process <0.23290.0> with 0 neighbours exited with reason: no such process or port in call to 'Elixir.GenServer':call('Elixir.RabbitMQ.MessageDeduplicationPlugin.Supervisor', {start_child,{{'Elixir.RabbitMQ.MessageDeduplicationPlugin.Cache',start_link,[cache_queue__updated_user,...]},...}}, infinity) in gen_server2:terminate/3 line 1166
2018-09-19 15:22:58.299 [error] <0.23278.0> Supervisor {<0.23278.0>,rabbit_amqqueue_sup} had child rabbit_amqqueue started with rabbit_prequeue:start_link({amqqueue,{resource,<<"/">>,queue,<<"updated_user">>},true,false,none,[{<<"x-message-deduplicati...">>,...}],...}, declare, <0.23277.0>) at <0.23290.0> exit with reason no such process or port in call to 'Elixir.GenServer':call('Elixir.RabbitMQ.MessageDeduplicationPlugin.Supervisor', {start_child,{{'Elixir.RabbitMQ.MessageDeduplicationPlugin.Cache',start_link,[cache_queue__updated_user,...]},...}}, infinity) in context child_terminated
2018-09-19 15:22:58.304 [error] <0.23292.0> ** Generic server <0.23292.0> terminating
** Last message in was {'$gen_cast',init}
** When Server state == {q,{amqqueue,{resource,<<"/">>,queue,<<"updated_user">>},true,false,none,[{<<"x-message-deduplication">>,bool,true}],<0.23292.0>,[],[],[],undefined,undefined,[],[],live,0,[],<<"/">>,#{user => <<"guest">>}},none,false,undefined,undefined,{state,{queue,[],[],0},{active,-576342243376706,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 ==
** {noproc,{'Elixir.GenServer',call,['Elixir.RabbitMQ.MessageDeduplicationPlugin.Supervisor',{start_child,{{'Elixir.RabbitMQ.MessageDeduplicationPlugin.Cache',start_link,[cache_queue__updated_user,[{ttl,nil},{persistence,memory}]]},permanent,5000,worker,['Elixir.RabbitMQ.MessageDeduplicationPlugin.Cache']}},infinity]}}
2018-09-19 15:22:58.512 [error] <0.23292.0> CRASH REPORT Process <0.23292.0> with 0 neighbours exited with reason: no such process or port in call to 'Elixir.GenServer':call('Elixir.RabbitMQ.MessageDeduplicationPlugin.Supervisor', {start_child,{{'Elixir.RabbitMQ.MessageDeduplicationPlugin.Cache',start_link,[cache_queue__updated_user,...]},...}}, infinity) in gen_server2:terminate/3 line 1166
2018-09-19 15:22:58.514 [error] <0.23278.0> Supervisor {<0.23278.0>,rabbit_amqqueue_sup} had child rabbit_amqqueue started with rabbit_prequeue:start_link({amqqueue,{resource,<<"/">>,queue,<<"updated_user">>},true,false,none,[{<<"x-message-deduplicati...">>,...}],...}, declare, <0.23277.0>) at <0.23292.0> exit with reason no such process or port in call to 'Elixir.GenServer':call('Elixir.RabbitMQ.MessageDeduplicationPlugin.Supervisor', {start_child,{{'Elixir.RabbitMQ.MessageDeduplicationPlugin.Cache',start_link,[cache_queue__updated_user,...]},...}}, infinity) in context child_terminated
2018-09-19 15:22:58.519 [error] <0.23278.0> Supervisor {<0.23278.0>,rabbit_amqqueue_sup} had child rabbit_amqqueue started with rabbit_prequeue:start_link({amqqueue,{resource,<<"/">>,queue,<<"updated_user">>},true,false,none,[{<<"x-message-deduplicati...">>,...}],...}, declare, <0.23277.0>) at <0.23292.0> exit with reason reached_max_restart_intensity in context shutdown
from rabbitmq-message-deduplication.
noxdafox
commented on July 19, 2024
This looks curious.
Could you please provide a minimal example capable of triggering the problem? Just the smallest python script which is needed to trigger the issue so I can try to reproduce it?
from rabbitmq-message-deduplication.
ryanermita
commented on July 19, 2024
here you go.
from kombu import Connection, Exchange, Queue
import uuid
rabbitmq_url = "amqp://guest:guest@localhost//"
rabbitmq_conn = Connection(rabbitmq_url)
sample_exchange = Exchange("sample_exchange", "direct", durable=True)
sample_queue = Queue("sample_queue", exchange=sample_exchange, routing_key="test.user",
queue_arguments={"x-message-deduplication": True})
producer = rabbitmq_conn.Producer(serializer="json", exchange=sample_exchange, routing_key="test.user")
def generate_uuid():
return uuid.uuid4().hex
producer.publish({"message": "ok"}, declare=[sample_queue], retry=True,
headers={"x-deduplication-header": generate_uuid()})
rabbitmq_conn.release()
from rabbitmq-message-deduplication.
noxdafox
commented on July 19, 2024
Thanks, I'll try to reproduce it later today.
One last, far fetched, question: how did you install the plugin? Did you enable it on a running RabbitMQ or did you restart the broker?
from rabbitmq-message-deduplication.
ryanermita
commented on July 19, 2024
okay i think it's working now.
all i did was restart the rabbitmq :)
Thank you for the quick response!
from rabbitmq-message-deduplication.
noxdafox
commented on July 19, 2024
I guess that was the issue. RabbitMQ has a bootstrap routine you can hook into to perform any initialization required by your plugins.
Nevertheless, I am not aware of any mean to initialize your plugin when enabled on a running cluster.
from rabbitmq-message-deduplication.
Related Issues (20)
- Queue level message deduplication failed sometimes. HOT 1
- Server crash HOT 2
- Support for quorums? HOT 1
- Deduplication doesn't consider the unack messages in the queue HOT 2
- Are there anyway for duplicated message to be dead letter upon published? [Question]
- Celery lost connection to broker HOT 1
- Queue crashes when is created with x-message-deduplication=true parameter on RabbitMQ 3.13.0, Plugin version 0.6.2 HOT 6
- 0.5.3 queues not working under rabbitmq 3.10.0 HOT 3
- Auto generate deduplication checksum base on payload or configurable properties
- 0.5.3 queues not working under rabbitmq 3.8.17 HOT 1
- Can key be removed from cache, after BasicAck and some time has ellapsed? HOT 3
- {:plugins_not_found, [:rabbitmq_message_deduplication]} HOT 2
- Policies support HOT 4
- Bug - when the rabbitmq is restarted the messages in a persistent queue are not deduplicated HOT 2
- Exchange level doesn't work but queue level does. What's differrence on using these two?
- Queue crashed with reason timeout to call RabbitMQMessageDeduplication.CacheManager HOT 7
- `x-cache-size` seems to be manadatory, not optional. HOT 1
- Queue level deduplication seems broken HOT 8
- Exchange info crash after upgrade to 0.6.0 HOT 5
- Debugging exchanges HOT 2
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
D3
Bring data to life with SVG, Canvas and HTML. 📊📈🎉
-
Recommend Topics
-
javascript
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
-
web
Some thing interesting about web. New door for the world.
-
server
A server is a program made to process requests and deliver data to clients.
-
Machine learning
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google ❤️ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.
from rabbitmq-message-deduplication.