CollectorFactory may return null when atomic reference does not yet contain definition. Use collector::getOption instead of collector::get so it's explicit. In case of None reject all connections. Test it where appropriate - maybe define another task for writing CSIT test case for it?