public int observe(int bytes)
	{
		if (observer != null && bytes != -1)
		{
			totalBytes += bytes;
			observer.bytesRead(totalBytes, clientId);
		}
		log.debug("Total Bytes Read = [" + totalBytes + "]");

		return bytes;
	}