Merge pull request #117 from monosoul/updated-tutorial-six-java

Added back forgotten correlation id check

Author: michaelklishin

java/RPCClient.java

@@ -44,7 +44,9 @@ public String call(String message) throws IOException, InterruptedException {
     channel.basicConsume(replyQueueName, true, new DefaultConsumer(channel) {
       @Override
       public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {
-        response.offer(new String(body, "UTF-8"));
+        if (properties.getCorrelationId().equals(corrId)) {
+          response.offer(new String(body, "UTF-8"));
+        }
       }
     });