Loading kinetic-test/src/test/java/com/seagate/kinetic/example/heartbeat/rest/HeartbeatCollector.java +4 −0 Original line number Diff line number Diff line Loading @@ -61,6 +61,10 @@ public class HeartbeatCollector extends HeartbeatListener { super(); } public HeartbeatCollector(String netInterfaceName) throws IOException { super(netInterfaceName); } @Override public void onMessage(byte[] data) { Loading kinetic-test/src/test/java/com/seagate/kinetic/example/heartbeat/rest/RestHeartbeatService.java +8 −1 Original line number Diff line number Diff line Loading @@ -53,7 +53,14 @@ public class RestHeartbeatService { port = Integer.parseInt(args[0]); } HeartbeatCollector hbc = new HeartbeatCollector(); HeartbeatCollector hbc = null; if (args.length > 1) { hbc = new HeartbeatCollector(args[1]); } else { hbc = new HeartbeatCollector(); } HeartbeatHandler handler = new HeartbeatHandler (hbc); Server server = new Server(port); Loading Loading
kinetic-test/src/test/java/com/seagate/kinetic/example/heartbeat/rest/HeartbeatCollector.java +4 −0 Original line number Diff line number Diff line Loading @@ -61,6 +61,10 @@ public class HeartbeatCollector extends HeartbeatListener { super(); } public HeartbeatCollector(String netInterfaceName) throws IOException { super(netInterfaceName); } @Override public void onMessage(byte[] data) { Loading
kinetic-test/src/test/java/com/seagate/kinetic/example/heartbeat/rest/RestHeartbeatService.java +8 −1 Original line number Diff line number Diff line Loading @@ -53,7 +53,14 @@ public class RestHeartbeatService { port = Integer.parseInt(args[0]); } HeartbeatCollector hbc = new HeartbeatCollector(); HeartbeatCollector hbc = null; if (args.length > 1) { hbc = new HeartbeatCollector(args[1]); } else { hbc = new HeartbeatCollector(); } HeartbeatHandler handler = new HeartbeatHandler (hbc); Server server = new Server(port); Loading