@Override
	public void messageReceived(IoSession session, Object message) throws Exception {
		String text = UTFCoder.decode(message);
		synchronized(message){
			String[] instructions = text.split(Constant.END_MSG);
			int start=0, end=instructions.length;

			if(!text.endsWith(Constant.END_MSG)){
				end = instructions.length-1;
				incomplete = incomplete + instructions[end];
			}else if(incomplete.length()>0){
				start=1;
				replicas.add(incomplete+instructions[0]);
				incomplete="";
			}

			for(int i=start; i<end;i++)
				replicas.add(instructions[i]);
		}
	}