<div dir="ltr"><pre style="" class="lang-rb prettyprint prettyprinted"><code><span class="pln">The RPC example on the rabbitmq website mentions: delivery_info.consumer.cancel to cancel the subscribe loop.<br><br>In newer versions of Bunny I think this should become <b>channel</b></span><b><span class="pun">.</span><span class="pln">consumers</span><span class="pun">[</span><span class="pln">delivery_info</span><span class="pun">.</span><span class="pln">consumer_tag</span><span class="pun">].</span><span class="pln">cancel</span></b><span class="pln"> ?<br><br>However my ruby rpc client is not behaving as expected: the client hangs and does not return the result.<br><br>The code is over here: https://gist.github.com/anonymous/6334383<br><br>And this is the logging that is generated. The stacktrace is generated once I stop the debug session.<br><br>send_message<br>result from server "{\"exception\":\"java.lang.NullPointerException\\n\\tat com.automatedev.releasequeue.debian.metadata.impl.handler.MetadataReader.getControlContent(MetadataReader.java:70)\\n\\tat com.automatedev.releasequeue.debian.metadata.impl.handler.MetadataReader.getMetadata(MetadataReader.java:32)\\n\\tat com.automatedev.releasequeue.debian.metadata.impl.handler.MetadataHandler.getMetadata(MetadataHandler.java:46)\\n\\tat com.automatedev.releasequeue.debian.metadata.impl.handler.MetadataHandler.handleMessage(MetadataHandler.java:32)\\n\\tat com.automatedev.releasequeue.debian.message.impl.MessageBeanImpl.handleMessage(MessageBeanImpl.java:98)\\n\\tat com.automatedev.releasequeue.debian.message.impl.MessageBeanImpl.receiveAndHandleMessage(MessageBeanImpl.java:78)\\n\\tat com.automatedev.releasequeue.debian.message.impl.MessageBeanImpl$1.run(MessageBeanImpl.java:65)\\n\\tat java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)\\n\\tat java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:334)\\n\\tat java.util.concurrent.FutureTask.run(FutureTask.java:166)\\n\\tat java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110)\\n\\tat java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603)\\n\\tat java.lang.Thread.run(Thread.java:722)\\n\"}"<br>/home/philippe/.rvm/gems/ruby-1.9.3-p286@releasequeue/gems/bunny-0.9.0.pre10/lib/bunny/consumer_work_pool.rb:48:in `join': Interrupt<br>        from /home/philippe/.rvm/gems/ruby-1.9.3-p286@releasequeue/gems/bunny-0.9.0.pre10/lib/bunny/consumer_work_pool.rb:48:in `block in join'<br>        from /home/philippe/.rvm/gems/ruby-1.9.3-p286@releasequeue/gems/bunny-0.9.0.pre10/lib/bunny/consumer_work_pool.rb:48:in `each'<br>        from /home/philippe/.rvm/gems/ruby-1.9.3-p286@releasequeue/gems/bunny-0.9.0.pre10/lib/bunny/consumer_work_pool.rb:48:in `join'<br>        from /home/philippe/.rvm/gems/ruby-1.9.3-p286@releasequeue/gems/bunny-0.9.0.pre10/lib/bunny/queue.rb:187:in `subscribe'<br>        from /home/philippe/projects/releasequeue/script/rpc.rb:18:in `send_message'<br>        from /home/philippe/projects/releasequeue/script/rpc.rb:32:in `&lt;top (required)&gt;'<br>        from -e:1:in `load'<br>        from -e:1:in `&lt;main&gt;'<br><br>Any help is appreciated!<br><br>Philippe<br><br></span></code></pre></div>