简单测试如下：

1：收下下载apache-activemq-5.14.4 解压apache-activemq-5.14.4\bin\win64，运行activemq.bat

启动本地MQ服务器。

通过浏览器可以查看本地MQ服务器的信息。

2: 先往mq中put数据

配置如下：

     
              
      
                   
       
                        
        
                              
        
       
      
     
      
          
     
              
      
              
      
                   
       
                        
                                
       
      
     

 
     
     
      
     

 
     
     
      
      
        
       
       
      
     
     
      
      
      
      
       
        
       
      
     
     
       
      
      
     
 
     
     
     public class CreditBillProcessor implements ItemProcessor
     
       {private JdbcTemplate jdbcTemplate = null;public JdbcTemplate getJdbcTemplate() {return jdbcTemplate;}public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {this.jdbcTemplate = jdbcTemplate;}@Overridepublic BizArgs process(BizArgs bizArgs) throws Exception {System.out.println(bizArgs);return bizArgs;}}
     
     public static void main(String[] args) {//ApplicationContext context = getContext("springJob/mq/job-db-jdbc-month01-putMq.xml");ApplicationContext context = getContext("springJob/mq/job-db-jdbc-month01-getMq.xml");//JmsTemplate jmsTemplate = getJmsTemplate(context);//sendMessage(jmsTemplate, new CreditBill("4047390012345678","tom",100.00,"2013-2-2 12:00:08","Lu Jia Zui road"));//sendMessage(jmsTemplate, new CreditBill("4047390012345678","tom",320,"2013-2-3 10:35:21","Lu Jia Zui road"));//sendMessage(jmsTemplate, new CreditBill("4047390012345678","tom",360.00,"2013-2-11 11:12:38","Longyang road"));executeJob(context, "jmsReadJob",new JobParametersBuilder().addDate("date", new Date()));}

完事后，apache-activemq服务器中会多一个叫enrollMq444（配置文件中配的）的Queue，并且数据和数据库中的条数一致。

3: 从mq中take数据,不详细说了，直接贴配置

     

     
              
      
                   
       
                        
        
                                 
        
       
      
     
 
     
      
          
      
       
       
         
        
        
       
      
     
     
      
      
      
       
       
        
       
      
     
     
      
      
       
       
       
        
       
      
     
     public class UpdateSqlSetter implementsItemPreparedStatementSetter
     
       {@Overridepublic void setValues(BizArgs bigargs, PreparedStatement ps) throws SQLException {ps.setString(1, bigargs.getBizTypePropName()+"haha");ps.setString(2, bigargs.getBizUuid());}}

4:完了，小试一把。