Refactored to use topics support in natty