Mineplex2018-withcommit/Plugins/Mineplex.ServerMonitor/src/mineplex/servermonitor/ServerMonitor.java

package mineplex.servermonitor;

import java.io.BufferedReader;
import java.io.InputStreamReader;

public class ServerMonitor
{
	private static Repository _repository = new Repository();
	
	public static void main (String args[])
	{		
		_repository.initialize();
		
		while (true)
		{
			for (ServerStatusData statusData : _repository.retrieveServerStatuses())
			{
				String key = statusData.Address + " " + statusData.Name;
				
				String cmd = "/home/mineplex/restartServer.sh";
				Process process = null;
				
			    try 
			    {
			    	process = new ProcessBuilder(new String[] {"/bin/sh", "-x", cmd, statusData.Address, statusData.Name}).start();
			    	process.waitFor(); 
		            BufferedReader reader=new BufferedReader(new InputStreamReader(process.getInputStream())); 
		            String line = reader.readLine(); 
		            
		            while(line != null) 
		            { 
			            System.out.println(line);
			            line=reader.readLine(); 
		            } 
			    }
			    catch (Exception e) 
			    {
			    	e.printStackTrace();
			    }
			    finally
			    {
			    	if (process != null)
			    	{
			    		process.destroy();
			    	}
			    }
			    
			    System.out.println("Sent restart command to " + key + "");
			}
			
			try
			{
				Thread.sleep(15000);
			} 
			catch (InterruptedException e)
			{
				e.printStackTrace();
			}
		}
	}
}