diff options
| author | Arnaud Cogoluègnes <acogoluegnes@gmail.com> | 2021-12-03 10:59:45 +0100 |
|---|---|---|
| committer | mergify-bot <noreply@mergify.com> | 2021-12-03 10:12:48 +0000 |
| commit | 3dcb04d82b1400fd103739440ec1cb8d5b05b588 (patch) | |
| tree | eb75c8b0f2f4e6918667bad4ee16f2fc97e935cf | |
| parent | 745cf23ab92bb75543b6aa2c9a9b4b85a302062f (diff) | |
| download | rabbitmq-server-git-3dcb04d82b1400fd103739440ec1cb8d5b05b588.tar.gz | |
Declare variable for better formatting
References #3841
(cherry picked from commit 854efb3e852cf428284430f1bfb938c294d48631)
| -rw-r--r-- | deps/rabbitmq_stream/src/rabbit_stream_reader.erl | 31 |
1 files changed, 13 insertions, 18 deletions
diff --git a/deps/rabbitmq_stream/src/rabbit_stream_reader.erl b/deps/rabbitmq_stream/src/rabbit_stream_reader.erl index feef7dbbba..12d4352603 100644 --- a/deps/rabbitmq_stream/src/rabbit_stream_reader.erl +++ b/deps/rabbitmq_stream/src/rabbit_stream_reader.erl @@ -1802,25 +1802,20 @@ handle_frame_post_auth(Transport, osiris_log:next_offset(Log)]), ConsumerCounters = atomics:new(2, [{signed, false}]), + ConsumerConfiguration = + #consumer_configuration{member_pid = + LocalMemberPid, + subscription_id = + SubscriptionId, + socket = Socket, + stream = Stream, + offset = OffsetSpec, + counters = + ConsumerCounters, + properties = + Properties}, ConsumerState = - #consumer{configuration = - #consumer_configuration{member_pid - = - LocalMemberPid, - subscription_id - = - SubscriptionId, - socket = - Socket, - stream = - Stream, - offset = - OffsetSpec, - counters = - ConsumerCounters, - properties - = - Properties}, + #consumer{configuration = ConsumerConfiguration, log = Log, credit = Credit}, |