diff options
| author | Supriyo <hisupriyooo@gmail.com> | 2024-03-11 13:09:38 +0530 |
|---|---|---|
| committer | Supriyo <hisupriyooo@gmail.com> | 2024-03-11 13:09:38 +0530 |
| commit | 34857cb82abb413100fa4aed668cdca7761e54c4 (patch) | |
| tree | a540f1d79c38cac8e74fd6f5922e8e3d81d6e795 /src/main/java/org/traccar/MainModule.java | |
| parent | 823878d4f797cf2fb8e2c6e3b466b3316613d886 (diff) | |
| download | trackermap-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.java | 14 |
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": |