我正在研究一个独立的Java应用程序,它从一个MQ队列中获取几条消息,处理消息中包含的数据,然后将新消息PUT到另一个MQ队列.其中一个要求是GET和PUT操作在同一工作单元内,我可以通过指定MQGMO_SYNCPOINT和MQGMO_SYNCPOINT获取/放置消息选项来完成此操作.
我不明白如何使用Java MQ API执行MQCMIT和MQBACK操作以显式提交或回滚MQ工作单元.
我在IBM MQ InfoCenter网站和JavaDoc上搜索过但我找不到用于提交和回滚工作单元的API的任何内容.
我正在使用的WebSphere MQ版本是7.5,我使用绑定模式连接到队列管理器.
是否有人能够提供一些示例代码,展示如何使用Java MQ API显式提交或回滚MQ工作单元,或者指向适当的JavaDoc页面的方向？
基本流程是,当您在事务中发送消息时,它会将消息保存在缓冲区中,直到调用提交或回滚:如果执行提交,则发送消息,否则将丢弃消息.
以下是使用JMS API的Novell示例,如果您使用的是JMS API,则应与WebSphere MQ相同:
http://www.novell.com/documentation/extend52/Docs/help/MP/jms/tutorial/txSession-1.htm
更新: 下面是StackOverflow上的另一个问题,它包含使用Websphere MQ API提交/回滚的代码: