*/
        public void connected(Channel channel) throws IOException
        {
        	//cache the server channel
        	TestExample.this.svrTCPChannel = (TCPChannel) channel;
        	channel.registerForReads(new MyDataListener("server"));
        }