|
package org.my431.activeMQ; import javax.jms.Queue; import org.my431.base.model.BaseLoginLog; import org.my431.log.model.LogUserLogin; import org.springframework.jms.core.JmsTemplate; /** * @author wangzhen * @see queue 生產(chǎn)者 * */ public class LogUserLoginProducer { private JmsTemplate template; private Queue destination; public void setTemplate(JmsTemplate template) { this.template = template; } public void setDestination(Queue destination) { this.destination = destination; } public void addLog(BaseLoginLog message) { template.convertAndSend(this.destination, message); } } 這是一個生產(chǎn)者 配置生產(chǎn)者 <!-- 先配置一個生產(chǎn)者 --> <bean id="logUserLoginProducer" class="org.my431.activeMQ.LogUserLoginProducer"> <property name="template" ref="jmsTemplate" /> <property name="destination" ref="baseQueueLogUserLogin" /> </bean> 生產(chǎn)者有一個目的地：destination <!-- 使用Queue方式要--> <amq:queue name="baseQueueLogUserLogin" physicalName="BaseLoginLog" />？？？這是他的目的地？ 配置一個接受者 <!-- 一下為接受者的配置 --> <bean id="queueConsumer" class="org.my431.activeMQ.QueueConsumer" /> <!-- Message Listener for --> 配置一個接收者的名字以及方法 <bean id="queueListener" class="org.springframework.jms.listener.adapter.MessageListenerAdapter"> <constructor-arg ref="queueConsumer" /> <!-- may be other method --> <property name="defaultListenerMethod" value="receive" /> <!-- custom MessageConverter define --> <property name="messageConverter" ref="defaultMessageConverter" /> </bean> <!-- 先配置生產(chǎn)者，再配置接收者 --> <!-- listener container，MDP無需實現(xiàn)接口 --> <bean id="queueListenerResourceLucContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer"> <property name="connectionFactory" ref="jmsConnectionFactory" /> <property name="destination" ref="baseQueueLogUserLogin" /> <property name="messageListener" ref="queueListener" /> </bean> 另外：<property name="messageConverter" ref="defaultMessageConverter" /> |
|
|
