0

我将 MQ 作为 Weblogic 服务器上的外部 JMS 服务器。问题是我需要回滚消息并重试，直到达到回退阈值。然后我需要将消息移动到回退队列。

MessageDrivenContext.setRollbackOnly() 方法可以很好地解决这个问题。然而，问题在于回退队列上的消息——它是未提交的。

此外，一旦新消息出现在主队列上，消息就会从回退队列中取出并再次处理。

这表明我的方法存在严重错误。但是，我无法改变这样一个事实，即我必须使用相同的消息多次重试 onMessage() 并将其发送到回退队列，以达到回退阈值。

@MessageDriven( name="MQListener", mappedName = "jms.mq.SOME.QUEUE.NAME",
        activationConfig = 
        { 
            @ActivationConfigProperty(propertyName = "destinationType",propertyValue = "javax.jms.Queue"),
            @ActivationConfigProperty(propertyName = "destination", propertyValue = "jms.mq.SOME.QUEUE.NAME"),
            @ActivationConfigProperty(propertyName = "connectionFactoryJndiName", propertyValue = "jms.mq.MQ"),
            @ActivationConfigProperty(propertyName = "useJNDI", propertyValue = "true")
        }) 
public class MQListener implements MessageListener {
    @Resource
    private MessageDrivenContext context;

    @Override
    public void onMessage(Message message) {
        String messageContent="";

        try {
            messageId = message.getJMSMessageID();
            if (message != null) {
                messageContent = ((TextMessage)message).getText();
                if(!doSomething(messageContent)){
                    // doSomething fails, I need to rollback the message and try again:
                    context.setRollbackOnly();
                }
            }
        } catch (Exception e) {
            throw new RuntimeException();
        }

    }

    private boolean doSomething(String messageContent){
        // ...
    }

}
4

1 回答 1

1

我是 EJB 的泰罗。但是从我在您的代码片段中可以看到，我认为您缺少MessageDrivenContext. 我想你必须做

context = getMessageDrivenContext(); 
context.setRollbackOnly();

或者

getMessageDrivenContext().setRollbackOnly();
于 2013-01-30T11:44:03.457 回答