diff options
| author | Arnaud Cogoluègnes <acogoluegnes@gmail.com> | 2021-12-03 10:59:45 +0100 |
|---|---|---|
| committer | Arnaud Cogoluègnes <acogoluegnes@gmail.com> | 2021-12-03 10:59:45 +0100 |
| commit | 854efb3e852cf428284430f1bfb938c294d48631 (patch) | |
| tree | ce1eefc3e23f44c5ae33bda293b5ae5abf057648 | |
| parent | 81b96325356c403b24b06cf8085f8211659412da (diff) | |
| download | rabbitmq-server-git-rabbitmq-server-3841-stream-consumer-nested-record.tar.gz | |
Declare variable for better formattingrabbitmq-server-3841-stream-consumer-nested-record
References #3841
| -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 e24150c57c..d0cd5111df 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}, |