package com.easylab.jms.consumer;import com.easylab.jms.entity.Student;public class  myListenner {//方法里面的参数可以是那五种消息类型，在接受的时候会自动通过反射转换，而不是想别的监听器需要在onmessage房中手动转换public void handleMessage(Student message) {System.out.println("ConsumerListener通过handleMessage接收到一个纯文本消息，消息内容是：" + message.toString());}public void receiveMessage(Student message) {System.out.println("ConsumerListener通过receiveMessage接收到一个纯文本消息，消息内容是：" + message.toString());}public void handleMessage(String message) {System.out.println("ConsumerListener通过handleMessage接收到一个纯文本消息，消息内容是：" + message.toString());}//一旦defaultListenerMethod设置的方法，返回值不是null，就说明要把返回值自动回复给发送者public String receiveMessage(String message) {System.out.println("ConsumerListener通过receiveMessage接收到一个纯文本消息，消息内容是：" + message.toString());return"自动给你回复消息了哦，你接到了吗？";}
}

 <!--以下是使用MessageListenerAdapter监听器相关==============================================================================--><!-- 消息监听适配器 第一种方法通过构造方法参数设置 --><!--<bean id="messageListenerAdapter" class="org.springframework.jms.listener.adapter.MessageListenerAdapter"><constructor-arg><bean class="com.easylab.jms.consumer.myListenner"/></constructor-arg></bean>--><!-- 消息监听适配器 第二种方法通过delegate属性设置 --><bean id="messageListenerAdapter" class="org.springframework.jms.listener.adapter.MessageListenerAdapter"><property name="delegate"><bean class="com.easylab.jms.consumer.myListenner"/></property><!--默认接受到消息后调用哪个方法--><property name="defaultListenerMethod" value="receiveMessage"/><!--设置监听器回复消息的队列（用的以前的点对点队列），也可以通过发送者发送方中的方法setJMSReplyTo设置--><property name="defaultResponseDestination" ref="queueDestination"/></bean><!-- 消息监听适配器对应的监听容器 --><bean id="messageListenerAdapterContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer"><property name="connectionFactory" ref="connectionFactory"/><property name="destination" ref="adapterQueue"/><property name="messageListener" ref="messageListenerAdapter"/><!-- 使用MessageListenerAdapter来作为消息监听器 --></bean><!-- 用于测试消息监听适配器的队列目的地 --><bean id="adapterQueue" class="org.apache.activemq.command.ActiveMQQueue"><constructor-arg><value>adapterQueue</value></constructor-arg></bean>

//以下是使用MessageListenerAdapter监听器相关
@Resource(name = "adapterQueue")Destination destination;@Resource(name = "queueDestination")Destination responseQueue;@Overridepublic void sendMessageByAdapter(String message){// 使用JmsTemplate发送消息jmsTemplate.send(destination, new MessageCreator() {public Message createMessage(Session session) throws JMSException {TextMessage textMessage = session.createTextMessage(message);System.out.println("发送消息：");//通过setJMSReplyTo设置监听器回复消息的队列，也可以通过xml中配置defaultResponseDestination设置/* textMessage.setJMSReplyTo(responseQueue);*/return textMessage;}});}

service.sendMessageByAdapter("测试MessageListenerAdapter");