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.java6
1 files changed, 3 insertions, 3 deletions
diff --git a/src/main/java/org/traccar/forward/EventForwarderMqtt.java b/src/main/java/org/traccar/forward/EventForwarderMqtt.java
index 90e8500ea..83df795b1 100644
--- a/src/main/java/org/traccar/forward/EventForwarderMqtt.java
+++ b/src/main/java/org/traccar/forward/EventForwarderMqtt.java
@@ -21,11 +21,11 @@ import org.traccar.helper.MqttUtil;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper;
-import com.hivemq.client.mqtt.mqtt3.Mqtt3AsyncClient;
+import com.hivemq.client.mqtt.mqtt5.Mqtt5AsyncClient;
public class EventForwarderMqtt implements EventForwarder {
- private final Mqtt3AsyncClient client;
+ private final Mqtt5AsyncClient client;
private final ObjectMapper objectMapper;
private final String topic;
@@ -49,4 +49,4 @@ public class EventForwarderMqtt implements EventForwarder {
MqttUtil.publish(client, topic, payload, (message, e) -> resultHandler.onResult(e == null, e));
}
-} \ No newline at end of file
+}