aboutsummaryrefslogtreecommitdiff
path: root/src/main/java/org/traccar/forward/EventForwarderMqtt.java
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/java/org/traccar/forward/EventForwarderMqtt.java')
-rw-r--r--src/main/java/org/traccar/forward/EventForwarderMqtt.java3
1 files changed, 1 insertions, 2 deletions
diff --git a/src/main/java/org/traccar/forward/EventForwarderMqtt.java b/src/main/java/org/traccar/forward/EventForwarderMqtt.java
index 7d1c7dd3c..ea075fc6c 100644
--- a/src/main/java/org/traccar/forward/EventForwarderMqtt.java
+++ b/src/main/java/org/traccar/forward/EventForwarderMqtt.java
@@ -36,9 +36,8 @@ public class EventForwarderMqtt implements EventForwarder {
@Override
public void forward(EventData eventData, ResultHandler resultHandler) {
- String payload;
try {
- payload = objectMapper.writeValueAsString(eventData);
+ String payload = objectMapper.writeValueAsString(eventData);
mqttClient.publish(topic, payload, (message, e) -> resultHandler.onResult(e == null, e));
} catch (JsonProcessingException e) {
resultHandler.onResult(false, e);