有没有办法使用 java 客户端从 Amqp 0.9.1 RabbitMq

Question

将 com.rabbitmq.client 与 AMQP 版本 0.9.1 一起使用我正在执行以下操作来声明一个持久的标头交换，声明一个持久的队列，并将队列绑定到带有标头的交换。

channel.exchangeDeclare("myExchange", "headers", true);

channel.queueDeclare("myQueue", true, false, false, null);

Map<String, Object> bindingArgs = new HashMap<String, Object>();

bindingArgs.put("x-match", "any"); //any or all

bindingArgs.put("headerName1", "headerValue1");

channel.queueBind("myQueue", "myExchange", "", bindingArgs);

如果我再次运行相同的代码，但使用不同的标头名称/值，我实际上是将另一个标头添加到代理上的队列中（而不是替换前一个）。

IE

...

bindingArgs.put("headerName2", "headerValue2");

...

java rabbitmq 客户端有没有办法从代理获取队列的所有绑定标头？

这将返回如下内容：

"headerName1" : "headerValue1"

"headerName2" : "headerValue2"