ci: format

Author: Alan Scherger

client/src/main/java/io/netifi/proteus/quickstart/client/Main.java

@@ -8,41 +8,37 @@
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
 
-/**
- * Starts the Proteus Quickstart Client
- */
+/** Starts the Proteus Quickstart Client */
 public class Main {
-    private static final Logger logger = LogManager.getLogger(Main.class);
-
-    public static void main(String... args) {
-
-        // Build Netifi Proteus Connection
-        Proteus netifi =
-                Proteus.tcp()
-                        .group("quickstart.clients")                    // Group name of client
-                        .destination("client1")                         // Name of this client instance
-                        .accessKey(9007199254740991L)
-                        .accessToken("kTBDVtfRBO4tHOnZzSyY5ym2kfY=")
-                        .host("localhost")                              // Proteus Broker Host
-                        .port(8001)                                     // Proteus Broker Port
-                        .disableSsl()                                   // Disabled for parity with Javascript Tutorial
-                        .build();
-
-        // Connect to Netifi Proteus Platform
-        ProteusSocket conn = netifi.groupServiceSocket("quickstart.services.helloservices",
-            Tags.empty());
-        
-        // Create Client to Communicate with the HelloService (included example service)
-        HelloServiceClient client = new HelloServiceClient(conn);
-
-        // Create Request to HelloService
-        HelloRequest request = HelloRequest.newBuilder()
-                .setName("World")
-                .build();
-
-        logger.info("Sending 'World' to HelloService...");
-
-        // Call the HelloService
-        logger.info(client.sayHello(request).block());
-    }
+  private static final Logger logger = LogManager.getLogger(Main.class);
+
+  public static void main(String... args) {
+
+    // Build Netifi Proteus Connection
+    Proteus netifi =
+        Proteus.tcp()
+            .group("quickstart.clients") // Group name of client
+            .destination("client1") // Name of this client instance
+            .accessKey(9007199254740991L)
+            .accessToken("kTBDVtfRBO4tHOnZzSyY5ym2kfY=")
+            .host("localhost") // Proteus Broker Host
+            .port(8001) // Proteus Broker Port
+            .disableSsl() // Disabled for parity with Javascript Tutorial
+            .build();
+
+    // Connect to Netifi Proteus Platform
+    ProteusSocket conn =
+        netifi.groupServiceSocket("quickstart.services.helloservices", Tags.empty());
+
+    // Create Client to Communicate with the HelloService (included example service)
+    HelloServiceClient client = new HelloServiceClient(conn);
+
+    // Create Request to HelloService
+    HelloRequest request = HelloRequest.newBuilder().setName("World").build();
+
+    logger.info("Sending 'World' to HelloService...");
+
+    // Call the HelloService
+    logger.info(client.sayHello(request).block());
+  }
 }

service/src/main/java/io/netifi/proteus/quickstart/service/DefaultHelloService.java

@@ -8,23 +8,23 @@
 import org.apache.logging.log4j.Logger;
 import reactor.core.publisher.Mono;
 
-/**
- * Service that returns a hello message.
- */
+/** Service that returns a hello message. */
 public class DefaultHelloService implements HelloService {
-    private static final Logger logger = LogManager.getLogger(DefaultHelloService.class);
+  private static final Logger logger = LogManager.getLogger(DefaultHelloService.class);
 
-    private final String serviceName;
+  private final String serviceName;
 
-    public DefaultHelloService(final String serviceName) {
-        this.serviceName = serviceName;
-    }
+  public DefaultHelloService(final String serviceName) {
+    this.serviceName = serviceName;
+  }
 
-    @Override
-    public Mono<HelloResponse> sayHello(HelloRequest message, ByteBuf metadata) {
-        logger.info("received a message -> {}", message.getName());
-        return Mono.fromCallable(() -> HelloResponse.newBuilder()
+  @Override
+  public Mono<HelloResponse> sayHello(HelloRequest message, ByteBuf metadata) {
+    logger.info("received a message -> {}", message.getName());
+    return Mono.fromCallable(
+        () ->
+            HelloResponse.newBuilder()
                 .setMessage("Hello, " + message.getName() + "! from " + serviceName)
                 .build());
-    }
+  }
 }

service/src/main/java/io/netifi/proteus/quickstart/service/Main.java

@@ -3,7 +3,6 @@
 import io.netifi.proteus.Proteus;
 import io.netifi.proteus.common.tags.Tags;
 import io.netifi.proteus.quickstart.service.protobuf.HelloServiceServer;
-
 import java.util.Optional;
 import java.util.UUID;
 
@@ -22,11 +21,13 @@ public static void main(String... args) throws Exception {
             .accessToken("kTBDVtfRBO4tHOnZzSyY5ym2kfY=")
             .host("localhost") // Proteus Broker Host
             .port(8001) // Proteus Broker Port
-            .disableSsl()                                   // Disabled for parity with Javascript Tutorial
+            .disableSsl() // Disabled for parity with Javascript Tutorial
             .build();
 
     // Add Service to Respond to Requests
-    netifi.addService(new HelloServiceServer(new DefaultHelloService(serviceName), Optional.empty(), Optional.empty()));
+    netifi.addService(
+        new HelloServiceServer(
+            new DefaultHelloService(serviceName), Optional.empty(), Optional.empty()));
 
     // Connect to Netifi Proteus Platform
     netifi.groupServiceSocket("quickstart.services.helloservices", Tags.empty());