c4181/teslamate-mqtt2telegram
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Add camel config #1

Merged
c4181 merged 4 commits from add-camel-config into main 2023-01-05 03:03:37 +00:00
Conversation 1 Commits 4 Files changed 6 +1 -4
1 changed files with 1 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files
Showing only changes of commit 9def9a8d4e - Show all commits

5
src/main/java/com/c4181/camel/CamelConfiguration.java
View file

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