Я использовал Flume для отправки сообщений из HDFS в IBM MQ Queue. Но сейчас мы пытаемся сделать это Нифи. Все работает нормально, кроме формата сообщений. Формат сообщения, которое я получаю в конце очереди, - MQHRF2. Мне нужно изменить его на формат MQSRT. Есть ли способ сделать это в PublishJMS или я должен использовать какой-то другой процессор в Nifi перед PublishJMS, чтобы это произошло?
PublishJMS отправляет заголовки XML с атрибутами сообщения и в конце «сообщение». Мне нужно только отправить сообщение в очередь, а не заголовки. Я думаю, это связано с форматами сообщений, упомянутыми выше, или я ошибаюсь?