adding RPC server demo

Author: jkyberneees

src/main/java/samples/rpc/Server.java

@@ -36,15 +36,18 @@ public static void main(String[] args) throws Exception {
         client.on("secure/inbound.gettime", (Object... eventArgs) -> {
             var replyFn = (ReplyFunction) eventArgs[1];
 
-            logger.info("Responding to gettime request...");
-
-            // Send a reply
-            try {
-                var waitFor = replyFn.reply(Map.of("time", new Date()), "ok", false);
-                waitFor.waitForAck().thenAccept(ack -> logger.info("Acknowledgment received."));
-            } catch (Exception e) {
-                logger.log(Level.SEVERE, "Failed to send reply", e);
-            }
+            client.getExecutorService().submit(() -> {
+                logger.info("Responding to gettime request...");
+
+                try {
+                    var response = Map.of("time", new Date());
+                    // Send a reply and wait for acknowledgment
+                    replyFn.reply(response, "ok", false).waitForAck().get();
+                    logger.info("Response delivered!");
+                } catch (Exception e) {
+                    logger.log(Level.SEVERE, "Failed to send reply", e);
+                }
+            });
         });
 
         client.connect();