diff options
| author | Anton Tananaev <anton.tananaev@gmail.com> | 2023-07-19 22:13:19 -0700 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2023-07-19 22:13:19 -0700 |
| commit | f1470e56708b66c805e63619209930e83116f4ea (patch) | |
| tree | f01e6b4777cbaad4b3464e89076c7e8aaf4ab6db /src/main/java/org/traccar/MainModule.java | |
| parent | 840d5600c69839e9be7a241d69005f322dfef124 (diff) | |
| parent | dacaefcd4e416eeeedf1074729a8670aec1e53fb (diff) | |
| download | trackermap-server-f1470e56708b66c805e63619209930e83116f4ea.tar.gz trackermap-server-f1470e56708b66c805e63619209930e83116f4ea.tar.bz2 trackermap-server-f1470e56708b66c805e63619209930e83116f4ea.zip | |
Merge pull request #5136 from RodolfoSilva/feature/amqp-forwarder
Add AMQP(RabbitMQ) Forwarder
Diffstat (limited to 'src/main/java/org/traccar/MainModule.java')
| -rw-r--r-- | src/main/java/org/traccar/MainModule.java | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/src/main/java/org/traccar/MainModule.java b/src/main/java/org/traccar/MainModule.java index b7bdbc6bf..f5db75846 100644 --- a/src/main/java/org/traccar/MainModule.java +++ b/src/main/java/org/traccar/MainModule.java @@ -37,10 +37,12 @@ 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; @@ -360,6 +362,8 @@ public class MainModule extends AbstractModule { if (config.hasKey(Keys.EVENT_FORWARD_URL)) { String forwardType = config.getString(Keys.EVENT_FORWARD_TYPE); switch (forwardType) { + case "amqp": + return new EventForwarderAmqp(config, objectMapper); case "kafka": return new EventForwarderKafka(config, objectMapper); case "mqtt": @@ -379,6 +383,8 @@ public class MainModule extends AbstractModule { switch (config.getString(Keys.FORWARD_TYPE)) { case "json": return new PositionForwarderJson(config, client, objectMapper); + case "amqp": + return new PositionForwarderAmqp(config, objectMapper); case "kafka": return new PositionForwarderKafka(config, objectMapper); case "redis": |