diff options
| -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), |