message content changed after export and import

[aggiefei]

I try to use this tool to backup rabbitmq queues. However, when I export the queues to the json file and then load the json file back, message content is changed. I tried with rabbitmq 3.7.5 and 3.6.16, both get same result.

python send.py

[s] send 'send message 1'
[s] send 'send message 2'
[s] send 'send message 3'
[s] send 'send message 4'
[s] send 'send message 5'
...

#amqp-tool --host localhost -u guest -p guest -q blue_q1 --export msg.json
#amqp-tool --host localhost -u guest -p guest -q blue_q1 --import msg.json

python receive.py

[*] Waiting for messages. To exit press CTRL+C
[x] Received '{"data":{"type":"Buffer","data":[115,101,110,100,32,109,101,115,115,97,103,101,32,52,52]}}'
[x] Received '{"data":{"type":"Buffer","data":[115,101,110,100,32,109,101,115,115,97,103,101,32,52,53]}}'
[x] Received '{"data":{"type":"Buffer","data":[115,101,110,100,32,109,101,115,115,97,103,101,32,52,54]}}'
[x] Received '{"data":{"type":"Buffer","data":[115,101,110,100,32,109,101,115,115,97,103,101,32,52,55]}}'
[x] Received '{"data":{"type":"Buffer","data":[115,101,110,100,32,109,101,115,115,97,103,101,32,52,56]}}'
[x] Received '{"data":{"type":"Buffer","data":[115,101,110,100,32,109,101,115,115,97,103,101,32,52,57]}}'
[x] Received '{"data":{"type":"Buffer","data":[115,101,110,100,32,109,101,115,115,97,103,101,32,53,48]}}'
...

#cat msg.json
[{"data":{"type":"Buffer","data":[115,101,110,100,32,109,101,115,115,97,103,101,32,49]}},{},{"queue":"blue_q1","deliveryTag":{"type":"Buffer","data":[0,0,0,0,0,0,0,1]},"redelivered":false,"exchange":"blue_direct1","routingKey":"ex1","consumerTag":"node-amqp-28056-0.2706967513320466"}]
[{"data":{"type":"Buffer","data":[115,101,110,100,32,109,101,115,115,97,103,101,32,50]}},{},{"queue":"blue_q1","deliveryTag":{"type":"Buffer","data":[0,0,0,0,0,0,0,2]},"redelivered":false,"exchange":"blue_direct1","routingKey":"ex1","consumerTag":"node-amqp-28056-0.2706967513320466"}]
[{"data":{"type":"Buffer","data":[115,101,110,100,32,109,101,115,115,97,103,101,32,51]}},{},{"queue":"blue_q1","deliveryTag":{"type":"Buffer","data":[0,0,0,0,0,0,0,3]},"redelivered":false,"exchange":"blue_direct1","routingKey":"ex1","consumerTag":"node-amqp-28056-0.2706967513320466"}]

---

Want to back this issue? Post a bounty on it! We accept bounties via Bountysource.

[FGRibreau]

Hello !

It seems you did not specify a Content-type: application/json header inside your AMQP message

[aggiefei]

I sent text messages, so I added content_type as ‘text/plain', but still can't get the right message.
[x] Received '{"data":{"type":"Buffer","data":[115,101,110,100,32,109,101,115,115,97,103,101,32,53]},"contentType":"text/plain"}'

this tool only support json message?

[FGRibreau]

Brcause only json is supported at the time being :) Le lun. 23 juil. 2018 à 11:35, aggiefe <notifications@github.com> a écrit :

I sent text messages, so I added content_type as ‘text/plain', but still can't get the right message. [x] Received '{"data":{"type":"Buffer","data":[115,101,110,100,32,109,101,115,115,97,103,101,32,53]},"contentType":"text/plain"}' this tool only support json message? — You are receiving this because you commented. Reply to this email directly, view it on GitHub <#19 (comment)>, or mute the thread <https://github.com/notifications/unsubscribe-auth/AAIbQvrgL-t0fRTH4XBC65TrtGYcOY22ks5uJZj0gaJpZM4VVmmP> .

-- Sent from my iPhone