JMS消息不承认错误

我得到这个消息不承认错误：JMS消息不承认错误

javax.jms.IllegalStateException: Message not delivered 
at com.tibco.tibjms.TibjmsxSessionImp._confirmNonTransacted(TibjmsxSessionImp.java:3295) 
at com.tibco.tibjms.TibjmsxSessionImp._confirm(TibjmsxSessionImp.java:3644) 
at com.tibco.tibjms.TibjmsxSessionImp._confirmNonAuto(TibjmsxSessionImp.java:4980) 
at com.tibco.tibjms.TibjmsMessage.acknowledge(TibjmsMessage.java:609)

这里是我的代码：

public processMessage(Message pMessage){ 
    try{ 
     performOperation(); 
    } 
    catch(Exception e){ 
    }finally{ 
     if (pMessage != null) { 
      try { 
       pMessage.acknowledge(); 
      } catch (Exception e) { 
       try { 
        if (pMessage.getJMSRedelivered()) { 
         log.info("Message has been redelivered"); 
        } else 
         log.error(("Message has not been delivered"),e); 
       } catch (JMSException e1) { 
        log.error(e1); 
       } 
      } 
     } 
     return null; 
    } 

public boolean performOperation(somedata){ 
    try{ 
    insert into database 
    } 
    catch(DataIntegrityViolationException e){ 
     do something 
     if (pMessage != null){ 
     pMessage.acknowledge(); 
     } 
    } 
} 

    }

来源

2013-08-21 user1910892

你是如何创建的JMS会话？你只能做客户端在非事务处理模式确认，所以一定要确保会话建立这样的：

connection.createSession(false, Session.CLIENT_ACKNOWLEDGE);

此外，你在做finallymessage.acknowledge()，这意味着如果performOperation()失败了，你承认消息，意味着消息将不会被重新发送以进行另一次尝试。考虑做这样的事情时的performOperation()消息是基于经纪人的配置重新发送失败这其中：

public processMessage(Message pMessage){ 
    try{ 
     performOperation(); 
     pMessage.acknowledge(); 
    } 
    catch(Exception e){ 
    }

来源

2013-08-21 19:21:26 raffian

我不知道是如何被创建的JMS会话，我已经更新了代码。 APP在prop中配置了生产者和消费者。 – user1910892

这是行不通的，除非你将它作为参数传递，否则'pMessage'不在'processMessage（）'的作用域中。您应该在processMessage（）中确认并保留所有与消息相关的操作。 – raffian

我传递pMessage作为参数。看得更清楚我在performOperation方法中有不同的条件，并且我在每个条件之后都承认，但是对于每条成功的消息，我正在使用finally确认。 – user1910892

JMS消息不承认错误

回答

相关问题