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":