private Collection < String > buildTopicNames ( Response response ) { Collection < String > topicNames = new HashSet <> ( ) ; Collection < String > detectionSystemNames = appSensorServer . getConfiguration ( ) . getRelatedDetectionSystems ( response . getDetectionSystem ( ) ) ; for ( String detectionSystemName : detectionSystemNames ) { topicNames . add ( KafkaUtils . buildResponseTopicName ( detectionSystemName ) ) ; } return topicNames ; }
build the appropriate topic names to send this response to based on related detection systems