writer: refactoring to support async functionality
nsq_to_nsq: proxy a topic from producer(s) to destination nsqd over TCP