• 大小: 12.01MB
    文件类型: .zip
    金币: 1
    下载: 0 次
    发布日期: 2023-06-15
  • 语言: Java
  • 标签: JMS  

资源简介

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\.settings\org.eclipse.jdt.core.prefs
     目录           0  2015-06-11 10:23  tJms\bin\
     目录           0  2015-06-11 10:23  tJms\bin\com\
     目录           0  2015-06-11 10:23  tJms\bin\com\andyao\
     目录           0  2015-06-11 10:35  tJms\bin\com\andyao\activemq\
     文件        4895  2015-06-11 10:35  tJms\bin\com\andyao\activemq\applicationContext-activemq.xml
     文件        2641  2015-06-11 10:23  tJms\bin\com\andyao\activemq\CoverterHolder.class
     文件        3537  2015-06-11 10:23  tJms\bin\com\andyao\activemq\DefaultMessageConverter.class
     文件         516  2015-06-11 10:23  tJms\bin\com\andyao\activemq\FooMessage.class
     文件         871  2015-06-11 10:23  tJms\bin\com\andyao\activemq\QueueConsumer.class
     文件         998  2015-06-11 10:23  tJms\bin\com\andyao\activemq\QueueMessageProducer.class
     文件        1379  2015-06-11 10:47  tJms\bin\com\andyao\activemq\TestMain.class
     文件        1291  2015-06-11 10:23  tJms\bin\com\andyao\activemq\TopicConsumerA$1.class
     文件        1319  2015-06-11 10:23  tJms\bin\com\andyao\activemq\TopicConsumerA.class
     文件         876  2015-06-11 10:23  tJms\bin\com\andyao\activemq\TopicConsumerB.class
     文件         998  2015-06-11 10:23  tJms\bin\com\andyao\activemq\TopicMessageProducer.class
     目录           0  2015-06-11 10:23  tJms\bin\com\andyao\listener\
     文件         545  2015-06-11 09:43  tJms\bin\com\andyao\listener\applicationContext.xml
     文件        1249  2015-06-11 10:23  tJms\bin\com\andyao\listener\TestBean.class
     文件         931  2015-06-11 10:23  tJms\bin\com\andyao\listener\TestEvent.class
     文件         790  2015-06-11 10:23  tJms\bin\com\andyao\listener\TestListener.class
     文件         883  2015-06-11 10:23  tJms\bin\com\andyao\listener\TestMain.class
     文件        2223  2015-06-11 09:44  tJms\bin\log4j.properties
     目录           0  2015-06-11 11:32  tJms\lib\
     文件     3834031  2012-03-15 13:02  tJms\lib\activemq-all-5.4.3.jar
     文件       15507  2012-03-15 12:56  tJms\lib\cfgatewayadapter.jar
     文件       46725  2012-03-15 12:56  tJms\lib\commons-codec-1.3.jar
............此处省略54个文件信息

评论

共有 条评论