diff options
| author | dcorbacho <dparracorbacho@piotal.io> | 2021-05-11 12:27:37 +0200 |
|---|---|---|
| committer | dcorbacho <dparracorbacho@piotal.io> | 2021-05-11 12:27:37 +0200 |
| commit | 5a5042521d78644fc84be5e2f127c5479aa4fe62 (patch) | |
| tree | edcb88d2a1d75d5aec74b9c4dc117184aa07ee8f | |
| parent | 464bf69cc410aa2b1046fbd3200e032ba717eee9 (diff) | |
| download | rabbitmq-server-git-relative-time-offset.tar.gz | |
Rename variablerelative-time-offset
| -rw-r--r-- | deps/rabbit/src/rabbit_stream_queue.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/deps/rabbit/src/rabbit_stream_queue.erl b/deps/rabbit/src/rabbit_stream_queue.erl index 7f8a0a5ec2..85fc1539c8 100644 --- a/deps/rabbit/src/rabbit_stream_queue.erl +++ b/deps/rabbit/src/rabbit_stream_queue.erl @@ -185,7 +185,7 @@ consume(Q, Spec, QState0) when ?amqqueue_is_stream(Q) -> case parse_offset(rabbit_misc:table_lookup(Args, <<"x-stream-offset">>)) of {error, _} = Err -> Err; - Offset -> + OffsetSpec -> rabbit_core_metrics:consumer_created(ChPid, ConsumerTag, ExclusiveConsume, not NoAck, QName, ConsumerPrefetchCount, false, @@ -194,7 +194,7 @@ consume(Q, Spec, QState0) when ?amqqueue_is_stream(Q) -> %% really it should be sent by the stream queue process like classic queues %% do maybe_send_reply(ChPid, OkMsg), - begin_stream(QState0, Q, ConsumerTag, Offset, ConsumerPrefetchCount) + begin_stream(QState0, Q, ConsumerTag, OffsetSpec, ConsumerPrefetchCount) end; Err -> Err |