Updated to work with new NSQ client API