diff --git a/src/main/scala/net/dergrimm/keycloak/providers/events/mqtt/MqttEventListenerProvider.scala b/src/main/scala/net/dergrimm/keycloak/providers/events/mqtt/MqttEventListenerProvider.scala index 0104cf4..58d41ee 100644 --- a/src/main/scala/net/dergrimm/keycloak/providers/events/mqtt/MqttEventListenerProvider.scala +++ b/src/main/scala/net/dergrimm/keycloak/providers/events/mqtt/MqttEventListenerProvider.scala @@ -73,12 +73,11 @@ class MqttEventListenerProvider( .withRetained(mqttOptions.retained) val future = Source.single(msg).runWith(mqttSink) future.onComplete { - case Success(value) => - logger.log(logging.Level.INFO, value.toString()) case Failure(exception) => logger.log( logging.Level.SEVERE, s"Failed to publish message: ${exception.getMessage()}" ) + case Success(_) => {} } end MqttEventListenerProvider