Skip to content

Commit 721113b

Browse files
committed
Return correct frame name
1 parent ae6e0c2 commit 721113b

File tree

3 files changed

+6
-4
lines changed

3 files changed

+6
-4
lines changed

deps/rabbitmq_stream/src/rabbit_stream_manager.erl

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -445,8 +445,8 @@ handle_call({route, RoutingKey, VirtualHost, SuperStream}, _From,
445445
end
446446
catch
447447
exit:Error ->
448-
rabbit_log:error("Error while looking up exchange ~tp, ~tp",
449-
[rabbit_misc:rs(ExchangeName), Error]),
448+
rabbit_log:warning("Error while looking up exchange ~tp, ~tp",
449+
[rabbit_misc:rs(ExchangeName), Error]),
450450
{error, stream_not_found}
451451
end,
452452
{reply, Res, State};

deps/rabbitmq_stream/src/rabbit_stream_reader.erl

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3018,7 +3018,7 @@ handle_frame_post_auth(Transport,
30183018
error ->
30193019
response(Transport,
30203020
Connection,
3021-
delete_stream,
3021+
delete_super_stream,
30223022
CorrelationId,
30233023
?RESPONSE_CODE_ACCESS_REFUSED),
30243024
rabbit_global_counters:increase_protocol_counter(stream,

deps/rabbitmq_stream/src/rabbit_stream_utils.erl

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -339,7 +339,9 @@ command_versions() ->
339339
{heartbeat, ?VERSION_1, ?VERSION_1},
340340
{route, ?VERSION_1, ?VERSION_1},
341341
{partitions, ?VERSION_1, ?VERSION_1},
342-
{stream_stats, ?VERSION_1, ?VERSION_1}].
342+
{stream_stats, ?VERSION_1, ?VERSION_1},
343+
{create_super_stream, ?VERSION_1, ?VERSION_1},
344+
{delete_super_stream, ?VERSION_1, ?VERSION_1}].
343345

344346
filtering_supported() ->
345347
rabbit_feature_flags:is_enabled(stream_filtering).

0 commit comments

Comments
 (0)