0007031: Add support for AWS SQS (load-only endpoint)

symmetric-core/src/main/java/org/jumpmind/symmetric/common/ParameterConstants.java

@@ -481,6 +481,15 @@ private ParameterConstants() {
     public final static String SYNC_USE_READY_QUEUES = "sync.use.ready.queues";
     public final static String KEEP_BULK_STAGING_FILES = "keep.bulk.staging.files";
     public final static String MSSQL_BULK_LOAD_BCP_CODE_PAGE = "mssql.bulk.load.bcp.code.page";
+    public static final String AWSSQS_QUEUE_URL = "awssqs.url.queue";
+    public static final String AWSSQS_QUEUE_BY = "awssqs.queue.by";
+    public static final String AWSSQS_MESSAGE_BY = "awssqs.message.by";
+    public static final String AWSSQS_ACCESS_KEY_ID = "awssqs.access.key.id";
+    public static final String AWSSQS_SECRET_ACCESS_KEY = "awssqs.secret.access.key";
+    public static final String AWSSQS_SESSION_TOKEN = "awssqs.session.token";
+    public static final String AWSSQS_REGION = "awssqs.region";
+    public static final String AWSSQS_FORMAT = "awssqs.format";
+    public static final String AWSSQS_QUEUE_NAME = "awssqs.queue.name";
 
     public static Map<String, ParameterMetaData> getParameterMetaData() {
         return parameterMetaData;

symmetric-core/src/main/resources/symmetric-default.properties

@@ -3234,3 +3234,59 @@ default.values.to.translate=
 # Tags: load
 # Type: boolean
 sync.use.ready.queues=true
+
+# The URL of the AWS queue you want to load data to (optional).
+#
+# DatabaseOverridable: true
+# Tags: awssqs
+awssqs.url.queue=
+
+# The following property determines what queues will be used to load data to. Possible values are
+# { TABLE | CHANNEL | USER }
+# DatabaseOverridable: true
+# Tags: awssqs
+awssqs.queue.by=
+
+# The following property determines how messages will be sent.  Possible values are
+# { BATCH | ROW }
+# DatabaseOverridable: true
+# Tags: awssqs
+awssqs.message.by=
+
+# Your AWS Access Key ID.
+#
+# DatabaseOverridable: true
+# Tags: awssqs
+awssqs.access.key.id=
+
+# Your AWS Secret Access Key.
+#
+# DatabaseOverridable: true
+# Tags: awssqs
+awssqs.secret.access.key=
+
+# Your AWS SQS session token. (optional)
+#
+# DatabaseOverridable: true
+# Tags: awssqs
+awssqs.session.token=
+
+# The AWS region your queue is located in.
+#
+# DatabaseOverridable: true
+# Tags: awssqs
+awssqs.region=
+
+# Specify the output message format.  Possible values are
+# { JSON | XML | CSV }
+# DatabaseOverridable: true
+# Tags: awssqs
+awssqs.format=
+
+# The queue name you wish to configure with SymmetricDS. If you enter
+# a value for this field, it will override the "Queue By" selection.
+# If you leave this field blank, queue(s) will be created based on the "Queue By" field.
+#
+# DatabaseOverridable: true
+# Tags: awssqs
+awssqs.queue.name=

symmetric-db/src/main/java/org/jumpmind/db/platform/DatabaseNamesConstants.java

@@ -79,4 +79,5 @@ private DatabaseNamesConstants() {
     public final static String EXASOL = "exasol";
     public final static String SPARKSQL = "sparksql";
     public final static String DATABRICKS = "databricks";
+    public static final String AWSSQS = "awssqs";
 }