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 index b87a027f7f..d5afa3683b 100644 --- a/symmetric-core/src/main/java/org/jumpmind/symmetric/common/ParameterConstants.java +++ b/symmetric-core/src/main/java/org/jumpmind/symmetric/common/ParameterConstants.java @@ -482,6 +482,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 getParameterMetaData() { return parameterMetaData; diff --git a/symmetric-core/src/main/resources/symmetric-default.properties b/symmetric-core/src/main/resources/symmetric-default.properties index 894aabe367..1d20fba855 100644 --- a/symmetric-core/src/main/resources/symmetric-default.properties +++ b/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= \ No newline at end of file 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 index ca954f85eb..a8994e0807 100644 --- a/symmetric-db/src/main/java/org/jumpmind/db/platform/DatabaseNamesConstants.java +++ b/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"; }