diff options
| author | Arnaud Cogoluègnes <acogoluegnes@gmail.com> | 2020-09-01 18:14:07 +0200 |
|---|---|---|
| committer | Arnaud Cogoluègnes <acogoluegnes@gmail.com> | 2020-09-01 18:14:07 +0200 |
| commit | b2f30a55ba87c14c12b3c2a407f7a5ac2594bd8c (patch) | |
| tree | 53e60710762a1fc271b2ef55f6baf0cc1f17e693 | |
| parent | 9a788362ddb0167d40db4d719a989546f3b55b57 (diff) | |
| download | rabbitmq-server-git-b2f30a55ba87c14c12b3c2a407f7a5ac2594bd8c.tar.gz | |
Use byte for sub ID in credit notification
| -rw-r--r-- | deps/rabbitmq_stream/src/rabbit_stream_reader.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/deps/rabbitmq_stream/src/rabbit_stream_reader.erl b/deps/rabbitmq_stream/src/rabbit_stream_reader.erl index 660ba0a8bc..401ea6c193 100644 --- a/deps/rabbitmq_stream/src/rabbit_stream_reader.erl +++ b/deps/rabbitmq_stream/src/rabbit_stream_reader.erl @@ -685,7 +685,7 @@ handle_frame_post_auth(Transport, #stream_connection{socket = S} = Connection, {Connection, State#stream_connection_state{consumers = Consumers#{SubscriptionId => Consumer1}}, Rest}; _ -> rabbit_log:warning("Giving credit to unknown subscription: ~p~n", [SubscriptionId]), - Frame = <<?COMMAND_CREDIT:16, ?VERSION_0:16, ?RESPONSE_CODE_SUBSCRIPTION_ID_DOES_NOT_EXIST:16, SubscriptionId:32>>, + Frame = <<?COMMAND_CREDIT:16, ?VERSION_0:16, ?RESPONSE_CODE_SUBSCRIPTION_ID_DOES_NOT_EXIST:16, SubscriptionId:8>>, FrameSize = byte_size(Frame), Transport:send(S, [<<FrameSize:32>>, Frame]), {Connection, State, Rest} |