场景: EJB3.0 从QueueA 中取得消息后,向QueueB放入消息.
问题:抛出运行时异常后,QueueA中的消息自动放回,但是QueueB中放入数据了,应该QueueB中也没有数据才对。
代码如下:
public void onMessage(Message message) {
TextMessage text = (TextMessage) message;// From QueueA
try {
test();
throw new RuntimeException();
} catch (JMSException e) {
e.printStackTrace();
}
}
private static void test() {
MQManager qManager = new MQManager();
try {
qManager.connect("9.123.100.42", "SYSTEM.DEF.SVRCONN", "CLUSQM",
"1415");
qManager.put("QueueB", new String("Hello world!!"));
} catch (Exception e) {
e.printStackTrace();
}
收起