diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_channel.erl | 8 |
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 |