Java多线程处理ActiveMQ消息

 package com.roncoo.pay.app.queue;

    
  
    
 import java.util.Map;
    
  
    
 import javax.jms.JMSException;
    
 import javax.jms.Message;
    
 import javax.jms.Session;
    
  
    
 import com.roncoo.pay.app.queue.bankmessage.BankMessageFixedThreadPool;
    
 import com.roncoo.pay.app.queue.bankmessage.BankMessageTask;
    
 import com.roncoo.pay.app.queue.bankmessage.biz.BankMessageBiz;
    
 import org.apache.activemq.command.ActiveMQTextMessage;
    
 import org.apache.commons.logging.Log;
    
 import org.apache.commons.logging.LogFactory;
    
 impor