国产一级a片免费看高清,亚洲熟女中文字幕在线视频,黄三级高清在线播放,免费黄色视频在线看

我近段的一個應用中需要消息驅(qū)動POJO。
最近也聽說Spring 2.0開始支持消息驅(qū)動POJO了，但我的應用使用的Spring1.2。
從網(wǎng)上找了一些文章看來都比較舊了，并且近段ActiveMQ處于Apache的孵化器中，包的結構也有些改變，原來的ActiveMQ中的JCA容器部分也從ActiveMQ中獨立也來成了Jencks項目。
后來參考這些文章和Jencks官網(wǎng)上的說明成功實現(xiàn)了消息驅(qū)動POJO。
下面記錄了我配置的過程：

 

1. 搞定相依賴的包。
   a.Spring相關的一些包，這部分就不再啰嗦了。
   b.ActiveMQ相關的包
   activemq-ra-4.01
   concurrent-1.3.4
   incubator-activemq-4.0.1
   c.JCA容器
   jencks-1.3-all

    

    

2. 服務端配置
   
   代碼
   1. <bean id="helloBean" class="mdp.demo.HelloBean" />  
   2.   
   3.     <bean id="jmsTransactionManager"  
   4.         class="org.jencks.factory.TransactionManagerFactoryBean" />  
   5.   
   6.     <bean id="activeMQContainer" class="org.jencks.JCAContainer">  
   7.         <property name="bootstrapContext" >  
   8.             <bean id="bootstrapContext" class="org.jencks.factory.BootstrapContextFactoryBean">  
   9.                 <property name="transactionManager" ref="jmsTransactionManager"/>  
   10.             </bean>  
   11.         </property>  
   12.            
   13.         <property name="resourceAdapter">  
   14.             <bean id="activeMQResourceAdapter"  
   15.                 class="org.apache.activemq.ra.ActiveMQResourceAdapter">  
   16.                 <property name="serverUrl"  
   17.                     value="tcp://localhost:61616" />  
   18.             </bean>  
   19.         </property>  
   20.     </bean>  
   21.   
   22.     <bean id="HelloMDP" class="org.jencks.JCAConnector">  
   23.         <property name="jcaContainer" ref="activeMQContainer" />  
   24.         <property name="transactionManager" ref="jmsTransactionManager" />  
   25.         <property name="activationSpec">  
   26.             <bean  
   27.                 class="org.apache.activemq.ra.ActiveMQActivationSpec">  
   28.                 <property name="destination" value="Hello.Queue" />  
   29.                 <property name="destinationType"  
   30.                     value="javax.jms.Queue" />  
   31.             </bean>  
   32.         </property>  
   33.         <property name="ref" value="helloBean" />  
   34.     </bean>  

    

    

3. 開發(fā)HelloBean
   
   代碼
   1. package mdp.demo;   
   2.   
   3. import javax.jms.JMSException;   
   4. import javax.jms.Message;   
   5. import javax.jms.MessageListener;   
   6.   
   7. public class HelloBean implements MessageListener {   
   8.   
   9.     public void onMessage(Message msg) {   
   10.         try {   
   11.             String name = msg.getStringProperty("name");   
   12.             if (name == null) {   
   13.                 name = "World";   
   14.             }   
   15.   
   16.             System.out.println("Hello " + name + "!");   
   17.         } catch (JMSException e) {   
   18.             e.printStackTrace();   
   19.         }   
   20.   
   21.     }   
   22.   
   23. }   
   24.   

    

    

4. 客戶端配置，這里直接使用Spring的JmsTemplate
   
   代碼
   1. <bean id="jmsTemplate"  
   2.         class="org.springframework.jms.core.JmsTemplate">  
   3.         <property name="defaultDestinationName" value="Hello.Queue" />  
   4.         <property name="connectionFactory" ref="connectionFactory" />  
   5.     </bean>  
   6. <bean id="connectionFactory"  
   7.         class="org.apache.activemq.ActiveMQConnectionFactory">  
   8.         <property name="brokerURL" value="tcp://localhost:61616" />  
   9.     </bean>  

    

    

5. 客戶端示例程序
   
   代碼
   1. package mdp.demo;   
   2.   
   3. import javax.jms.JMSException;   
   4. import javax.jms.MapMessage;   
   5. import javax.jms.Message;   
   6. import javax.jms.Session;   
   7.   
   8. import org.springframework.context.ApplicationContext;   
   9. import org.springframework.context.support.ClassPathXmlApplicationContext;   
   10. import org.springframework.jms.core.JmsTemplate;   
   11. import org.springframework.jms.core.MessageCreator;   
   12.   
   13. public class MDPClient {   
   14.     public static void main(String[] args) {   
   15.         ApplicationContext ctx = new ClassPathXmlApplicationContext(   
   16.                 "spring-client.xml");   
   17.   
   18.         JmsTemplate template = (JmsTemplate) ctx.getBean("jmsTemplate");   
   19.         template.setDefaultDestinationName("Hello.Queue");   
   20.         template.send(new MessageCreator() {   
   21.             public Message createMessage(Session session) throws JMSException {   
   22.                 MapMessage message = session.createMapMessage();   
   23.                 message.setStringProperty("name", "消息驅(qū)動POJO");   
   24.                 return message;   
   25.             }   
   26.         });   
   27.            
   28.            
   29.     }   
   30. }   

    

   上面的示例代碼實現(xiàn)了消息驅(qū)動POJO，但是POJO類仍需實現(xiàn)MessageListener接口。
   上面的配置也不支持XA事務，Jencks官網(wǎng)上有說明，但我沒有配置成功(Hibernate和JMS)。有哪位兄弟配置成功請告知，謝謝。