@Override
	public void run()
	{
		if (input == null)						//check if we already created the input stream
		{
			try
			{
				input = new DataInputStream(socket.getInputStream());
			} catch (IOException e)
			{
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
		
		while (true)
		{
			try
			{
				if ((buff = input.readUTF()) != null)
				{
					consumer.consume(buff);
				}
			} catch (IOException e)
			{
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
	}