我在integrationcontext.xml中有以下交换
<!-- rabbit exchanges, queues, and bindings used by this app -->
<rabbit:topic-exchange name="newPaymentEventsExchange" auto-delete="false" durable="true">
<rabbit:bindings>
</rabbit:bindings>
</rabbit:topic-exchange>
我需要能够根据来自数据库的以下对象的channelName值动态地将队列添加到交换中，当有人添加新通道时我应该能够更新：
public class Channel {
private Long channelId;
private String tenantId;
private String channelName;
------
//Getters & setters
}
用于AmqpAdmin执行此类操作：
/**
* Declare the given queue.
* @param queue the queue to declare.
* @return the name of the queue.
*/
String declareQueue(Queue queue);
/**
* Declare a binding of a queue to an exchange.
* @param binding a description of the binding to declare.
*/
void declareBinding(Binding binding);
为了方便起见QueueBuilder，您可以考虑使用：BindingBuilder
QueueBuilder.nonDurable("foo")
.autoDelete()
.exclusive()
.withArgument("foo", "bar")
.build()
...
BindingBuilder.bind(
marketDataQueue()).to(marketDataExchange()).with(marketDataRoutingKey)