не проходит последний пункт

package com.javarush.task.task30.task3008; import java.net.*; import java.io.*; import java.util.concurrent.*; import java.util.*; public class Server{ private static Map<String, Connection>connectionMap=new ConcurrentHashMap(); public static void sendBroadcastMessage(Message message){ for(Map.Entry<String, Connection> en:connectionMap.entrySet()){ Connection con = en.getValue(); try{ con.send(message); }catch(IOException e){ ConsoleHelper.writeMessage("could not send a message"); } } } private static class Handler extends Thread{ private Socket socket; public void run(){ ConsoleHelper.writeMessage("socketaddress"+socket.getRemoteSocketAddress()); Connection con=new Connection(socket); //SocketAddress ad=con.getRemoteSocketAddress(); //ConsoleHelper.writeMessage("socketaddress"+ad); //System.out.println("socketaddress"+ad); String newClient=""; try{ newClient=serverHandshake(con); }catch(ClassNotFoundException ee){ConsoleHelper.writeMessage("io er"); }catch( IOException e){ ConsoleHelper.writeMessage("io er"); }finally{ try{ con.close(); }catch(IOException e){ConsoleHelper.writeMessage("class n");} } if(newClient==null || newClient.isEmpty())return; if(!newClient.isEmpty())sendBroadcastMessage(new Message(MessageType.USER_ADDED,newClient)); try{ notifyUsers(con,newClient); serverMainLoop(con,newClient); }catch(ClassNotFoundException e){ ConsoleHelper.writeMessage("io error in run"+newClient); } catch(IOException ee){ ConsoleHelper.writeMessage("class not found ex in run"+newClient); } finally{ try{ con.close(); }catch(IOException e){ConsoleHelper.writeMessage("class n");} } if(newClient!=null && !newClient.isEmpty()){ try{ connectionMap.remove(newClient); }catch(Exception e){ConsoleHelper.writeMessage("class not found ex in run"+newClient);} sendBroadcastMessage(new Message(MessageType.USER_REMOVED,newClient)); } ConsoleHelper.writeMessage("disconnected with "+newClient); } private void serverMainLoop(Connection connection,String userName)throws IOException,ClassNotFoundException{ int count=0; while(true){ //if(count>15)break;else count++; Message mes=connection.receive(); Message newmes=null; if(mes.getType()==MessageType.TEXT){ String text=userName+": "+mes.getData(); newmes=new Message(MessageType.TEXT,text); sendBroadcastMessage(newmes); }else ConsoleHelper.writeMessage("servermain received message in not TEXT"); } } private void notifyUsers(Connection connection,String userName)throws IOException{ for(Map.Entry<String,Connection> co:connectionMap.entrySet()){ String clientname=co.getKey(); if(clientname.equalsIgnoreCase(userName))continue; Message mes=new Message(MessageType.USER_ADDED,clientname); connection.send(mes); } } private String serverHandshake(Connection connection)throws IOException,ClassNotFoundException{ int count=0; String name=""; while(true){ if(count>15){break;} count++; connection.send(new Message(MessageType.NAME_REQUEST)); Message mes=connection.receive(); if(mes.getType()==MessageType.USER_NAME){ name=mes.getData(); } if(name.isEmpty()){continue;} if(!name.isEmpty()){ //for(Map.Entry<String,Connection> en:connectionMap.entrySet()){ if(!connectionMap.containsKey(name)){ connectionMap.put(name,connection); }else continue; connection.send(new Message(MessageType.NAME_ACCEPTED)); return name; } }//true return ""; } public Handler(Socket socket){ this.socket=socket; } } public static void main(String[]args)throws IOException{ //ConsoleHelper ch=new ConsoleHelper(); int port=ConsoleHelper.readInt(); ServerSocket sersock=null; //try{//}(ServerSocket sersock2=new ServerSocket(port)){ sersock=new ServerSocket(port); //}catch(IOException e){} ConsoleHelper.writeMessage("server is running"); Socket so=null; try{int loop=0; while(loop<20){ loop++; so=sersock.accept(); Handler h=new Handler(so); h.start(); } }catch(IOException e){} finally{ if(so!=null){ //try{ so.close(); //}catch(IOException e){} }sersock.close(); } } }