ruby​​のrabbitmqでオブジェクトをシリアライズして逆シリアル化する

Question

オブジェクトをJSONにシリアル化して、rabbitmq経由でワイヤを介して送信し、それをデシリアライズしたいとします。

私は、私は、次のオブジェクトを直列化していていること：他の側では

lead = Lead.new 

lead.company = 'some company' 

operation = proc{ AMQP::Exchange.default.publish(
           lead.to_json, 
           :routing_key => header.reply_to, 
           :correlation_id => header.correlation_id 
          )} 

、私はこのようなオブジェクトdescerialiseしようとしています：

callback_queue.subscribe do |header, body| 
    puts "received #{body.inspect}" 

    lead = ActiveSupport::JSON.decode body 

    puts lead.company #NoMethodError: undefined method `company' for #<Array:0x6fe03f3b> 

JSONをされた不思議な配列の3ハッシュで、このように見えます。

[{\"created_at\":null,\"email\":\"dagda1@scotalt.net\",\"id\":null,\"lead_id\":null,\"updated_at\":null},{\"created_at\":null,\"email\":\"paul.cowan@continuity2.com\",\"id\":null,\"lead_id\":null,\"updated_at\":null}]" 

私が間違っていることは誰でも見ることができますか？

Answer 1

私は同じaproachを多かれ少なかれ使用しており、私の側で正しく動作します。おそらく、間違ったメッセージを送信している可能性があります（シリアル化の問題）。新しいrabbitmqを使用すると、ウサギのWebコンソールでメッセージを検査できます。

前にto_jsonを印刷しようとするとよいでしょう。