Отправить amqp сообщение с заголовками в quarkus - PullRequest
1 голос
/ 03 марта 2020

Я хочу отправить Java (хорошо Kotlin) POJO как JSON в сообщении AMQP на RabbitMQ с использованием Quarkus.

@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.

...