JMS整合spring含jar


JMS实例,整合spring,含jar,完整可运行
资源截图
代码片段和文件信息
package com.andyao.activemq;

import java.util.HashMap;
import java.util.Map;

import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.Session;

import org.springframework.jms.support.converter.MessageConverter;

public class CoverterHolder implements MessageConverter {
private MessageConverter defaultMessageConverter;
private Map converters = new HashMap();

public Message toMessage(object obj Session session) throws JMSException {
String clz = obj.getClass().getName();
if (converters.containsKey(clz)) {
Message message = converters.get(clz).toMessage(obj session);
message.setobjectProperty(“meta-class“ clz);
return message;
} else {
Message message = defaultMessageConverter.toMessage(obj session);
message.setobjectProperty(“default-meta-class“ clz);
return message;
}
}
public object fromMessage(Message msg) throws JMSException {
if (msg.getobjectProperty(“meta-class“) != null) {
String clz = msg.getobjectProperty(“meta-class“).toString();
if (converters.containsKey(clz)) {
return converters.get(clz).fromMessage(msg);
}
} else if (msg.getobjectProperty(“default-meta-class“) != null) {
return defaultMessageConverter.fromMessage(msg);
} else {
throw new JMSException(“Msg:[“ + msg + “] is not Map“);
}

return null;
}

public void setConverters(Map converters) {
this.converters = converters;
}

public void setDefaultMessageConverter(MessageConverter defaultMessageConverter) {
this.defaultMessageConverter = defaultMessageConverter;
}

}

 属性            大小     日期    时间   名称
----------- ---------  ---------- -----  ----
     目录           0  2015-06-11 11:32  tJms
     文件        4623  2015-06-11 10:23  tJms.classpath
     文件         380  2015-06-11 09:42  tJms.project
     目录           0  2015-06-11 09:42  tJms.settings
     文件         598  2015-06-11 09:42  tJms.settingsorg.eclipse.jdt.core.prefs
     目录           0  2015-06-11 10:23  tJmsin
     目录           0  2015-06-11 10:23  tJmsincom
     目录           0  2015-06-11 10:23  tJmsincomandyao
     目录           0  2015-06-11 10:35  tJmsincomandyaoactivemq
     文件        4895  2015-06-11 10:35  tJmsincomandyaoactivemqapplicationContext-activemq.xml
     文件        2641  2015-06-11 10:23  tJmsincomandyaoactivemqCoverterHolder.class
     文件        3537  2015-06-11 10:23  tJmsincomandyaoactivemqDefaultMessageConverter.class
     文件         516  2015-06-11 10:23  tJmsincomandyaoactivemqFooMessage.class
     文件         871  2015-06-11 10:23  tJmsincomandyaoactivemqQueueConsumer.class
     文件         998  2015-06-11 10:23  tJmsincomandyaoactivemqQueueMessageProducer.class
     文件        1379  2015-06-11 10:47  tJmsincomandyaoactivemqTestMain.class
     文件        1291  2015-06-11 10:23  tJmsincomandyaoactivemqTopicConsumerA$1.class
     文件        1319  2015-06-11 10:23  tJmsincomandyaoactivemqTopicConsumerA.class
     文件         876  2015-06-11 10:23  tJmsincomandyaoactivemqTopicConsumerB.class
     文件         998  2015-06-11 10:23  tJmsincomandyaoactivemqTopicMessageProducer.class
     目录           0  2015-06-11 10:23  tJmsincomandyaolistener
     文件         545  2015-06-11 09:43  tJmsincomandyaolistenerapplicationContext.xml
     文件        1249  2015-06-11 10:23  tJmsincomandyaolistenerTestBean.class
     文件         931  2015-06-11 10:23  tJmsincomandyaolistenerTestEvent.class
     文件         790  2015-06-11 10:23  tJmsincomandyaolistenerTestListener.class
     文件         883  2015-06-11 10:23  tJmsincomandyaolistenerTestMain.class
     文件        2223  2015-06-11 09:44  tJmsinlog4j.properties
     目录           0  2015-06-11 11:32  tJmslib
     文件     3834031  2012-03-15 13:02  tJmslibactivemq-all-5.4.3.jar
     文件       15507  2012-03-15 12:56  tJmslibcfgatewayadapter.jar
     文件       46725  2012-03-15 12:56  tJmslibcommons-codec-1.3.jar
............此处省略54个文件信息

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容, 请发送邮件举报,一经查实,本站将立刻删除。

发表评论

评论列表(条)