+ else {
+ readTopic = props.getProperty(UEBPropertiesKeys.TOPIC_READ); //TOPIC_READ = "topic.read"
+ if(readTopic == null) {
+ logger.error("Error reading property '"+ UEBPropertiesKeys.TOPIC_READ + "' defaulting to " + DEFAULT_READ_TOPIC);
+ readTopic = DEFAULT_READ_TOPIC;
+ }
+ writeTopic = props.getProperty(UEBPropertiesKeys.TOPIC_WRITE); //TOPIC_WRITE = "topic.write"
+ if(writeTopic == null) {
+ logger.error("Error reading property '" + UEBPropertiesKeys.TOPIC_READ + "' defaulting to " + DEFAULT_WRITE_TOPIC);
+ writeTopic = DEFAULT_WRITE_TOPIC;
+ }
+ }
+
+ logger.debug("Using topics: Read = '" + readTopic + "' Write = '" + writeTopic + "'");
+