问题[jms](coding)

我尝试通过 Jolokia JMX 从 Artemis 获取一条消息，但找不到过滤方法JMSMessageID。

代理版本：Red Hat AMQ 7.11.7

我目前最好的尝试是：

https://broker/console/jolokia/exec/org.apache.activemq.artemis:broker=!%22amq-broker!%22,component=addresses,address=!%22ExpiryQueue!%22,subcomponent=queues,routing-type=!%22anycast!%22,queue=!%22ExpiryQueue!%22/browse(java.lang.String)/JMSmessageID=!%2215232235223!%22

它使用参数调用browse(String filter)上的方法，但过滤器不起作用。当我执行此请求时，我只会获取队列的所有消息。QueueControlJMSmessageID="15232235223"

当我省略消息 ID 周围的双引号时，我没有得到任何结果。

我在另一个答案中看到，无法过滤消息头（仅针对属性），这听起来很奇怪。

但是，有没有建议如何通过消息 ID 获取单个消息？谢谢

我们使用 Quarkus Messaging（带有“smallrye-jms”扩展以连接到 IBM MQ）和转换器将以字符串形式接收的消息转换为 Java 对象。

当在“queue_A”中接收到传入消息时，我们必须在以下两个目的地之一中生成消息：

• “queue_A_error”：如果在转换传入消息时遇到问题。此目标中要生成的新消息是有效负载为 JSON 格式的字符串的消息（包含原始有效负载以及遇到的所有错误的列表）。
• “queue_B”：包含以 JSON 序列化的原始对象的消息

我们如何使用 Quarkus Messaging 实现这个错误处理用例？

我需要从 ActiveMQ Artemis 中的 DLQ 中删除没有属性集的消息。

据我了解，JMX 操作removeMessages(string)支持过滤表达式，但我不确定是否可以使用“属性为 NULL”之类的表达式。是吗？

我正在尝试使用 SoapUI 5.7.2 和 Groovy 脚本向 Amazon ActiveMQ 代理发布消息。计算机上安装了 Java 17。

下面是代码：

import org.apache.qpid.jms.JmsConnectionFactory;
import jakarta.jms.Connection;
import jakarta.jms.DeliveryMode;
import jakarta.jms.MessageProducer;
import jakarta.jms.Session;
import jakarta.jms.TextMessage;
import jakarta.jms.Topic;

JmsConnectionFactory factory = new JmsConnectionFactory("amqps://broker-url:5671");
factory.setUsername("username");
factory.setPassword("password");

Connection connection = factory.createConnection();
connection.start();

出现错误：

jakarta.jms.JMSException: 'void org.apache.qpid.proton.engine. Transport.setOutboundFrameSizeLimit(int)' error at Connection connection = factory.createConnection()

添加以下罐子：

• 质子-j-0.34.1.jar
• qpid-jms-client-2.5.0.jar
• jakarta.jms-api-3.1.0.jar

有人可以指导一下这个错误的原因可能是什么以及如何解决这个问题吗？我们还需要通过 url 传递其他参数吗？

我尝试使用javax.jmsMQ 依赖项在 Spring Boot 2.5 中调用 Enterprise MQ。正在成功建立连接。下面是我的pom.xml代码。我正在使用 App ID 凭据连接到我在 UserCredentialsProvider 类中设置的队列。

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-activemq</artifactId>
        </dependency>
        
        <dependency>
            <groupId>com.ibm.mq</groupId>
            <artifactId>com.ibm.mq.allclient</artifactId>
            <version>0.0.0.3</version>
        </dependency>
        
        <dependency>
            <groupId>javax.jms</groupId>
            <artifactId>javax.jms-api</artifactId>
            <version>2.0.1</version>
        </dependency>

代码 -

    @Bean
    public MQQueueConnectionFactory mqQueueConnectionFactory() {
        MQQueueConnectionFactory mqQueueConnectionFactory = new MQQueueConnectionFactory();
        mqQueueConnectionFactory.setHostName(host);
        try {
            mqQueueConnectionFactory.setTransportType(WMQConstants.WMQ_CM_CLIENT);
            mqQueueConnectionFactory.setCCSID(1208);
            mqQueueConnectionFactory.setChannel(channel);
            mqQueueConnectionFactory.setPort(port);
            mqQueueConnectionFactory.setQueueManager(queueManager);            
            
        } catch (Exception e) {
            e.printStackTrace();
        }
        return mqQueueConnectionFactory;
    }

    @Bean
    UserCredentialsConnectionFactoryAdapter userCredentialsConnectionFactoryAdapter(MQQueueConnectionFactory mqQueueConnectionFactory) {
        UserCredentialsConnectionFactoryAdapter userCredentialsConnectionFactoryAdapter = new UserCredentialsConnectionFactoryAdapter();
        userCredentialsConnectionFactoryAdapter.setUsername(username);
        userCredentialsConnectionFactoryAdapter.setPassword(password);
        userCredentialsConnectionFactoryAdapter.setTargetConnectionFactory(mqQueueConnectionFactory);
        return userCredentialsConnectionFactoryAdapter;
    }

    @Bean
    @Primary
    public CachingConnectionFactory cachingConnectionFactory(UserCredentialsConnectionFactoryAdapter userCredentialsConnectionFactoryAdapter) {
        CachingConnectionFactory cachingConnectionFactory = new CachingConnectionFactory();
        cachingConnectionFactory.setTargetConnectionFactory(userCredentialsConnectionFactoryAdapter);
        cachingConnectionFactory.setSessionCacheSize(500);
        cachingConnectionFactory.setReconnectOnException(true);
        return cachingConnectionFactory;
    }

    @Bean
    public PlatformTransactionManager jmsTransactionManager(CachingConnectionFactory cachingConnectionFactory) {
        JmsTransactionManager jmsTransactionManager = new JmsTransactionManager();
        jmsTransactionManager.setConnectionFactory(cachingConnectionFactory);
        return jmsTransactionManager;
    }

    @Bean
    public JmsOperations jmsOperations(CachingConnectionFactory cachingConnectionFactory) throws JMSException {
        JmsTemplate jmsTemplate = new JmsTemplate(cachingConnectionFactory);
        jmsTemplate.setReceiveTimeout(receiveTimeout);
   Connection c = jmsTemplate.getConnectionFactory().createConnection();
   System.out.println(c.getMetaData()); //the connection is established successfully
        return jmsTemplate;
    }

现在，我所做的是尝试迁移到 Spring Boot 3.1.1。我必须更改 POM 中的 MQ 依赖项以代替jakarta包javax。以下是我更新的 POM：

        <dependency>
            <groupId>jakarta.jms</groupId>
            <artifactId>jakarta.jms-api</artifactId>
        </dependency>
        <dependency>
            <groupId>com.ibm.mq</groupId>
            <artifactId>com.ibm.mq.jakarta.client</artifactId>
            <version>9.3.0.0</version>
        </dependency>

我更新了上面的代码以使用 jakarta Connection Factory 而不是 JMS ，但现在我收到 MQRC_NOT_AUTHORIZED(2035) 错误。

我必须执行哪些修改才能使其在带有 com.ibm.mq.jakarta.client.jar 9.3 的 Spring Boot 3.1 中工作？