diff --git a/src/main/java/com/c4181/camel/CamelConfiguration.java b/src/main/java/com/c4181/camel/CamelConfiguration.java index 8e94f6a..f43ef8b 100644 --- a/src/main/java/com/c4181/camel/CamelConfiguration.java +++ b/src/main/java/com/c4181/camel/CamelConfiguration.java @@ -2,7 +2,6 @@ package com.c4181.camel; import org.apache.camel.Exchange; import org.apache.camel.builder.RouteBuilder; -import org.apache.camel.component.telegram.model.OutgoingTextMessage; import javax.measure.Measure; import javax.measure.quantity.Pressure; @@ -15,9 +14,7 @@ public class CamelConfiguration extends RouteBuilder { public void configure() { from("paho-mqtt5:teslamate/cars/1/update_version?brokerUrl={{sys:BROKER_URL}}").process((exchange -> { String updateVersion = exchange.getIn().getBody(String.class); - OutgoingTextMessage message = new OutgoingTextMessage(); - message.setText(updateVersion); - exchange.getIn().setBody("New Update available. Version: " + message); + exchange.getIn().setBody("New Update available. Version: " + updateVersion); log.info("New Version {} found. Sending to telegram", updateVersion); }))