MQ 消息队列的使用

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 生产者

 * 

 */

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);

    }

}

这是一个生产者

配置生产者

 <!-- 先配置一个生产者 -->

<bean id="logUserLoginProducer" class="org.my431.activeMQ.LogUserLoginProducer">

<property name="template" ref="jmsTemplate" />

<property name="destination" ref="baseQueueLogUserLogin" />

</bean>

生产者有一个目的地：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>

<!-- 先配置生产者，再配置接收者 -->

 <!--  listener container，MDP无需实现接口 -->

<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" />