diff options
| author | dcorbacho <dparracorbacho@piotal.io> | 2020-11-09 14:39:36 +0000 |
|---|---|---|
| committer | dcorbacho <dparracorbacho@piotal.io> | 2020-11-09 14:39:36 +0000 |
| commit | 7e1a518f5254a4eef6a5780f06422310d130562f (patch) | |
| tree | 0a4e295ddc563113e1dc1721eec2f42b1d3e79a2 | |
| parent | 2f5adcad55947b4c56b8300681a7d2516056c4b0 (diff) | |
| download | rabbitmq-server-git-stream-credit.tar.gz | |
Fix typesstream-credit
| -rw-r--r-- | src/rabbit_fifo_client.erl | 2 | ||||
| -rw-r--r-- | src/rabbit_queue_type.erl | 2 |
2 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_fifo_client.erl b/src/rabbit_fifo_client.erl index 1262158356..7dc4099c80 100644 --- a/src/rabbit_fifo_client.erl +++ b/src/rabbit_fifo_client.erl @@ -421,7 +421,7 @@ checkout(ConsumerTag, NumUnsettled, CreditMode, Meta, Credit :: non_neg_integer(), Drain :: boolean(), state()) -> - state(). + {state(), actions()}. credit(ConsumerTag, Credit, Drain, #state{consumer_deliveries = CDels} = State0) -> ConsumerId = consumer_id(ConsumerTag), diff --git a/src/rabbit_queue_type.erl b/src/rabbit_queue_type.erl index f404fa321a..b9a601617b 100644 --- a/src/rabbit_queue_type.erl +++ b/src/rabbit_queue_type.erl @@ -473,7 +473,7 @@ settle(QRef, Op, CTag, MsgIds, Ctxs) -spec credit(amqqueue:amqqueue() | queue_ref(), rabbit_types:ctag(), non_neg_integer(), - boolean(), state()) -> state(). + boolean(), state()) -> {ok, state(), actions()}. credit(Q, CTag, Credit, Drain, Ctxs) -> #ctx{state = State0, module = Mod} = Ctx = get_ctx(Q, Ctxs), |