activemq用spring怎么配置messageconsumer

发布网友 发布时间:2022-04-24 01:56

我来回答

1个回答

热心网友 时间:2023-10-20 08:06

首先,如果知道了activemq的工作原理,以及spring是如何来调用activemq,估计你就知道怎么配置了,这里我先说一下,amq的工作原理和spring在调用amq时的工作流程,然后再给出配置文件,相信你会更加明白。


工作的时候,部署结构如下(图有点大,使用右键->在新标签页打开):

针对上面的proce message,详细的过程如下(图有点大,使用右键->在新标签页打开):

针对consume message,详细过程如下:


spring的配置文件其实,很简单:

生产:

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="

xmlns:xsi="

xsi:schemaLocation="


<bean id="connf" class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL" value="tcp://localhost:61616"></property>
</bean>

<bean id="mydest" class="org.apache.activemq.command.ActiveMQQueue">
<constructor-arg index="0" value="test.queue"></constructor-arg>
</bean>

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


消费:

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns="

xmlns:xsi="

xsi:schemaLocation="


<bean id="connf" class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL" value="tcp://localhost:61616"></property>
</bean>

<bean id="mydest" class="org.apache.activemq.command.ActiveMQQueue">
<constructor-arg index="0" value="test.queue"></constructor-arg>
</bean>

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

</beans>

热心网友 时间:2023-10-20 08:06

首先,如果知道了activemq的工作原理,以及spring是如何来调用activemq,估计你就知道怎么配置了,这里我先说一下,amq的工作原理和spring在调用amq时的工作流程,然后再给出配置文件,相信你会更加明白。


工作的时候,部署结构如下(图有点大,使用右键->在新标签页打开):

针对上面的proce message,详细的过程如下(图有点大,使用右键->在新标签页打开):

针对consume message,详细过程如下:


spring的配置文件其实,很简单:

生产:

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="

xmlns:xsi="

xsi:schemaLocation="


<bean id="connf" class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL" value="tcp://localhost:61616"></property>
</bean>

<bean id="mydest" class="org.apache.activemq.command.ActiveMQQueue">
<constructor-arg index="0" value="test.queue"></constructor-arg>
</bean>

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


消费:

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns="

xmlns:xsi="

xsi:schemaLocation="


<bean id="connf" class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL" value="tcp://localhost:61616"></property>
</bean>

<bean id="mydest" class="org.apache.activemq.command.ActiveMQQueue">
<constructor-arg index="0" value="test.queue"></constructor-arg>
</bean>

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

</beans>

热心网友 时间:2023-10-20 08:06

首先,如果知道了activemq的工作原理,以及spring是如何来调用activemq,估计你就知道怎么配置了,这里我先说一下,amq的工作原理和spring在调用amq时的工作流程,然后再给出配置文件,相信你会更加明白。


工作的时候,部署结构如下(图有点大,使用右键->在新标签页打开):

针对上面的proce message,详细的过程如下(图有点大,使用右键->在新标签页打开):

针对consume message,详细过程如下:


spring的配置文件其实,很简单:

生产:

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="

xmlns:xsi="

xsi:schemaLocation="


<bean id="connf" class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL" value="tcp://localhost:61616"></property>
</bean>

<bean id="mydest" class="org.apache.activemq.command.ActiveMQQueue">
<constructor-arg index="0" value="test.queue"></constructor-arg>
</bean>

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


消费:

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns="

xmlns:xsi="

xsi:schemaLocation="


<bean id="connf" class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL" value="tcp://localhost:61616"></property>
</bean>

<bean id="mydest" class="org.apache.activemq.command.ActiveMQQueue">
<constructor-arg index="0" value="test.queue"></constructor-arg>
</bean>

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

</beans>

热心网友 时间:2023-10-20 08:06

首先,如果知道了activemq的工作原理,以及spring是如何来调用activemq,估计你就知道怎么配置了,这里我先说一下,amq的工作原理和spring在调用amq时的工作流程,然后再给出配置文件,相信你会更加明白。


工作的时候,部署结构如下(图有点大,使用右键->在新标签页打开):

针对上面的proce message,详细的过程如下(图有点大,使用右键->在新标签页打开):

针对consume message,详细过程如下:


spring的配置文件其实,很简单:

生产:

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="

xmlns:xsi="

xsi:schemaLocation="


<bean id="connf" class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL" value="tcp://localhost:61616"></property>
</bean>

<bean id="mydest" class="org.apache.activemq.command.ActiveMQQueue">
<constructor-arg index="0" value="test.queue"></constructor-arg>
</bean>

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


消费:

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns="

xmlns:xsi="

xsi:schemaLocation="


<bean id="connf" class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL" value="tcp://localhost:61616"></property>
</bean>

<bean id="mydest" class="org.apache.activemq.command.ActiveMQQueue">
<constructor-arg index="0" value="test.queue"></constructor-arg>
</bean>

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

</beans>

声明声明:本网页内容为用户发布,旨在传播知识,不代表本网认同其观点,若有侵权等问题请及时与本网联系,我们将在第一时间删除处理。E-MAIL:11247931@qq.com