Format

rabbitmq · May 29, 2024 · fd4dec6 · fd4dec6
1 parent 42d0a18
commit fd4dec6
Show file tree

Hide file tree

Showing 2 changed files with 21 additions and 15 deletions.
diff --git a/src/main/java/com/rabbitmq/perf/PerfTest.java b/src/main/java/com/rabbitmq/perf/PerfTest.java
@@ -1357,8 +1357,10 @@ static Options getOptions() {
             false,
             "Same as --verbose, but with message headers and body as well. Use only with slow rates."));
 
-    options.addOption(new Option("tsbs", "tcp-send-buffer-size", true, "value for TCP SO_SNDBUF option"));
-    options.addOption(new Option("trbs", "tcp-receive-buffer-size", true, "value for TCP SO_RCVBUF option"));
+    options.addOption(
+        new Option("tsbs", "tcp-send-buffer-size", true, "value for TCP SO_SNDBUF option"));
+    options.addOption(
+        new Option("trbs", "tcp-receive-buffer-size", true, "value for TCP SO_RCVBUF option"));
     return options;
   }
 

diff --git a/src/main/java/com/rabbitmq/perf/Utils.java b/src/main/java/com/rabbitmq/perf/Utils.java
@@ -141,18 +141,21 @@ static SocketConfigurator socketConfigurator(CommandLineProxy cmd) {
     SocketConfigurator socketConfigurator = SocketConfigurators.defaultConfigurator();
     List<SNIServerName> serverNames = sniServerNames(strArg(cmd, "sni", null));
     if (!serverNames.isEmpty()) {
-      socketConfigurator = socketConfigurator.andThen(socket -> {
-        if (socket instanceof SSLSocket) {
-          SSLSocket sslSocket = (SSLSocket) socket;
-          SSLParameters sslParameters =
-              sslSocket.getSSLParameters() == null
-                  ? new SSLParameters()
-                  : sslSocket.getSSLParameters();
-          sslParameters.setServerNames(serverNames);
-          sslSocket.setSSLParameters(sslParameters);
-        } else {
-          LOGGER.warn("SNI parameter set on a non-TLS connection");
-        }});
+      socketConfigurator =
+          socketConfigurator.andThen(
+              socket -> {
+                if (socket instanceof SSLSocket) {
+                  SSLSocket sslSocket = (SSLSocket) socket;
+                  SSLParameters sslParameters =
+                      sslSocket.getSSLParameters() == null
+                          ? new SSLParameters()
+                          : sslSocket.getSSLParameters();
+                  sslParameters.setServerNames(serverNames);
+                  sslSocket.setSSLParameters(sslParameters);
+                } else {
+                  LOGGER.warn("SNI parameter set on a non-TLS connection");
+                }
+              });
     }
     int sendBufferSize = intArg(cmd, "tsbs", -1);
     int receiveBufferSize = intArg(cmd, "trbs", -1);
@@ -172,7 +175,8 @@ static SocketConfigurator socketConfigurator(CommandLineProxy cmd) {
   static SocketChannelConfigurator socketChannelConfigurator(CommandLineProxy cmd) {
     int sendBufferSize = intArg(cmd, "tsbs", -1);
     int receiveBufferSize = intArg(cmd, "trbs", -1);
-    return SocketChannelConfigurators.defaultConfigurator().andThen(
+    return SocketChannelConfigurators.defaultConfigurator()
+        .andThen(
             socketChannel -> {
               if (sendBufferSize > 0) {
                 socketChannel.socket().setSendBufferSize(sendBufferSize);