Merge pull request #297 from Crabzmatic/accumulated-consumers

Don't call BasicConsume inside Call method #296

Author: michaelklishin

dotnet/RPCClient/RPCClient.cs

@@ -34,6 +34,11 @@ public RpcClient()
             var response = Encoding.UTF8.GetString(body);
             tcs.TrySetResult(response);
         };
+
+        channel.BasicConsume(
+          consumer: consumer,
+          queue: replyQueueName,
+          autoAck: true);
     }
 
     public Task<string> CallAsync(string message, CancellationToken cancellationToken = default(CancellationToken))
@@ -52,11 +57,6 @@ public RpcClient()
           basicProperties: props,
           body: messageBytes);
 
-      channel.BasicConsume(
-          consumer: consumer,
-          queue: replyQueueName,
-          autoAck: true);
-
       cancellationToken.Register(() => callbackMapper.TryRemove(correlationId, out var tmp));
       return tcs.Task;
     }