diff options
| author | Anton Tananaev <anton.tananaev@gmail.com> | 2022-12-23 17:35:26 -0800 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-12-23 17:35:26 -0800 |
| commit | 1963e01a6597734636fac22ab859452b8000b623 (patch) | |
| tree | ec06bbbc091cec82a8607f90faf869ed7d367efd /src/main/java/org/traccar/MainModule.java | |
| parent | 81aac9fbdd85db06b4f5162b39edd3c039cc7dec (diff) | |
| parent | fdc1997909043b128b358e4404260b3fbff8c289 (diff) | |
| download | trackermap-server-1963e01a6597734636fac22ab859452b8000b623.tar.gz trackermap-server-1963e01a6597734636fac22ab859452b8000b623.tar.bz2 trackermap-server-1963e01a6597734636fac22ab859452b8000b623.zip | |
Merge pull request #5009 from sveba/feature/mqttForwarder
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 078573a60..55211d109 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; @@ -326,10 +327,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; |