Я использую Java amqp-client: 4.1.0 и RabbitMq server 3.7.6, я использовал для публикации простых текстовых сообщений в Rabbitmq (фактический логический контент полезной нагрузки - XML BTW, некоторые из них даже недействительны).
Проблема заключается в следующем: На портале управления, когда я пытаюсь получить сообщения, я вижу, что некоторые из них являются обычным текстом, как и ожидалось, в то время как другие сообщения кодируются в base64 (и НЕ все сообщения base64 могут быть декодированы) (ПОЧЕМУ !!!).
Нет другого издателя, отправляющего то же самое, поэтому я единственный издатель.
Я использую код ниже:
Channel myChannel = conn.createChannel();
Map<String, Object> props = new HashMap();
props.put("x-max-length-bytes", 90000000l);
myChannel.queueDeclareNoWait("my-queue", false, false, false, props);
myChannel.basicPublish("", "my-queue", new AMQP.BasicProperties.Builder()
.contentType("text/plain")
.contentEncoding("utf-8")
.deliveryMode(1)
.priority(1)
.build()
, msg.getBytes());
Что мне здесь не хватает?