public void stopConsumeMessage(){
		try{
			if(threads != null && threads.size() != 0){
				for (int i = 0;i < threads.size(); i++) {
					CommonConsumer consumer = threads.get(i);
					consumer.getSession().commit();
					consumer.closeConsumerAndSession();
					//中断消费者
					if(!consumer.isInterrupted()){
						consumer.interrupt();
					}
					threads.remove(consumer);
					//移除对象后集合的索引都变小，需要重置i
					i--;
				}
			}
		}catch(Exception e){
			LOG.error("停止消费线程失败", e);
		}finally{
			JmsUtil.close();
		}
	}