当前位置: 首页 > 知识库问答 >
问题:

JMS和IBM WebSphere不生成COD

凌运恒
2023-03-14

以下是我的接收消息代码

public byte[] readMsgFromClient() throws JMSException {
        byte[] message = null;
        QueueReceiver reader = null;
        try {
            connection = getQueueConnection();
            connection.start();
            session = connection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);

            Queue queue = session.createQueue(config.getQueueRsp());

            ((MQQueue) queue).setTargetClient(JMSC.MQJMS_CLIENT_NONJMS_MQ);

            reader = session.createReceiver(queue);

            JMSBytesMessage byteMessage = (JMSBytesMessage) reader.receive(3000);

            if (byteMessage != null) {
                message = new byte[(int) byteMessage.getBodyLength()];
                byteMessage.readBytes(message);
            }
        } finally {
            if (reader != null) {
                reader.close();
            }

            if (session != null) {
                session.close();
            }

            if (connection != null) {
                connection.close();
            }
        }

        return message;
    }

我必须手动发送鳕鱼吗?我必须配置我的WebSphere来自动发送COD吗?我必须通知WebSphere我的应用程序已经使用了消息吗?

共有1个答案

尚恩
2023-03-14

COD消息可能会以RC(原因代码)2035(未授权)结束死信队列(DLQ)。

下面是另一个你辛苦学到的东西:

  • COA消息在队列管理器的用户ID下生成
  • COD消息是在发送者消息的用户ID下生成的。
 类似资料:
  • 在尝试从Spring Boot应用程序连接IBM MQ JMS队列时,我遇到以下异常 原因:com。国际商用机器公司味精。客户jms。DetailedJMSExException:JMSCC0005:指定的值“”不允许用于“XMSC\u WMQ\u APPNAME”。 我已经提到:https://github.com/ibm-messaging/mq-jms-spring,但没有帮助。 有什么建议

  • 关于 Storm JMS Storm JMS是在Storm框架内集成JMS消息传递的通过框架。 Storm-JMS 允许您通过JMS spout(喷口)将数据注入到Storm,并通过通用JMS bolt(螺栓)从Storm 消费数据。 JMS Spout(喷口)和Bolt(螺栓)都是数据不可知的。要使用它们,您需要提供一个简单的Java类,用于桥接JMS和Storm API 以及封装和特定域的逻辑

  • 我正在尝试从JMS队列(使用ActiveMQ)读取消息。我面临的问题是,消息正在从队列中读取,但没有显示在“服务激活器”中。 非常感谢您的帮助。 我的代码如下: (1) Spring配置 (2) 服务激活器MDP: (3) 申请开始课程: 谢谢

  • 问题内容: 我有以下代码。但是,文件和是0字节。为什么不工作? 问题答案: 问题出在您的用法上-这是不正确的,并且在实现中掩盖了一个非常重要的异常- 。 问题是您不能使用RSA密钥来加密长度超过密钥大小(示例中为128字节)的数据。您应该对大数据块使用对称加密算法,例如 AES 。 如果您出于某种原因(例如安全传输数据)使用非对称密钥- 您可以在此SO答案中找到一个很好的示例。

  • 我设置了一个EJB项目,使用JMS将持久性实体对象发送到MDB。我使用JBoss EAP 7,使用Apache ActiveMQ作为消息传递提供程序。我像这样设置ConnectionFactory和队列: 这是我的消息生成器,它接收“Account”实体对象作为参数并将其发送到队列: EntityEnqueueBean。Java语言 MDB从队列接收消息并对其进行处理: java账户 不确定我做错

  • 下面是关于Spring Boot服务器存根的生成,使用swagger代码(-l Spring)。 Swagger codegen 二进制文件(当前:v2.3.1)是否有任何选项可以在没有hashCode()和equals()方法的情况下生成dto模型? 我在配置帮助中没有找到任何选项。我希望生成的 dto 模型扩展一个抽象类,其中 hashCode() 和 equals() 方法已经声明,因此不应