From 372cba10bb23e5e1fc50631c63dfa5ad4da6db20 Mon Sep 17 00:00:00 2001
From: Eric Goebelbecker <egoebelbecker@users.noreply.github.com>
Date: Mon, 5 Feb 2018 19:47:17 -0500
Subject: [PATCH] BAEL-1486 - small changes to JGroups (#3590)

* BAEL-1486 - sample code for JGroups. Fixed a typo in InfluxDB.

* BAEL-1486 - updates for JGroups.
---
 .../baeldung/jgroups/JGroupsMessenger.java    | 24 ++++++-------------
 1 file changed, 7 insertions(+), 17 deletions(-)

diff --git a/jgroups/src/main/java/com/baeldung/jgroups/JGroupsMessenger.java b/jgroups/src/main/java/com/baeldung/jgroups/JGroupsMessenger.java
index 2a8df8a9ab..70eacabf1e 100644
--- a/jgroups/src/main/java/com/baeldung/jgroups/JGroupsMessenger.java
+++ b/jgroups/src/main/java/com/baeldung/jgroups/JGroupsMessenger.java
@@ -100,21 +100,16 @@ public class JGroupsMessenger extends ReceiverAdapter {
             System.out.println("Received initial view:");
             newView.forEach(System.out::println);
         } else {
-
             // Compare to last view
             System.out.println("Received new view.");
 
             List<Address> newMembers = View.newMembers(lastView, newView);
-            if (newMembers.size() > 0) {
-                System.out.println("New members: ");
-                newMembers.forEach(System.out::println);
-            }
+            System.out.println("New members: ");
+            newMembers.forEach(System.out::println);
 
             List<Address> exMembers = View.leftMembers(lastView, newView);
-            if (exMembers.size() > 0) {
-                System.out.println("Exited members:");
-                exMembers.forEach(System.out::println);
-            }
+            System.out.println("Exited members:");
+            exMembers.forEach(System.out::println);
         }
         lastView = newView;
     }
@@ -122,7 +117,7 @@ public class JGroupsMessenger extends ReceiverAdapter {
     /**
      * Loop on console input until we see 'x' to exit
      */
-    private void processInput() {
+    private void processInput() throws Exception {
 
         BufferedReader in = new BufferedReader(new InputStreamReader(System.in));
         while (running) {
@@ -138,13 +133,8 @@ public class JGroupsMessenger extends ReceiverAdapter {
                     running = false;
                     continue;
                 } else if (!destinationName.isEmpty()) {
-                    Optional<Address> optDestination = getAddress(destinationName);
-                    if (optDestination.isPresent()) {
-                        destination = optDestination.get();
-                    } else {
-                        System.out.println("Destination not found, try again.");
-                        continue;
-                    }
+                    destination = getAddress(destinationName)
+                      . orElseThrow(() -> new Exception("Destination not found"));
                 }
 
                 // Accept a string to send