ActiveMQ Artemis中已过期的消息

Question

我已经使用Eclipse微配置文件发射器在Quarkus应用程序中创建了一个ActiveMQ Artemis生成器。但是消息会立即过期，并被移到expiryqueue中。我不确定这种行为。请建议如何将消息保存到队列中，以便它仅在指定时间后过期。

我正在使用下面的代码。

        @Inject
        @Channel("my-queue")
        Emitter<String> emitter;

        String message = "my-message";
        OutgoingAmqpMetadata metadata = OutgoingAmqpMetadata.builder()
                    .withExpiryTime(10000L)
                    .withDurable(true)
                    .withMessageId(String.valueOf(message.hashCode()))
                    .build();
       
        emitter.send(Message.of(message, Metadata.of(metadata)));

mp.messaging.outgoing.my-queue.connector=smallrye-amqp

Answer 1

我认为您在With ExpiryTime中设置了错误的值。你把它设置成一个TTL，但我相信这是一个绝对的时间，所以你应该这样做：

OutgoingAmqpMetadata metadata = OutgoingAmqpMetadata.builder()
            .withExpiryTime(System.currentTimeMillis() + 10000L)
            .withDurable(true)
            .withMessageId(String.valueOf(message.hashCode()))
            .build();