Remove unnecessaray log
This commit is contained in:
parent
588998bce7
commit
2f6537dc8e
|
@ -73,12 +73,11 @@ class MqttEventListenerProvider(
|
||||||
.withRetained(mqttOptions.retained)
|
.withRetained(mqttOptions.retained)
|
||||||
val future = Source.single(msg).runWith(mqttSink)
|
val future = Source.single(msg).runWith(mqttSink)
|
||||||
future.onComplete {
|
future.onComplete {
|
||||||
case Success(value) =>
|
|
||||||
logger.log(logging.Level.INFO, value.toString())
|
|
||||||
case Failure(exception) =>
|
case Failure(exception) =>
|
||||||
logger.log(
|
logger.log(
|
||||||
logging.Level.SEVERE,
|
logging.Level.SEVERE,
|
||||||
s"Failed to publish message: ${exception.getMessage()}"
|
s"Failed to publish message: ${exception.getMessage()}"
|
||||||
)
|
)
|
||||||
|
case Success(_) => {}
|
||||||
}
|
}
|
||||||
end MqttEventListenerProvider
|
end MqttEventListenerProvider
|
||||||
|
|
Loading…
Reference in a new issue