Weblogic JMS 客户端 - 在单个事务中从多个队列读取

Question

使用 WebLogic JMS 客户端 (wlthin3client.jar( 从 WebLogic 11g (WebLogic Server 10.3.6.0( 读取单个事务中来自多个 JMS 队列的消息时出现问题。我正在尝试首先从队列 Q1 中读取一条消息，然后，如果此消息满足某些要求，则从队列 Q2 读取其他消息(如果当时可用(。

我希望在提交交易后，两条消息都应该从 Q1 和 Q2 中消失。在回滚的情况下 - 消息应同时保留在 Q1 和 Q2 中。

我的第一个方法是使用异步队列接收器从 Q1 读取，然后在需要时从 Q2 同步读取：

void run() throws JMSException, NamingException {
QueueConnectionFactory cf = (QueueConnectionFactory) ctx.lookup(connectionFactory);
// create connection and session
conn = cf.createQueueConnection();
session = conn.createQueueSession(true, Session.SESSION_TRANSACTED);
Queue q1 = (Queue) ctx.lookup(queue1);
// setup async receiver for Q1
QueueReceiver q1Receiver = session.createReceiver(q1 );
q1Receiver.setMessageListener(this);
conn.start();
// ...
// after messages are processed
conn.close();
}
@Override
public void onMessage(Message q1msg) {
try {
QueueReceiver q2receiver = session.createReceiver(queue2);
if(shouldReadFromQ2(q1msg)){      
// synchronous receive from Q2
Message q2msg = q2receiver.receiveNoWait();
process(q2msg);
}
session.commit();
} catch (JMSException e) {
e.printStackTrace();
} finally {
q2receiver.close();
}
}

不幸的是，即使我发出session.commit()，来自Q1的消息仍未提交。在连接或接收器关闭之前，它一直处于receive状态。然后似乎在达到delayed状态时回滚。

其他观察结果：

1. 如果 Q2 为空并且没有要从中读取的内容，则 Q1 消息将正确提交。
2. 当我以类似的嵌套方式对 Q1 和 Q2 使用同步 API 时，不会出现此问题。因此，如果我使用q1Receiver.receiveNoWait()一切都很好。
3. 如果我以类似的嵌套方式对 Q1 和 Q2 使用异步 API，则仅调用 Q1 消息侦听器并在 Q1 上工作。但是 Q2 消息侦听器根本没有被调用，Q2 也没有提交(消息卡在receive/delayed中(。

我是否以某种方式滥用了 API？或者这是一个 WLS JMS 错误？如何将从多个队列读取与异步 API 相结合？

Answer 1

事实证明，这是一个 WLS JMS 错误28637420。 错误状态说它已修复，但我不会依赖这个 - 具有此修复程序的 WLS 11g 补丁不起作用(请参阅 bug 29177370(。

Oracle 表示，发生这种情况是因为两种不同的传递机制(同步消息与异步消息(没有设计为在同一会话上协同工作。

解决此问题的最简单方法是在需要在单个会话中处理多个队列的情况使用同步 API(轮询(。我决定采用这种方法。

oracle 建议的另一个选项是将 UserTransactions 与两个不同的会话一起使用，一个会话用于异步使用者，另一个会话用于同步使用者。不过我没有测试。