quarkus - 在 quarkus 中发送带有 header 的 amqp 消息

Question

我想使用 Quarkus 在 AMQP 消息中将 Java(以及 Kotlin)POJO 作为 JSON 发送到 RabbitMQ。

@Path("/amqp")
class TestSource {

    @Inject
    @Channel("amqpwrite")
    lateinit var emitter: Emitter<MonitoringStatusDto>

    @POST
    @Path("/send")
    fun sendMsg() {
        val status = MonitoringStatusDto(status = "OK", message = "test amqp write")
        emitter.send(status)
    }
}

在 rabbit 队列上，消息以 base64 编码字节流的形式接收。

如何在这里设置标题以将内容类型放入其中？TTL 等 header 设置也可能很有趣。

Answer 1

您可以向发射器添加元数据:

emitter.send(Message.of(recordToPublish,
        () -> {
          // Called when the message is acked
          return CompletableFuture.completedFuture(null);
        },
        e -> {
          // Called when the message is nacked
          throw new RuntimeException(errorMessage, e);
        }).addMetadata(OutgoingKafkaRecordMetadata.<String>builder()
            .withHeaders(new RecordHeaders().add("my-header", "value".getBytes()))
            .build()));

我遇到了同样的问题，我找到了这个指南:https://quarkus.io/guides/kafka#sending-messages-to-kafka