[rabbitmq-discuss] Trying to implement RPC between Erlang and Java clients

[Martin Koroudjiev]

Hello,

The Erlang client is acting as a server, waiting for messages and
replying to them. The code is very simple. It is wrapped in a
gen_server. On startup, a Channel is created and then it's kept in the
state for later use. Then I do amqp_channel:subscribe/3. The Java client
sends a message, then declares an anonymous queue and starts waiting on
it. The initial message is handled as expected. I see the Erlang code to
pick the message, do its thing and when it tries to send back a
response, I get this:

=ERROR REPORT==== 1-May-2014::22:31:01 ===
** Generic server harmony_mom terminating
** Last message in was {'$gen_cast',
                           {send,"amq.gen-xbmvAa-yp5Ws_QkNwrFN7g",
                               [<message>],
                               "b60f9f9f-fccd-4a66-aff2-0b2ea60aa0af"}}
** When Server state == [{conn,{<0.134.0>,<0.143.0>}},
                         {queues,["dev.set_credentials","dev.inbound"]},
                        
{mom_config,[{protocol,"amqp"},{host,"localhost"}]}]
** Reason for termination ==
** {noproc,{gen_server,call,[<0.143.0>,{close,200,<<"Goodbye">>},infinity]}}


Thanks in advance,

Martin