Closed dabogee closed 2 weeks ago
Hello,
the error is incomplete, could you please paste the whole error message?
I confirm this issue.
supervisor: {<0.666.0>,rabbit_amqqueue_sup}
errorContext: child_terminated
reason: {function_clause,
[{'Elixir.RabbitMQMessageDeduplication.Queue','duplicate?',
[{amqqueue,
{resource,<<"/">>,queue,
<<"queue_name">>},
true,false,none,
[{<<"x-message-deduplication">>,bool,true}],
<0.1771.0>,[],[],[],undefined,undefined,[],[],
crashed,0,[],<<"/">>,
#{user => <<"####">>},
rabbit_classic_queue,#{}},
{mc,mc_amqpl,
{content,60,none,
<<####>>,
rabbit_framing_amqp_0_9_1,
[<<"{\"message\":\"####\"}">>]},
#{id =>
<<####>>,
x => <<"####">>,
rk => [<<"queue_name">>],
rts => 1714046802630}}],
[{file,
"lib/rabbitmq_message_deduplication/rabbit_message_deduplication_queue.ex"},
{line,524}]},
{'Elixir.RabbitMQMessageDeduplication.Queue',is_duplicate,2,
[{file,
"lib/rabbitmq_message_deduplication/rabbit_message_deduplication_queue.ex"},
{line,431}]},
{rabbit_amqqueue_process,maybe_deliver_or_enqueue,3,
[{file,"rabbit_amqqueue_process.erl"},{line,728}]},
{rabbit_amqqueue_process,handle_cast,2,
[{file,"rabbit_amqqueue_process.erl"},{line,1576}]},
{gen_server2,handle_msg,2,
[{file,"gen_server2.erl"},{line,1056}]},
{proc_lib,init_p_do_apply,3,
[{file,"proc_lib.erl"},{line,241}]}]}
offender: [{pid,<0.1771.0>},
{id,rabbit_amqqueue},
{mfargs,
{rabbit_prequeue,start_link,
[{amqqueue,
{resource,<<"/">>,queue,
<<"queue_name">>},
true,false,none,
[{<<"x-message-deduplication">>,bool,true}],
<0.3998.0>,[],[],[],undefined,undefined,[],[],
stopped,0,[],<<"/">>,
#{user => <<"####">>},
rabbit_classic_queue,#{}},
recovery,<0.665.0>]}},
{restart_type,transient},
{significant,true},
{shutdown,600000},
{child_type,worker}]
[error] <0.666.0>
Hey hey, same problem here with RabbitMQ 3.13.2.
Same Issue here!!
The problem is most likely the introduction of "message containers" (different internal representation of messages) in RabbitMQ 3.13.0. I'm looking at fixing this.
Issue should be resolved in release 0.6.3
. Re-open this ticket if the problem persists.
Steps:
PS: Code works on RabbitMQ 3.11.0 (as mentioned on release page for 0.6.2 ) then I have to downgrade RabbitMQ to get it works.
Actual: There is error message in the logs
And then receive a popup message on UI: "rejected Unable to publish message. Check queue limits."