Я хочу отправить 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.