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

}

?屬性????????????大小?????日期????時(shí)間???名稱
-----------?---------??----------?-----??----
?????目錄???????????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個(gè)文件信息