quarkus - 在 quarkus 中发送带有标头的 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)
    }
}

在兔子队列上，消息作为 base64 编码字节流接收。

如何在此处设置标题以将内容类型放入其中？像 TTL 这样的标头设置也可能很有趣。