while ((len = stream->receive(input, sizeof(input)-1)) > 0 )
 {
                input[len] = NULL;
                //Code Addition by Srini starts here


                //Client declaration
                TCPConnector* connector_client = new TCPConnector();
                printf("ip_client = %stport_client = %stport_client_int = %dn", ip_client.c_str(), port_client.c_str(),atoi(port_client.c_str()));
                TCPStream* stream_client = connector_client->connect(ip_client.c_str(), atoi(port_client.c_str()));

                //Client declaration ends
                if (stream_client)
                {
                        //message = "Is there life on Mars?";
                        //stream_client->send(message.c_str(), message.size());
                        //printf("sent - %sn", message.c_str());

                        stream_client->send(input, sizeof(input));
                        printf("sent - %sn", input);
                        len = stream_client->receive(line, sizeof(line));
                        line[len] = NULL;
                        printf("received - %sn", line);
                        delete stream_client;
                }

                //Code Additon by Srini ends here

                stream->send(line, len);
                printf("thread %lu, echoed '%s' back to the clientn",
                       (long unsigned int)self(), line);
}