Change mind again on how this should work - have a synchronous reply method, and an async method for spontaneous notification.

1 files changed, 4 insertions, 4 deletions

diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl
index c4b9daf73f..139dfd478c 100644
--- a/src/rabbit_channel.erl
+++ b/src/rabbit_channel.erl
@@ -1058,10 +1058,10 @@ handle_method(#'basic.credit'{consumer_tag = CTag, credit = Credit,
             stopped -> unlimit_queues(State)
         end,
     State1 = State#ch{limiter_pid = LimiterPid2},
-    return_ok(State1, false, #'basic.credit_state'{consumer_tag = CTag,
-                                                   credit = Credit,
-                                                   available = Available,
-                                                   drain = Drain});
+    return_ok(State1, false, #'basic.credit_ok'{consumer_tag = CTag,
+                                                credit = Credit,
+                                                available = Available,
+                                                drain = Drain});
 
     %% TODO port this bit ?
     %% case consumer_queues(Consumers) of