记一次MQ异常、且事务自动提交 导致的生产问题

public class ReciveRepayQueue extends NQueueCustomer {

@Override
    public void doExecute() throws Exception {
        for (Message message:this.getMessageList()){
//          Connection conn = getConnection();
            Connection conn = DataSourceOperationUtil.getConnection();
            conn.setAutoCommit(false);　　//设置数据库手动提交事务

            try {
                handleBiz(message,conn);
                conn.commit();　　　　　　//业务逻辑正常执行完，才commit
            } catch (Exception e) {
                e.printStackTrace();
                log.
                throw new Exception(e);
            } finally {
                //释放连接
                DataSourceOperationUtil.releaseConnection(conn);
                if (!conn.isClosed()) {
                    conn.close();
                }
            }
        }
    }

    private void handleBiz(Message message, Connection conn) throws Exception {
       try {
        ...
       }catch (Exception e){
          log.
          throw new Exception(e);  //抛出异常
      }
　　｝

｝