首次访问后在代理上创建jms队列

Question

如果要在spring integration jms上为消息发布者创建qpid目标。例如，我可以创建如下队列：

<bean id="theTestQueue" class="org.apache.qpid.client.AMQQueue">
    <constructor-arg name="address" value="testQueue" />
    <property name="create" value="ALWAYS"/>
    <property name="node">
        <bean class="org.apache.qpid.client.messaging.address.Node">
            <constructor-arg name="name" value="testQueue"/>
            <property name="durable" value="true"/>
        </bean>
    </property>
</bean>

之后，我将此队列设置为通道适配器：

<int:channel id="testChannel"/>
<int-jms:outbound-channel-adapter channel="testChannel" destination="theTestQueue" session-transacted="true"/>

如果发布者发送第一条消息，将在消息代理上创建队列。

但是如果我想动态设置队列，我能做什么呢？

<int:channel id="testChannel"/>   
<int-jms:outbound-channel-adapter destination-expression="headers.destination" channel="testChannel"/>

发布者看起来像：

@Publisher(channel = "testChannel")
public Message<?> sendMessage (Message<?> message, @Header("destination") String name) {
  return message;

}

publisher方法的第二个参数是目标的名称。如果我在发送消息之前在brokerside上创建队列，那么这是可行的。我当前的解决方案是在发布者发送第一条消息之前由jmx mbean创建。但我希望尽可能少地使用jmx连接。是否有机会自动创建队列？或者是没有jmx的工厂。。。

感谢您的帮助。：）

Answer 1

正如您可能注意到的那样，destination属性需要一个bean引用（id）。从另一方面来看，目标表达式也可以计算为目标对象。

如果你有组织。阿帕奇。qpid。客户AMQQueuebean定义对于所有这些“动态目标”，您只需要改进表达式，从应用程序上下文中获得适当的bean

destination-expression="@beanFactoryAccessor.get(headers.destination)"

其中，beanFactoryAccessor是一个简单的bean，它被注入BeanFactory，通过提供的名称调用它的getBean（）。