之前例子中,将创建session的第一个参数设置为false,即不支持(不开启)事务
//创建Session,第一个参数是否启用事务,第二个参数配置签收模式
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
现在将它变成true,再通过生产者进行生产操作,此时在控制台可以看到队列里是没有新的数据产生,这时候就要手动提交事务:
session.commit();
同时,有事务基本上都会有回滚事务,在出现一些不正常的问题时可以进行回滚:
session.rollback();