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>