jms如何支持事务/故障转移？

Question

在后端我想要原子事务，这意味着

try{
get database connection

update employee record;
update department record;
produces messages 1 on queue1
produces messages 2 on queue2
// some exception occured
}
finally{
connection.rollback();
// how to roll back the messages from queue
}

同样，如果消息代理关闭，我将如何确保消息一旦启动就会被删除。

我正在使用 ActiveMQ

Answer 1

假设你有一个JmsSession来发送消息，你可以通过jmsSession.commit()和jmsSession.rollback()来完成jms事务。

如果你希望消息是持久化的，即jms服务器崩溃后可以投递，可以设置消息的投递方式为持久化：jmsMessageProducer.send(msg, DeliveryMode.PERSITENT)

查看详情：

http://docs.oracle.com/javaee/6/api/javax/jms/Session.html