我已经按照预定的消息这条成功地,但是当我发布延迟的消息有约束力的队列。我无法立即在队列中看到消息。x延迟类型的交换插件将消息缓冲在某个地方,直到时间到了。
无论如何,在延迟时间到了之前,是否有任何配置(配置)可以在管理插件中查看这些延迟消息?
延迟的消息存储在内部Mnesia
,为:
因此,您无法在管理界面中看到它。
编辑
您可以使用:
rabbitmqctl eval 'ets:tab2list(rabbit_delayed_messagerabbit@Your_HOST_NAME).'
前任:
➜ sbin ./rabbitmqctl eval 'ets:tab2list(rabbit_delayed_messagerabbit@mac).'
[{delay_entry,
{delay_key,1487934959224,
{exchange,
{resource,<<"/">>,exchange,<<"my-exchange">>},
'x-delayed-message',true,false,false,
[{<<"x-delayed-type">>,longstr,<<"direct">>}],
undefined,undefined,
{[],[]}}},
{delivery,false,false,<10495.911.0>,
{basic_message,
{resource,<<"/">>,exchange,<<"my-exchange">>},
[<<>>],
{content,60,
{'P_basic',undefined,undefined,
[{<<"x-delay">>,signedint,90000}],
undefined,undefined,undefined,undefined,undefined,
undefined,undefined,undefined,undefined,undefined,
undefined},
<<32,0,0,0,0,13,7,120,45,100,101,108,97,121,73,0,1,95,144>>,
rabbit_framing_amqp_0_9_1,
[<<"delayed payload">>]},
<<174,59,245,237,135,189,175,240,121,105,31,191,47,97,189,156>>,
false},
undefined,noflow},
#Ref<10495.0.1.3514>},
(有效载荷可能无法读取)
编辑2
此功能将从版本开始可用 3.7.0
https://github.com/rabbitmq/rabbitmq-delayed-message-exchange/issues/3
本文收集自互联网,转载请注明来源。
如有侵权,请联系[email protected] 删除。
我来说两句