System.out.println(message_string);  ServerMessage	message = ServerMessage.parse(message_string); if (message.isResponse()) { fireReceivedResponse(message); } if (message.isCommand()) { fireReceivedCommand(message); }
fireServerMessageEvents(ServerMessage.parse(message_string));
    public void run()    {		while (mConnected)		{			try			{				if (mInput != null)				{					String message_string = mInput.readLine();										// check if a message has been received, if this is not the case,					// the connection has been terminated and the stream also					// try to reconnect until this succeeds					if (null == message_string)					{						handleTerminatedStream(null);						return;					}					// handle the received message					else					{						System.out.println(message_string);												ServerMessage	message = ServerMessage.parse(message_string);						if (message.isResponse())						{							fireReceivedResponse(message);						}						if (message.isCommand())						{							fireReceivedCommand(message);						}					}				}			}			catch (IOException e)			{				handleTerminatedStream(e);				return;			}						mServerThread.yield();		}				mServerThread = null;	}