通过属性标志禁用或启用jms队列侦听器

jtjikinw  于 2021-07-23  发布在  Java
关注(0)|答案(0)|浏览(178)
<bean id="transportConfiguration" class="org.hornetq.api.core.TransportConfiguration">
    <constructor-arg index="0">
        <value>org.hornetq.core.remoting.impl.netty.NettyConnectorFactory</value>
    </constructor-arg>
    <constructor-arg index="1">
        <map>
            <entry key="host" value="${jms.host}" />
            <entry key="port" value="${jms.port}" />
        </map>
    </constructor-arg>
</bean>

<bean id="connectionFactory" class="org.hornetq.api.jms.HornetQJMSClient" factory-method="createConnectionFactoryWithoutHA">
    <constructor-arg index="0">
        <bean class="org.hornetq.api.jms.JMSFactoryType" factory-method="valueOf">
            <constructor-arg>
                <value>CF</value>
            </constructor-arg>
        </bean>
    </constructor-arg>
    <constructor-arg index="1" ref="transportConfiguration" />
</bean>

<bean id="messageConverter" class="###.jms.JmsMessageConverter"></bean>

<jms:listener-container destination-resolver="destinationResolver" connection-factory="connectionFactory"
    destination-type="queue" message-converter="messageConverter">
    <jms:listener destination="faxInNotificationPersistentQueue" ref="faxMessageConsumer" method="faxReceived"
        selector="JMSType = '###.messages.FaxReceivedMessage'" />
</jms:listener-container>

我的豆子是这样定义的。我想通过属性文件中的标志动态地打开/关闭队列侦听器。有什么办法吗?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题