7

我有 Spring Boot 应用程序,它通过@JmsListener如下注释从组件类中侦听 IBM MQ 队列。MQ 属性(主机名、通道、端口等)是从yaml文件中设置的。

 @JmsListener(destination = "<QueueName>")
 public void receiveMessage(BytesMessage msg) { 
     //snippet to read msg
 }

MQ 依赖项在 gradle build 中添加如下,

compile("com.ibm.mq:mq-jms-spring-boot-starter:0.0.2") {  
        exclude group: 'org.springframework.boot', module: 'spring-boot-starter-logging'
    }

只要我使用 Tomcat 容器在本地运行应用程序,它就可以正常工作并收听消息。但是如果我将它打包为 EAR 并部署到 Wesbphere8.5 服务器,它会抛出异常并且侦听器不会从队列中读取消息。我确认所有运行时依赖项都打包在 EAR 中。尝试了不同版本的 MQ 依赖项,但没有运气。

2018-07-10 15:21:16,531 错误 DefaultMessageListenerContainer - 无法刷新目标“QueueName”的 JMS 连接 - 使用 FixedBackOff{interval=5000,currentAttempts=34,maxAttempts=unlimited} 重试。原因:JMSFMQ6312:Java(tm) MQI 中发生异常。嵌套异常是 com.ibm.mq.jmqi.JmqiException: CC=2;RC=2195;AMQ9546: Error return code received。[1=java.lang.reflect.InvocationTargetException[null],3=NativeConstructorAccessorImpl.newInstance0]

需要帮助来解决此问题。

4

1 回答 1

0

我遇到了类似的问题。发生这种情况是因为 IBM MQ Connection 与您的 JMS 应用程序缺少配置。就我而言,我遇到了与授权相关的异常,但我为 IBM mq 设置了正确的用户凭据。当我检查 IBM mq 站点时,用户名不同,这不是我在我的 spring 应用程序中配置的。

#IBM MQ JMS Configuration
ibm.mq.queueManager={QUEUE_MANAGER}
ibm.mq.channel={CHANNEL_NAME}
ibm.mq.connName={HOST_NAME(HOST_PORT)}
ibm.mq.user={USER_NAME}
ibm.mq.password={PASSWORD}

然后,在使用队列管理器进行身份验证时,我将以下属性添加到使用兼容模式。在这里,我们覆盖了身份验证模式。这在当前维护级别的 MQ V8 或 V9 中通常不需要,但一些较早的级别有时会出错,然后可以将此标志设置为“ false

ibm.mq.user-authentication-m-q-c-s-p=false

请参阅此页面了解更多详情

于 2021-10-22T15:51:46.817 回答