diff options
| author | Svetoslav Batchovski <sb@autom8.de> | 2022-12-21 22:51:51 +0100 |
|---|---|---|
| committer | Svetoslav Batchovski <sb@autom8.de> | 2022-12-23 22:11:44 +0100 |
| commit | fdc1997909043b128b358e4404260b3fbff8c289 (patch) | |
| tree | 57ef1d88fe53cd155179d2431748a8f6edf826de /src/main/java/org/traccar/MainModule.java | |
| parent | b9cc31bf3ab278df45fa90f6481f929e325326f0 (diff) | |
| download | trackermap-server-fdc1997909043b128b358e4404260b3fbff8c289.tar.gz trackermap-server-fdc1997909043b128b358e4404260b3fbff8c289.tar.bz2 trackermap-server-fdc1997909043b128b358e4404260b3fbff8c289.zip | |
MQTT EventForwarder added
Diffstat (limited to 'src/main/java/org/traccar/MainModule.java')
| -rw-r--r-- | src/main/java/org/traccar/MainModule.java | 13 |
1 files changed, 9 insertions, 4 deletions
diff --git a/src/main/java/org/traccar/MainModule.java b/src/main/java/org/traccar/MainModule.java index a8f895d3b..55b26010f 100644 --- a/src/main/java/org/traccar/MainModule.java +++ b/src/main/java/org/traccar/MainModule.java @@ -38,6 +38,7 @@ import org.traccar.database.StatisticsManager; import org.traccar.forward.EventForwarder; import org.traccar.forward.EventForwarderJson; import org.traccar.forward.EventForwarderKafka; +import org.traccar.forward.EventForwarderMqtt; import org.traccar.forward.PositionForwarder; import org.traccar.forward.PositionForwarderJson; import org.traccar.forward.PositionForwarderKafka; @@ -322,10 +323,14 @@ public class MainModule extends AbstractModule { @Provides public static EventForwarder provideEventForwarder(Config config, Client client, ObjectMapper objectMapper) { if (config.hasKey(Keys.EVENT_FORWARD_URL)) { - if (config.getString(Keys.EVENT_FORWARD_TYPE).equals("kafka")) { - return new EventForwarderKafka(config, objectMapper); - } else { - return new EventForwarderJson(config, client); + String forwardType = config.getString(Keys.EVENT_FORWARD_TYPE); + switch (forwardType) { + case "kafka": + return new EventForwarderKafka(config, objectMapper); + case "mqtt": + return new EventForwarderMqtt(config, objectMapper); + default: + return new EventForwarderJson(config, client); } } return null; |