事情开始想的简单，可开始做发现没那么容易。

开始只是想能够找一个具有CALLBACK功能的REMOTING RPC式的POJO方案。一搜就是LINGO，啥话也不说了，整!

可没想到LINGO依赖于4.0.2的ACTIVEMQ，且POM里的MAVEN路径也没更新成ACTIVEMQ搬家后的地方(从CODEHAUSE搬到APACHE了)。去改它的POM指向4.1.1，后来不行又找了4.0.2来自己手工安装上。

这个过程中，发现了其实直接用SPRING+MQ的方案也不错，这里有个方案。再看看LINGO的用户论坛，门可罗雀，算了，转攻MQ吧，别涂简单了。好像工作量就是多写一个消息到POJO的CONVERTER，也可以达到直接发POJO。

没想到，这边也不是很顺，不断报解析不到http://activemq.org/config/1.0的schemaLocation，我按照这里说的，自己写了META-INF里的spring.schema，顺便学了下，这个文件就是告诉SPRING到本地找XSD文件的。

晕！可还是报这个错，我想最新版应该没事吧，又找来MQ的5.0 SNAPSHOT版，还是一样，最后我把SPRING的LOG4J级别设成DEBUG，发现是报找不到XBEAN的解析HANDLER：

    <dependency>
      <groupId>org.apache.xbean</groupId>
      <artifactId>xbean-spring</artifactId>
       <version>3.2</version>
    </dependency>  


赶紧加上，这次LOG走得远点，可以还是报找不到SCHEMA，彻底晕死了!最后仔仔细细查配置文件，发现我从官网这里，拷贝的SCHEMALOCATION：http://activemq.apache.org/snapshot-schema/activemq-core-5.0-SNAPSHOT.xsd，而解开实际的MQ的JAR包里，看相应的meta-inf/spring.schema文件，又是http://activemq.apache.org/schema/activemq-core-5.0.xsd，看出区别了吧？所以对应不上找不着，改了这里，就好了。把JMS配置及POM相关部分贴上来以明志，这才是开始呀!

<?xml version="1.0" encoding="UTF-8" ?>
     
<beans 
  xmlns="http://www.springframework.org/schema/beans" 
  xmlns:amq="http://activemq.org/config/1.0"
  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  xsi:schemaLocation="
    http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsd
    http://activemq.org/config/1.0 http://activemq.apache.org/schema/activemq-core-5.0.xsd">
        
 
    <!--  embedded ActiveMQ Broker -->
    <amq:broker useJmx="false" persistent="false">
        <amq:transportConnectors>
            <amq:transportConnector uri="tcp://localhost:6116"/>
        </amq:transportConnectors>
    </amq:broker>

    <!--  ActiveMQ connectionFactory  -->
    <amq:connectionFactory id="jmsConnectionFactory" brokerURL="tcp://localhost:6116"/>

    <!--  ActiveMQ destinations  -->
    <amq:queue name="destination" physicalName="org.apache.activemq.spring.Test.spring.embedded"/>

    <!--  Spring JmsTemplate config -->
    <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
        <property name="connectionFactory">
            <!--  lets wrap in a pool to avoid creating a connection per send -->
            <bean class="org.springframework.jms.connection.SingleConnectionFactory">
                <property name="targetConnectionFactory" ref="jmsConnectionFactory"/>
            </bean>
        </property>
        <!-- custom MessageConverter -->
        <property name="messageConverter" ref="orderMessageConverter"/>
    </bean>

    <!--  OrderMessage converter  -->
    <bean id="statusConverter" class="com.exchangebit.nms.magic.mq.ConvertAddHostData"/>

    <!-- POJO which send Message uses  Spring JmsTemplate -->
    <bean id="statusProducer" class="com.exchangebit.nms.magic.mq.StatusProducer">
        <property name="template" ref="jmsTemplate"/>
        <property name="destination" ref="destination"/>
    </bean>

    <!--  Message Driven POJO (MDP) -->
    <bean id="messageListener" class="org.springframework.jms.listener.adapter.MessageListenerAdapter">
        <constructor-arg>
            <bean class="com.exchangebit.nms.magic.mq.StatusConsumer">
            </bean>
        </constructor-arg>
        <property name="messageConverter" ref="statusConverter"/>
    </bean>

    <bean id="listenerContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
        <property name="connectionFactory" ref="jmsConnectionFactory"/>
        <property name="destination" ref="destination"/>
        <property name="messageListener" ref="messageListener"/>
    </bean>
</beans>

POM文件相关节：

    <dependency>
      <groupId>org.springframework</groupId>
      <artifactId>spring</artifactId>
      <version>2.0.6</version>
    </dependency>

    <dependency>
      <groupId>org.apache.activemq</groupId>
      <artifactId>activemq-core</artifactId>
      <version>5.0-SNAPSHOT</version>
    </dependency>
      
    <dependency>
      <groupId>org.apache.xbean</groupId>
      <artifactId>xbean-spring</artifactId>
      <version>3.2</version>
    </dependency>     

9266 INFO main  [org.apache.activemq.broker.BrokerService] - Using Persistence Adapter: MemoryPersistenceAdapter
9282 INFO main  [org.apache.activemq.broker.BrokerService] - ActiveMQ 5.0-SNAPSHOT JMS Message Broker (localhost) is starting
9282 INFO main  [org.apache.activemq.broker.BrokerService] - For help or more information please see: http://activemq.apache.org/
2007-11-24 14:57:41 org.apache.cxf.service.factory.ReflectionServiceFactoryBean buildServiceFromClass
信息: Creating Service {http://magic.nms.exchangebit.com/}NotifyServiceImplService from class com.exchangebit.nms.magic.NotifyServiceImpl
2007-11-24 14:57:43 org.apache.cxf.service.factory.ReflectionServiceFactoryBean buildServiceFromClass
信息: Creating Service {http://nodesvc.magic.nms.exchangebit.com/}NodeSvcImplService from class com.exchangebit.nms.magic.nodesvc.NodeSvcImpl
9813 INFO main  [org.apache.activemq.transport.TransportServerThreadSupport] - Listening for connections at: tcp://hehe:6116
9829 INFO main  [org.apache.activemq.broker.TransportConnector] - Connector tcp://localhost:6116 Started
9844 INFO main  [org.apache.activemq.broker.BrokerService] - ActiveMQ JMS Message Broker (localhost, ID:hehe-1857-1195887464218-0:0) started