Rename this thing for consistency and also RabbitMQ-specificness.

Author: Simon MacMullen

src/com/rabbitmq/client/RpcClient.java

@@ -152,7 +152,7 @@ public void handleDelivery(String consumerTag,
                 }
             }
         };
-        _channel.basicConsume("amq.reply-to", true, consumer);
+        _channel.basicConsume("amq.rabbitmq.reply-to", true, consumer);
         return consumer;
     }
 
@@ -171,7 +171,7 @@ public byte[] primitiveCall(AMQP.BasicProperties props, byte[] message)
             _correlationId++;
             String replyId = "" + _correlationId;
             props = ((props==null) ? new AMQP.BasicProperties.Builder() : props.builder())
-                    .correlationId(replyId).replyTo("amq.reply-consumer").build();
+                    .correlationId(replyId).replyTo("amq.rabbitmq.reply-to").build();
             _continuationMap.put(replyId, k);
         }
         publish(props, message);