3

我们计划使用 Solace Queue Management。用例之一是，在消费者收到消息后，如果在处理消息时出现任何异常，应该自动重新传递消息。

截至目前，我没有向队列发送确认消息，因此消息不会从队列中删除，但不幸的是它无法自动重新传递。如果我重新启动会话，那么只有我能够收到相同的消息。

我已经探索了几个选项。session.rollback 或 session.revoke 异常，但它会增加队列中所有消息的传递计数。此外，没有任何延迟时间配置来重新传递相同的消息。

期望是，相同的消息应该在 30 分钟（配置的延迟）后自动重新传递。

以下是我用于消费者的示例代码：

https://github.com/SolaceSamples/solace-samples-jms/blob/master/src/main/java/com/solace/samples/QueueConsumer.java

@Override
public void onMessage(Message message) {
    try {
        if (message instanceof TextMessage) {
            System.out.printf("TextMessage received: '%s'%n", ((TextMessage) message).getText());
        } else {
            System.out.println("Message received.");
        }
        System.out.printf("Message Content:%n%s%n", SolJmsUtility.dumpMessage(message));

        // ACK the received message manually because of the set SupportedProperty.SOL_CLIENT_ACKNOWLEDGE above
        message.acknowledge();

        latch.countDown(); // unblock the main thread
    } catch (JMSException ex) {
        System.out.println("Error processing incoming message.");
        ex.printStackTrace();
    }
}

感谢您的支持。谢谢

4

1 回答 1

1

Solace 目前不支持此类功能。消息不会在应用层重新传递。仅当重新建立连接（准确地说是流）时，才会重新传递它们。

Solace 确实在传输级别重新传递消息。这样做的目的是确保将消息传递到应用程序缓冲区。从那时起，它的应用程序负责处理它们并确认。超过该点重新传递将导致在消费者端重复消息——这将违反包括 JMS 在内的多个协议。

当应用程序流重新建立时，任何未确认的消息都可以安全地重新传递，因为我们知道它被传递到的原始流不能再确认​​消息（并导致潜在的重复消息传递）。

于 2021-10-28T18:34:09.027 回答