root
/
rabbitmq-server
mirror of https://github.com/rabbitmq/rabbitmq-server.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

Declare variable for better formatting 

References #3841
This commit is contained in:
Arnaud Cogoluègnes 2021-12-03 10:59:45 +01:00
parent 81b9632535
commit 854efb3e85
No known key found for this signature in database
GPG Key ID: D5C8C4DFAD43AFA8
1 changed files with 13 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
deps/rabbitmq_stream/src/rabbit_stream_reader.erl vendored
View File

@ -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},