diff options
Diffstat (limited to 'hv-collector-utils/src/main')
2 files changed, 39 insertions, 0 deletions
diff --git a/hv-collector-utils/src/main/kotlin/org/onap/dcae/collectors/veshv/utils/commandline/CommandLineOption.kt b/hv-collector-utils/src/main/kotlin/org/onap/dcae/collectors/veshv/utils/commandline/CommandLineOption.kt index d36f194d..9d1f7aa8 100644 --- a/hv-collector-utils/src/main/kotlin/org/onap/dcae/collectors/veshv/utils/commandline/CommandLineOption.kt +++ b/hv-collector-utils/src/main/kotlin/org/onap/dcae/collectors/veshv/utils/commandline/CommandLineOption.kt @@ -55,6 +55,20 @@ enum class CommandLineOption(val option: Option) { .desc("Amount of messages to send") .build() ), + KAFKA_SERVERS(Option.builder("s") + .longOpt("kafka-bootstrap-servers") + .required() + .hasArg() + .desc("Comma-separated Kafka bootstrap servers in <host>:<port> format") + .build() + ), + KAFKA_TOPICS(Option.builder("f") + .longOpt("kafka-topics") + .required() + .hasArg() + .desc("Comma-separated Kafka topics") + .build() + ), PRIVATE_KEY_FILE(Option.builder("k") .longOpt("private-key-file") .hasArg() diff --git a/hv-collector-utils/src/main/kotlin/org/onap/dcae/collectors/veshv/utils/logging/Logger.kt b/hv-collector-utils/src/main/kotlin/org/onap/dcae/collectors/veshv/utils/logging/Logger.kt index 314c9bf9..19bfa126 100644 --- a/hv-collector-utils/src/main/kotlin/org/onap/dcae/collectors/veshv/utils/logging/Logger.kt +++ b/hv-collector-utils/src/main/kotlin/org/onap/dcae/collectors/veshv/utils/logging/Logger.kt @@ -107,4 +107,29 @@ class Logger(val logger: org.slf4j.Logger) { logger.warn(messageProvider(), ex) } } + + + // + // ERROR + // + + fun error(message: String) { + logger.error(message) + } + + fun error(message: String, ex: Exception) { + logger.error(message, ex) + } + + fun error(messageProvider: () -> String) { + if (logger.isErrorEnabled) { + logger.error(messageProvider()) + } + } + + fun error(ex: Exception, messageProvider: () -> String) { + if (logger.isErrorEnabled) { + logger.error(messageProvider(), ex) + } + } } |