1

spring を使用してアプリケーションをデプロイした後に ActiveMQ messageListener を開始する方法は?

私のxmlファイルは以下のとおりです。

--> 

<bean id="connectionFactory" class="org.springframework.jms.connection.SingleConnectionFactory">
    <property name="targetConnectionFactory" ref="activeMQConnectionFactory"/>
</bean>

<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
    <property name="connectionFactory" ref="connectionFactory"/>
</bean>

<bean id="messageListener" class="com.job.SampleMessageListener">
    <property name="jobResponseBean" ref="jobResponseBean"/>
    <property name="startupMessageHandlerBean" ref="startupMessageHandlerBean"/>
</bean>

<bean id="listenerContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
    <property name="concurrentConsumers" value="${consumer.count}"/>
    <property name="connectionFactory" ref="connectionFactory"/>
    <property name="destinationName" value="general"/>
    <property name="messageListener" ref="messageListener"/>


enter code here
</bean>

<bean id="generalQueue" class="org.apache.activemq.command.ActiveMQQueue">
    <constructor-arg value="general"/>
</bean>
4

1 に答える 1

1

Spring は、開始/開始時に listenerContainer を自動的に開始する必要があります。そのため、すべての構成を正しく設定していれば、すぐに使用できるはずです。

于 2012-09-27T06:27:46.927 に答える