java - WebSphere MQ wmq.jmsra 在 MDB 中出现异常后循环

Question

我在使用 JBoss EAP 6 和 WebSphere MQ 时遇到问题。我开发了一个消息驱动的 bean:

@MessageDriven(activationConfig = {
    @ActivationConfigProperty(propertyName = "useJNDI", propertyValue = "true"),
    @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue"),
    @ActivationConfigProperty(propertyName = "destination", propertyValue = "java:/jms/VGT.EXTERN.IN"),
    @ActivationConfigProperty(propertyName = "clientID", propertyValue = "VGT_BYSENDINGSYSTEMDISPATCHERMDB") })
@Pool(value = "BySendingSystemDispatcherMDB-pool")
@TransactionAttribute(TransactionAttributeType.REQUIRED)
public class BySendingSystemDispatcherMDB implements javax.jms.MessageListener {

private Logger logger = Logger.getLogger(getClass());

@Inject
@Named
BySendingSystemDispatcher bySendingSystemDispatcher;

@Resource
MessageDrivenContext mdc;

@Inject
@Named
Listener listener;

@Override
public void onMessage(Message message) {
    try {
        // Weiterbearbeitung deligieren
        bySendingSystemDispatcher.onMessage(message);
    } catch (JMSException e) {
        listener.handleExceptionWhenMessageIsPoisend(e);
        logger.error(e.getLinkedException(), e);
        mdc.setRollbackOnly();
    } catch (JAXBException e) {
        mdc.setRollbackOnly();
        listener.handleExceptionWhileProcessingMessage(message, e);
        logger.error(e.getMessage(), e);
    } catch (ClassCastException e) {
        logger.error(e.getMessage(), e);
        mdc.setRollbackOnly();
    } catch (Exception e) {
        logger.error(e.getMessage(), e);
        mdc.setRollbackOnly();
    } finally {
        // logging
        if (logger.isDebugEnabled()) {
            String id = null;
            try {
                id = message.getJMSMessageID();
                logger.debug(((TextMessage) message).getText());
            } catch (Exception e) {
                logger.debug("logging of message - " + id + " failed");
            }
        }

    }

}

bySendingSystemDispatcher.onMessage(message) 方法抛出一个源自 java.lang.Exception 的异常，并用 @ApplicationException(rollback=true) 进行注释。如果发生这种情况，消息将按照配置重新传递 5 次，之后它会在资源适配器中循环，并且不会再传递。我已经使用 HornetQ 检查了相同的场景，它按预期工作。

MQ将抛出以下异常

Class : class javax.jms.JMSException
Stack : com.ibm.msg.client.commonservices.trace.Trace.ffst(Trace.java:1611)
      : com.ibm.msg.client.wmq.common.internal.messages.WMQSendMarshal.constructMQMD(WMQSendMarshal.java:287)
      : com.ibm.msg.client.wmq.common.internal.messages.WMQSendMarshal.exportMQMDAndMessageBuffers(WMQSendMarshal.java:503)
      : com.ibm.msg.client.wmq.common.internal.messages.WMQSendMarshal.exportMQMD(WMQSendMarshal.java:567)
      : com.ibm.msg.client.wmq.internal.WMQPoison$PoisonMessage.calculateMqmdAndBuffers(WMQPoison.java:1816)
      : com.ibm.msg.client.wmq.

一个有趣的点是，您可以在 MQMD header 中找到超过回退阈值的回退计数。

知道发生了什么以及如何解决吗？

约尔格

Answer 1

我们找到了资源适配器被迫循环的原因。由于输入错误，我们的 boq 配置错误，max-msg-len 属性比引用队列小 8 倍。如果有一条消息大于 boq 的 max-msg-len，并且异常迫使其移动到 boq，则资源适配器会尝试将其放入 boq，但会失败。通常，资源适配器应该将其移动到 dlq，但这也失败了，因为事务丢失。移动到 dlq 失败后，资源适配器没有丢弃该消息，而是再次尝试将其移动到 boq，但再次失败并开始循环。

在我看来，资源适配器的行为并不真正正确，但如果同步 max-msg-len 属性，则不会出现问题。

感谢 Umapathy 的支持。

约尔格