Skip to content

Commit a24b443

Browse files
acogoluegnesmergify[bot]
authored andcommitted
Polish authentication in stream reader
(cherry picked from commit 6c14d73)
1 parent 540c761 commit a24b443

File tree

1 file changed

+1
-4
lines changed

1 file changed

+1
-4
lines changed

deps/rabbitmq_stream/src/rabbit_stream_reader.erl

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -64,6 +64,7 @@
6464
%% client port
6565
peer_port,
6666
auth_mechanism,
67+
authentication_state :: any(),
6768
connected_at :: integer(),
6869
helper_sup :: pid(),
6970
socket :: rabbit_net:socket(),
@@ -75,7 +76,6 @@
7576
stream_leaders :: #{stream() => pid()},
7677
stream_subscriptions :: #{stream() => [subscription_id()]},
7778
credits :: atomics:atomics_ref(),
78-
authentication_state :: any(),
7979
user :: undefined | #user{},
8080
virtual_host :: undefined | binary(),
8181
connection_step ::
@@ -1426,9 +1426,6 @@ handle_frame_pre_auth(Transport,
14261426
{C1#stream_connection{connection_step = failure},
14271427
{sasl_authenticate, ?RESPONSE_SASL_ERROR, <<>>}};
14281428
{challenge, Challenge, AuthState1} ->
1429-
rabbit_core_metrics:auth_attempt_succeeded(Host,
1430-
<<>>,
1431-
stream),
14321429
{C1#stream_connection{authentication_state = AuthState1,
14331430
connection_step = authenticating},
14341431
{sasl_authenticate, ?RESPONSE_SASL_CHALLENGE,

0 commit comments

Comments
 (0)