aboutsummaryrefslogtreecommitdiff
path: root/src/main/java/org/traccar/MainModule.java
diff options
context:
space:
mode:
authorSupriyo <hisupriyooo@gmail.com>2024-03-11 13:09:38 +0530
committerSupriyo <hisupriyooo@gmail.com>2024-03-11 13:09:38 +0530
commit34857cb82abb413100fa4aed668cdca7761e54c4 (patch)
treea540f1d79c38cac8e74fd6f5922e8e3d81d6e795 /src/main/java/org/traccar/MainModule.java
parent823878d4f797cf2fb8e2c6e3b466b3316613d886 (diff)
downloadtrackermap-server-34857cb82abb413100fa4aed668cdca7761e54c4.tar.gz
trackermap-server-34857cb82abb413100fa4aed668cdca7761e54c4.tar.bz2
trackermap-server-34857cb82abb413100fa4aed668cdca7761e54c4.zip
feat: add configuration for event forwarding with mqtt
Diffstat (limited to 'src/main/java/org/traccar/MainModule.java')
-rw-r--r--src/main/java/org/traccar/MainModule.java14
1 files changed, 3 insertions, 11 deletions
diff --git a/src/main/java/org/traccar/MainModule.java b/src/main/java/org/traccar/MainModule.java
index 3fec4d1e6..c3c3586be 100644
--- a/src/main/java/org/traccar/MainModule.java
+++ b/src/main/java/org/traccar/MainModule.java
@@ -35,17 +35,7 @@ import org.traccar.config.Keys;
import org.traccar.database.LdapProvider;
import org.traccar.database.OpenIdProvider;
import org.traccar.database.StatisticsManager;
-import org.traccar.forward.EventForwarder;
-import org.traccar.forward.EventForwarderJson;
-import org.traccar.forward.EventForwarderAmqp;
-import org.traccar.forward.EventForwarderKafka;
-import org.traccar.forward.EventForwarderMqtt;
-import org.traccar.forward.PositionForwarder;
-import org.traccar.forward.PositionForwarderJson;
-import org.traccar.forward.PositionForwarderAmqp;
-import org.traccar.forward.PositionForwarderKafka;
-import org.traccar.forward.PositionForwarderRedis;
-import org.traccar.forward.PositionForwarderUrl;
+import org.traccar.forward.*;
import org.traccar.geocoder.AddressFormat;
import org.traccar.geocoder.BanGeocoder;
import org.traccar.geocoder.BingMapsGeocoder;
@@ -386,6 +376,8 @@ public class MainModule extends AbstractModule {
return new PositionForwarderAmqp(config, objectMapper);
case "kafka":
return new PositionForwarderKafka(config, objectMapper);
+ case "mqtt":
+ return new PositionForwarderMqtt(config, objectMapper);
case "redis":
return new PositionForwarderRedis(config, objectMapper);
case "url":