04_ActiveMQ_设置事务

之前例子中,将创建session的第一个参数设置为false,即不支持(不开启)事务 

//创建Session,第一个参数是否启用事务,第二个参数配置签收模式
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

现在将它变成true,再通过生产者进行生产操作,此时在控制台可以看到队列里是没有新的数据产生,这时候就要手动提交事务: 

session.commit();

同时,有事务基本上都会有回滚事务,在出现一些不正常的问题时可以进行回滚: 

session.rollback();

猜你喜欢

转载自blog.csdn.net/butterballj/article/details/80879736