writer: refactoring to support async functionality
nsq_to_nsq
use new async methods