【问题标题】:how to use priority queue in rabbitmq?如何在rabbitmq中使用优先级队列?
【发布时间】:2016-09-17 14:40:35
【问题描述】:

rabbitmq 版本 3.6.1 我不知道如何用erlang代码在rabbitmq中创建优先级队列。

我的代码如下:

{ok, Connection} =
    amqp_connection:start(#amqp_params_network{host = "localhost"}),
{ok, Channel} = amqp_connection:open_channel(Connection),

amqp_channel:call(Channel,
                  #'queue.declare'{queue = <<"my-priority-queue">>, passive = true,
                                   arguments = [{<<"x-max-priority">>, 10}]}).

【问题讨论】:

  • 运行这些代码时发生异常,它说 **exception exit : {shutdown, {gen_server, call, [, {call, {'queue.declare', 0, >, 真, 假, 假, 假, 假, [{>, 10}]}, 非, } 。 ......... ]}}

标签: erlang rabbitmq priority-queue


【解决方案1】:

argumnets 是 AMQP 类型表,其条目必须具有 Erlang API 中指定的类型。试试

arguments = [{<<"x-max-priority">>, long, 10}]

其他方便的类型有longstrtimestamparray[{Type, Value}])、table[{Key, Type, value}])等等。

【讨论】:

    猜你喜欢
    • 1970-01-01
    • 2011-12-06
    • 1970-01-01
    • 2015-01-06
    • 2013-02-02
    • 1970-01-01
    • 2011-12-20
    • 1970-01-01
    • 1970-01-01
    相关资源
    最近更新 更多