0006063: Add support for RabbitMQ

JumpMind · Dec 15, 2023 · ac71960 · ac71960
1 parent bd2f07b
commit ac71960
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 0 deletions.
diff --git a/symmetric-client/src/main/resources/symmetric-modules.properties b/symmetric-client/src/main/resources/symmetric-modules.properties
@@ -36,6 +36,7 @@ ignite=org.apache.ignite:ignite-core:2.12.0
 informix=jdbc.informix:ifxjdbc:1.0, jdbc.informix:ifxlang:1.0
 interbase=jdbc.interbase:interclient:13.2.0
 kafka=org.apache.kafka:kafka-clients:3.1.0, org.lz4:lz4-java:1.8.0, org.xerial.snappy:snappy-java:1.1.8.4, org.apache.avro:avro:1.11.0, org.codehaus.jackson:jackson-mapper-asl:1.9.13, com.thoughtworks.paranamer:paranamer:2.8, org.xerial.snappy:snappy-java:1.1.8.4, org.apache.commons:commons-compress:1.8.1, org.tukaani:xz:1.9, io.confluent:kafka-avro-serializer:7.1.0, io.confluent:kafka-schema-serializer:7.1.0, io.confluent:kafka-schema-registry-client:7.1.0, io.confluent:common-config:7.1.0, io.confluent:common-utils:7.1.0, com.101tec:zkclient:0.11, org.apache.zookeeper:zookeeper:3.8.0, org.jline:jline:3.21.0, io.netty:netty-all:4.1.76.Final, org.codehaus.jackson:jackson-core-asl:1.9.13
+rabbitmq=com.rabbitmq:amqp-client:5.16.0
 mariadb=org.mariadb.jdbc:mariadb-java-client:2.7.5
 mongodb=org.mongodb:mongodb-driver-sync:4.5.1,org.mongodb:mongodb-driver-core:4.5.1,org.mongodb:bson:4.5.1
 nuodb=jdbc.nuodb:nuodb-jdbc:3.3.1
@@ -68,6 +69,7 @@ driver.ignite=org.apache.ignite.IgniteJdbcThinDriver
 driver.informix=com.informix.jdbc.IfxDriver
 driver.interbase=interbase.interclient.Driver
 driver.kafka=org.apache.kafka.clients.producer.KafkaProducer
+driver.rabbitmq=com.rabbitmq.client.ConnectionFactory
 driver.mariadb=org.mariadb.jdbc.Driver
 driver.nuodb=com.nuodb.jdbc.Driver
 driver.opensearch=org.opensearch.client.RestClientBuilder

diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/common/ParameterConstants.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/common/ParameterConstants.java
@@ -440,6 +440,10 @@ private ParameterConstants() {
             KAFKA_TOPIC_BY, KAFKA_CONFLUENT_REGISTRY_URL, KAFKA_AVRO_JAVA_PACKAGE, KAFKACLIENT_SECURITY_PROTOCOL,
             KAFKACLIENT_SSL_KEYSTORE_LOCATION, KAFKACLIENT_SSL_KEYSTORE_PASSWORD, KAFKACLIENT_SSL_TRUSTSTORE_LOCATION,
             KAFKACLIENT_SSL_KEYSTORE_TYPE };
+    public final static String RABBITMQ_FORMAT = "rabbitmq.format";
+    public final static String RABBITMQ_QUEUE_NAME = "rabbitmq.queue.name";
+    public final static String RABBITMQ_MESSAGE_BY = "rabbitmq.message.by";
+    public final static String RABBITMQ_QUEUE_BY = "rabbitmq.queue.by";
     public final static String SNOWFLAKE_STAGING_TYPE = "snowflake.staging.type";
     public final static String SNOWFLAKE_INTERNAL_STAGE_NAME = "snowflake.internal.stage.name";
     public final static String CLOUD_BULK_LOAD_MAX_ROWS_BEFORE_FLUSH = "cloud.bulk.load.max.rows.before.flush";

diff --git a/symmetric-db/src/main/java/org/jumpmind/db/platform/DatabaseNamesConstants.java b/symmetric-db/src/main/java/org/jumpmind/db/platform/DatabaseNamesConstants.java
@@ -61,6 +61,7 @@ private DatabaseNamesConstants() {
     public final static String TERADATA = "teradata";
     public final static String CASSANDRA = "cassandra";
     public final static String KAFKA = "kafka";
+    public final static String RABBITMQ = "rabbitmq";
     public final static String SNOWFLAKE = "snowflake";
     public final static String HBASE = "hbase";
     public final static String BIGQUERY = "bigquery";