Merge pull request #36 from apache/nsq-source