Проверка на новое сообщение

import java.io.IOException;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.logging.Level;
import java.util.logging.Logger;
 
public class Server {
    public static final int PORT = 2510;
    private static final int SLEEP = 100;
    private ServerSocket server;
    
    public Server(){
        try {       
            server = new ServerSocket(PORT);
        } catch (IOException ex) {
            System.out.println("Error " + ex);
        }
    }
    public void go()
    {
        class Listner implements Runnable
        {
            Socket socket;
            public Listner(Socket socket) {
                this.socket = socket;
            }
            private String message;
            private Connection con;
            private Statement st;
            private OutputStream out;
            private OutputStreamWriter writer;
            private PrintWriter pWriter;
            private boolean isNewMessage = false;
            private Thread checkMessage;
            private void newMessage()
            {
                try {
                    Class.forName("com.mysql.jdbc.Driver");
                    con = DriverManager.getConnection("jdbc:mysql://127.0.0.1:2501/chatdb", "root", "");
                    st = con.createStatement();
                    ResultSet rs = st.executeQuery("select * from chat;");
                    rs.beforeFirst();                    
                    long result1 = rs.getTime("time").getTime();
                } catch (ClassNotFoundException | SQLException ex) {
                    Logger.getLogger(Server.class.getName()).log(Level.SEVERE, null, ex);
                }  
            }
            @Override
            public void run() 
            {
                System.out.println("Listner started");
                try {
                    out = socket.getOutputStream();
                    writer = new OutputStreamWriter(out);
                    pWriter = new PrintWriter(writer);
                    Class.forName("com.mysql.jdbc.Driver");
                    con = DriverManager.getConnection("jdbc:mysql://127.0.0.1:2501/chatdb", "root", "");
                    st = con.createStatement();
                    ResultSet rs = st.executeQuery("select * from chat;");
                    rs.beforeFirst();
                    for(int i = 0; i<10; i++)
                    {                        
                        rs.next();                
                        message= rs.getDate("date").toString() + "\t" + rs.getTime("time").toString() + "\n" + rs.getString("message");
                        pWriter.print(message);
                        Thread.sleep(SLEEP);
                    }            
                    message = null;
                    con.close(); 
                    pWriter.close();
                    writer.close();
                    out.close();
                } catch (IOException | InterruptedException e) {
                    System.out.println("Error " + e);
                } catch (ClassNotFoundException | SQLException ex) {
                    Logger.getLogger(Server.class.getName()).log(Level.SEVERE, null, ex);
                }
            }
            
        }
        System.out.println("Server started");
        while(true)
        {
            Socket socket;
            try {
                socket = server.accept();
                Listner listner = new Listner(socket);
                new Thread(listner).start();
            } catch (IOException ex) {
                Logger.getLogger(Server.class.getName()).log(Level.SEVERE, null, ex);
            }            
        }
    }
    public static void main(String[] args) throws IOException {
        Server ser = new Server();
        ser.go();
    }
}