aboutsummaryrefslogtreecommitdiff
path: root/src/main/java/org/traccar/config
diff options
context:
space:
mode:
authorRodolfo Silva <contato@rodolfosilva.com>2023-07-13 14:26:34 -0300
committerRodolfo Silva <contato@rodolfosilva.com>2023-07-13 15:05:37 -0300
commitbd64dc0bc759e8325f09686909c25f3a08fbf686 (patch)
tree47c13829b922c022a1ab89dc78449ec22c91b2db /src/main/java/org/traccar/config
parent2be2a4558ace9825a69aecf6329305490eb5fe5e (diff)
downloadtrackermap-server-bd64dc0bc759e8325f09686909c25f3a08fbf686.tar.gz
trackermap-server-bd64dc0bc759e8325f09686909c25f3a08fbf686.tar.bz2
trackermap-server-bd64dc0bc759e8325f09686909c25f3a08fbf686.zip
AMQP Forwarder
Add support to forward events and positions to AMQP (RabbitMQ).
Diffstat (limited to 'src/main/java/org/traccar/config')
-rw-r--r--src/main/java/org/traccar/config/Keys.java20
1 files changed, 18 insertions, 2 deletions
diff --git a/src/main/java/org/traccar/config/Keys.java b/src/main/java/org/traccar/config/Keys.java
index 6f5360c22..314ac0df2 100644
--- a/src/main/java/org/traccar/config/Keys.java
+++ b/src/main/java/org/traccar/config/Keys.java
@@ -837,7 +837,15 @@ public final class Keys {
"url");
/**
- * Position forwarding Kafka topic.
+ * Position forwarding AMQP exchange.
+ */
+ public static final ConfigKey<String> FORWARD_EXCHANGE = new StringConfigKey(
+ "forward.exchange",
+ List.of(KeyType.CONFIG),
+ "traccar");
+
+ /**
+ * Position forwarding Kafka topic or AQMP Routing Key.
*/
public static final ConfigKey<String> FORWARD_TOPIC = new StringConfigKey(
"forward.topic",
@@ -906,7 +914,15 @@ public final class Keys {
"json");
/**
- * Events forwarding Kafka topic.
+ * Events forwarding AMQP exchange.
+ */
+ public static final ConfigKey<String> EVENT_FORWARD_EXCHANGE = new StringConfigKey(
+ "event.forward.exchange",
+ List.of(KeyType.CONFIG),
+ "traccar");
+
+ /**
+ * Events forwarding Kafka topic or AQMP Routing Key.
*/
public static final ConfigKey<String> EVENT_FORWARD_TOPIC = new StringConfigKey(
"event.forward.topic",