I was using Flume to send messages from HDFS to IBM MQ Queue. But now we are trying Nifi to do so. Everything is working fine except the message format is different. The message format I am getting on the Queue end is in MQHRF2. I need to change it to MQSRT format. Is there a way to do that in PublishJMS or should I use some other processor in Nifi before PublishJMS to make it happen?
PublishJMS is sending the XML headers with message attributes and at the end "the-message". I only need message to be sent to the queue not the headers. I think this is somewhat related to the message formats mentioned above or am I wrong?