Skip to content

Commit cc030d6

Browse files
committed
Fix code style
1 parent b2101da commit cc030d6

File tree

1 file changed

+8
-4
lines changed

1 file changed

+8
-4
lines changed

pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ServerCnxTest.java

Lines changed: 8 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -515,7 +515,8 @@ public void testConnectCommandWithPassingOriginalAuthData() throws Exception {
515515

516516
ByteBuf clientCommand = Commands.newConnect(authMethodName, "pass.proxy", 1, null,
517517
null, "client", "pass.client", authMethodName);
518-
BinaryAuthSession binaryAuthSession = spyBinaryAuthSession(authenticationService, clientCommand.copy(), svcConfig);
518+
BinaryAuthSession binaryAuthSession =
519+
spyBinaryAuthSession(authenticationService, clientCommand.copy(), svcConfig);
519520
when(authenticationService.createBinaryAuthSession(any())).thenReturn(binaryAuthSession);
520521
channel.writeInbound(clientCommand);
521522

@@ -641,7 +642,8 @@ public void testConnectWithNonProxyRoleAndProxyVersion() throws Exception {
641642

642643
ByteBuf clientCommand = Commands.newConnect(authMethodName, AuthData.of("pass.pass".getBytes()),
643644
1, null, null, null, null, null, "my-pulsar-proxy", null);
644-
BinaryAuthSession binaryAuthSession = spyBinaryAuthSession(authenticationService, clientCommand.copy(), svcConfig);
645+
BinaryAuthSession binaryAuthSession =
646+
spyBinaryAuthSession(authenticationService, clientCommand.copy(), svcConfig);
645647
when(authenticationService.createBinaryAuthSession(any())).thenReturn(binaryAuthSession);
646648
channel.writeInbound(clientCommand);
647649
Object response = getResponse();
@@ -669,7 +671,8 @@ public void testAuthChallengePrincipalChangeFails() throws Exception {
669671
serverCnx.cancelKeepAliveTask();
670672

671673
ByteBuf clientCommand = Commands.newConnect(authMethodName, "pass.client", "");
672-
BinaryAuthSession binaryAuthSession = spyBinaryAuthSession(authenticationService, clientCommand.copy(), svcConfig);
674+
BinaryAuthSession binaryAuthSession =
675+
spyBinaryAuthSession(authenticationService, clientCommand.copy(), svcConfig);
673676
when(authenticationService.createBinaryAuthSession(any())).thenReturn(binaryAuthSession);
674677

675678
channel.writeInbound(clientCommand);
@@ -728,7 +731,8 @@ public void testAuthChallengeOriginalPrincipalChangeFails() throws Exception {
728731

729732
ByteBuf clientCommand = Commands.newConnect(authMethodName, "pass.proxy", 1, null,
730733
null, "pass.client", "pass.client", authMethodName);
731-
BinaryAuthSession binaryAuthSession = spyBinaryAuthSession(authenticationService, clientCommand.copy(), svcConfig);
734+
BinaryAuthSession binaryAuthSession =
735+
spyBinaryAuthSession(authenticationService, clientCommand.copy(), svcConfig);
732736
when(authenticationService.createBinaryAuthSession(any())).thenReturn(binaryAuthSession);
733737
channel.writeInbound(clientCommand);
734738

0 commit comments

Comments
 (0)