This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
The following commit(s) were added to refs/heads/main by this push:
new cd4ee06 [create-pull-request] automated change
cd4ee06 is described below
commit cd4ee06146f5da614d7c78832a480e28df3e9753
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Wed May 19 04:24:07 2021 +0000
[create-pull-request] automated change
---
.../connectors/camel-azure-cosmosdb-sink.json | 4 +-
.../connectors/camel-azure-cosmosdb-source.json | 4 +-
.../connectors/camel-salesforce-sink.json | 53 +++++++++++++++++++++-
.../resources/connectors/camel-smpp-sink.json | 28 ++++++++++++
.../resources/connectors/camel-smpp-source.json | 28 ++++++++++++
.../resources/connectors/camel-smpps-sink.json | 28 ++++++++++++
.../resources/connectors/camel-smpps-source.json | 28 ++++++++++++
.../resources/camel-azure-cosmosdb-sink.json | 4 +-
.../resources/camel-azure-cosmosdb-source.json | 4 +-
.../camel-azure-cosmosdb-kafka-sink-connector.adoc | 6 +--
...amel-azure-cosmosdb-kafka-source-connector.adoc | 6 +--
.../generated/resources/camel-salesforce-sink.json | 53 +++++++++++++++++++++-
.../camel-salesforce-kafka-sink-connector.adoc | 12 ++++-
.../CamelSalesforceSinkConnectorConfig.java | 34 +++++++++++++-
.../src/generated/resources/camel-smpp-sink.json | 28 ++++++++++++
.../src/generated/resources/camel-smpp-source.json | 28 ++++++++++++
.../main/docs/camel-smpp-kafka-sink-connector.adoc | 6 ++-
.../docs/camel-smpp-kafka-source-connector.adoc | 6 ++-
.../smpp/CamelSmppSinkConnectorConfig.java | 16 +++++++
.../smpp/CamelSmppSourceConnectorConfig.java | 16 +++++++
.../src/generated/resources/camel-smpps-sink.json | 28 ++++++++++++
.../generated/resources/camel-smpps-source.json | 28 ++++++++++++
.../docs/camel-smpps-kafka-sink-connector.adoc | 6 ++-
.../docs/camel-smpps-kafka-source-connector.adoc | 6 ++-
.../smpps/CamelSmppsSinkConnectorConfig.java | 16 +++++++
.../smpps/CamelSmppsSourceConnectorConfig.java | 16 +++++++
.../camel-azure-cosmosdb-kafka-sink-connector.adoc | 6 +--
...amel-azure-cosmosdb-kafka-source-connector.adoc | 6 +--
.../camel-salesforce-kafka-sink-connector.adoc | 12 ++++-
.../camel-smpp-kafka-sink-connector.adoc | 6 ++-
.../camel-smpp-kafka-source-connector.adoc | 6 ++-
.../camel-smpps-kafka-sink-connector.adoc | 6 ++-
.../camel-smpps-kafka-source-connector.adoc | 6 ++-
33 files changed, 495 insertions(+), 45 deletions(-)
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-azure-cosmosdb-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-azure-cosmosdb-sink.json
index 46b14ce..4078284 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-azure-cosmosdb-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-azure-cosmosdb-sink.json
@@ -6,7 +6,7 @@
"id": "camel-azure-cosmosdb-sink",
"type": "sink",
"version": "0.10.0-SNAPSHOT",
- "description": "Azure Cosmos DB is Microsofts globally
distributed, multi-model database service for operational and analytics
workloads. It offers multi-mastering feature by automatically scaling
throughput, compute, and storage. This component interacts with Azure CosmosDB
through Azure SQL API"
+ "description": "To read and write records to the CosmosDB
database on Azure cloud platform."
},
"properties": {
"camel.sink.path.databaseName": {
@@ -347,4 +347,4 @@
"required": "true"
}
}
-}
+}
\ No newline at end of file
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-azure-cosmosdb-source.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-azure-cosmosdb-source.json
index 331d0a1..53a0ae0 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-azure-cosmosdb-source.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-azure-cosmosdb-source.json
@@ -6,7 +6,7 @@
"id": "camel-azure-cosmosdb-source",
"type": "source",
"version": "0.10.0-SNAPSHOT",
- "description": "Azure Cosmos DB is Microsofts globally
distributed, multi-model database service for operational and analytics
workloads. It offers multi-mastering feature by automatically scaling
throughput, compute, and storage. This component interacts with Azure CosmosDB
through Azure SQL API"
+ "description": "To read and write records to the CosmosDB
database on Azure cloud platform."
},
"properties": {
"camel.source.path.databaseName": {
@@ -342,4 +342,4 @@
"required": "true"
}
}
-}
+}
\ No newline at end of file
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-salesforce-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-salesforce-sink.json
index 183b7c0..c9328fa 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-salesforce-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-salesforce-sink.json
@@ -11,7 +11,7 @@
"properties": {
"camel.sink.path.operationName": {
"name": "camel.sink.path.operationName",
- "description": "The operation to use One of:
[getVersions] [getResources] [getGlobalObjects] [getBasicInfo] [getDescription]
[getSObject] [createSObject] [updateSObject] [deleteSObject] [getSObjectWithId]
[upsertSObject] [deleteSObjectWithId] [getBlobField] [query] [queryMore]
[queryAll] [search] [apexCall] [recent] [createJob] [getJob] [closeJob]
[abortJob] [createBatch] [getBatch] [getAllBatches] [getRequest] [getResults]
[createBatchQuery] [getQueryResultIds] [getQueryResult] [getR [...]
+ "description": "The operation to use One of:
[getVersions] [getResources] [getGlobalObjects] [getBasicInfo] [getDescription]
[getSObject] [createSObject] [updateSObject] [deleteSObject] [getSObjectWithId]
[upsertSObject] [deleteSObjectWithId] [getBlobField] [query] [queryMore]
[queryAll] [search] [apexCall] [recent] [createJob] [getJob] [closeJob]
[abortJob] [createBatch] [getBatch] [getAllBatches] [getRequest] [getResults]
[createBatchQuery] [getQueryResultIds] [getQueryResult] [getR [...]
"priority": "MEDIUM",
"required": "false",
"enum": [
@@ -78,7 +78,8 @@
"bulk2GetAllQueryJobs",
"bulk2GetQueryJobResults",
"bulk2AbortQueryJob",
- "bulk2DeleteQueryJob"
+ "bulk2DeleteQueryJob",
+ "raw"
]
},
"camel.sink.endpoint.apexMethod": {
@@ -394,6 +395,30 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.sink.endpoint.rawHttpHeaders": {
+ "name": "camel.sink.endpoint.rawHttpHeaders",
+ "description": "Comma separated list of message headers
to include as HTTP parameters for Raw operation.",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.sink.endpoint.rawMethod": {
+ "name": "camel.sink.endpoint.rawMethod",
+ "description": "HTTP method to use for the Raw
operation",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.sink.endpoint.rawPath": {
+ "name": "camel.sink.endpoint.rawPath",
+ "description": "The portion of the endpoint URL after
the domain name. E.g., '\/services\/data\/v52.0\/sobjects\/Account\/'",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.sink.endpoint.rawQueryParameters": {
+ "name": "camel.sink.endpoint.rawQueryParameters",
+ "description": "Comma separated list of message headers
to include as query parameters for Raw operation. Do not url-encode values as
this will be done automatically.",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.salesforce.apexMethod": {
"name": "camel.component.salesforce.apexMethod",
"description": "APEX method name",
@@ -758,6 +783,30 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.salesforce.rawHttpHeaders": {
+ "name": "camel.component.salesforce.rawHttpHeaders",
+ "description": "Comma separated list of message headers
to include as HTTP parameters for Raw operation.",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.component.salesforce.rawMethod": {
+ "name": "camel.component.salesforce.rawMethod",
+ "description": "HTTP method to use for the Raw
operation",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.component.salesforce.rawPath": {
+ "name": "camel.component.salesforce.rawPath",
+ "description": "The portion of the endpoint URL after
the domain name. E.g., '\/services\/data\/v52.0\/sobjects\/Account\/'",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.component.salesforce.rawQueryParameters": {
+ "name": "camel.component.salesforce.rawQueryParameters",
+ "description": "Comma separated list of message headers
to include as query parameters for Raw operation. Do not url-encode values as
this will be done automatically.",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.salesforce.autowiredEnabled": {
"name": "camel.component.salesforce.autowiredEnabled",
"description": "Whether autowiring is enabled. This is
used for automatic autowiring options (the option must be marked as autowired)
by looking up in the registry to find if there is a single instance of matching
type, which then gets configured on the component. This can be used for
automatic configuring JDBC data sources, JMS connection factories, AWS Clients,
etc.",
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-smpp-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-smpp-sink.json
index 373901b..6946daa 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-smpp-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-smpp-sink.json
@@ -249,6 +249,20 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.sink.endpoint.pduProcessorDegree": {
+ "name": "camel.sink.endpoint.pduProcessorDegree",
+ "description": "Sets the number of threads which can
read PDU and process them in parallel.",
+ "defaultValue": "\"3\"",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.sink.endpoint.pduProcessorQueueCapacity": {
+ "name": "camel.sink.endpoint.pduProcessorQueueCapacity",
+ "description": "Sets the capacity of the working queue
for PDU processing.",
+ "defaultValue": "\"100\"",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.sink.endpoint.sessionStateListener": {
"name": "camel.sink.endpoint.sessionStateListener",
"description": "You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed.",
@@ -576,6 +590,20 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.smpp.pduProcessorDegree": {
+ "name": "camel.component.smpp.pduProcessorDegree",
+ "description": "Sets the number of threads which can
read PDU and process them in parallel.",
+ "defaultValue": "\"3\"",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.component.smpp.pduProcessorQueueCapacity": {
+ "name":
"camel.component.smpp.pduProcessorQueueCapacity",
+ "description": "Sets the capacity of the working queue
for PDU processing.",
+ "defaultValue": "\"100\"",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.smpp.sessionStateListener": {
"name": "camel.component.smpp.sessionStateListener",
"description": "You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed.",
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-smpp-source.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-smpp-source.json
index 140f5e5..6440e81 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-smpp-source.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-smpp-source.json
@@ -99,6 +99,20 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.source.endpoint.pduProcessorDegree": {
+ "name": "camel.source.endpoint.pduProcessorDegree",
+ "description": "Sets the number of threads which can
read PDU and process them in parallel.",
+ "defaultValue": "\"3\"",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.source.endpoint.pduProcessorQueueCapacity": {
+ "name":
"camel.source.endpoint.pduProcessorQueueCapacity",
+ "description": "Sets the capacity of the working queue
for PDU processing.",
+ "defaultValue": "\"100\"",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.source.endpoint.sessionStateListener": {
"name": "camel.source.endpoint.sessionStateListener",
"description": "You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed.",
@@ -259,6 +273,20 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.smpp.pduProcessorDegree": {
+ "name": "camel.component.smpp.pduProcessorDegree",
+ "description": "Sets the number of threads which can
read PDU and process them in parallel.",
+ "defaultValue": "\"3\"",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.component.smpp.pduProcessorQueueCapacity": {
+ "name":
"camel.component.smpp.pduProcessorQueueCapacity",
+ "description": "Sets the capacity of the working queue
for PDU processing.",
+ "defaultValue": "\"100\"",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.smpp.sessionStateListener": {
"name": "camel.component.smpp.sessionStateListener",
"description": "You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed.",
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-smpps-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-smpps-sink.json
index 737b091..12c3967 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-smpps-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-smpps-sink.json
@@ -249,6 +249,20 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.sink.endpoint.pduProcessorDegree": {
+ "name": "camel.sink.endpoint.pduProcessorDegree",
+ "description": "Sets the number of threads which can
read PDU and process them in parallel.",
+ "defaultValue": "\"3\"",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.sink.endpoint.pduProcessorQueueCapacity": {
+ "name": "camel.sink.endpoint.pduProcessorQueueCapacity",
+ "description": "Sets the capacity of the working queue
for PDU processing.",
+ "defaultValue": "\"100\"",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.sink.endpoint.sessionStateListener": {
"name": "camel.sink.endpoint.sessionStateListener",
"description": "You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed.",
@@ -576,6 +590,20 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.smpps.pduProcessorDegree": {
+ "name": "camel.component.smpps.pduProcessorDegree",
+ "description": "Sets the number of threads which can
read PDU and process them in parallel.",
+ "defaultValue": "\"3\"",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.component.smpps.pduProcessorQueueCapacity": {
+ "name":
"camel.component.smpps.pduProcessorQueueCapacity",
+ "description": "Sets the capacity of the working queue
for PDU processing.",
+ "defaultValue": "\"100\"",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.smpps.sessionStateListener": {
"name": "camel.component.smpps.sessionStateListener",
"description": "You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed.",
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-smpps-source.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-smpps-source.json
index b6ca142..71e87c6 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-smpps-source.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-smpps-source.json
@@ -99,6 +99,20 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.source.endpoint.pduProcessorDegree": {
+ "name": "camel.source.endpoint.pduProcessorDegree",
+ "description": "Sets the number of threads which can
read PDU and process them in parallel.",
+ "defaultValue": "\"3\"",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.source.endpoint.pduProcessorQueueCapacity": {
+ "name":
"camel.source.endpoint.pduProcessorQueueCapacity",
+ "description": "Sets the capacity of the working queue
for PDU processing.",
+ "defaultValue": "\"100\"",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.source.endpoint.sessionStateListener": {
"name": "camel.source.endpoint.sessionStateListener",
"description": "You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed.",
@@ -259,6 +273,20 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.smpps.pduProcessorDegree": {
+ "name": "camel.component.smpps.pduProcessorDegree",
+ "description": "Sets the number of threads which can
read PDU and process them in parallel.",
+ "defaultValue": "\"3\"",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.component.smpps.pduProcessorQueueCapacity": {
+ "name":
"camel.component.smpps.pduProcessorQueueCapacity",
+ "description": "Sets the capacity of the working queue
for PDU processing.",
+ "defaultValue": "\"100\"",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.smpps.sessionStateListener": {
"name": "camel.component.smpps.sessionStateListener",
"description": "You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed.",
diff --git
a/connectors/camel-azure-cosmosdb-kafka-connector/src/generated/resources/camel-azure-cosmosdb-sink.json
b/connectors/camel-azure-cosmosdb-kafka-connector/src/generated/resources/camel-azure-cosmosdb-sink.json
index 46b14ce..4078284 100644
---
a/connectors/camel-azure-cosmosdb-kafka-connector/src/generated/resources/camel-azure-cosmosdb-sink.json
+++
b/connectors/camel-azure-cosmosdb-kafka-connector/src/generated/resources/camel-azure-cosmosdb-sink.json
@@ -6,7 +6,7 @@
"id": "camel-azure-cosmosdb-sink",
"type": "sink",
"version": "0.10.0-SNAPSHOT",
- "description": "Azure Cosmos DB is Microsofts globally
distributed, multi-model database service for operational and analytics
workloads. It offers multi-mastering feature by automatically scaling
throughput, compute, and storage. This component interacts with Azure CosmosDB
through Azure SQL API"
+ "description": "To read and write records to the CosmosDB
database on Azure cloud platform."
},
"properties": {
"camel.sink.path.databaseName": {
@@ -347,4 +347,4 @@
"required": "true"
}
}
-}
+}
\ No newline at end of file
diff --git
a/connectors/camel-azure-cosmosdb-kafka-connector/src/generated/resources/camel-azure-cosmosdb-source.json
b/connectors/camel-azure-cosmosdb-kafka-connector/src/generated/resources/camel-azure-cosmosdb-source.json
index 331d0a1..53a0ae0 100644
---
a/connectors/camel-azure-cosmosdb-kafka-connector/src/generated/resources/camel-azure-cosmosdb-source.json
+++
b/connectors/camel-azure-cosmosdb-kafka-connector/src/generated/resources/camel-azure-cosmosdb-source.json
@@ -6,7 +6,7 @@
"id": "camel-azure-cosmosdb-source",
"type": "source",
"version": "0.10.0-SNAPSHOT",
- "description": "Azure Cosmos DB is Microsofts globally
distributed, multi-model database service for operational and analytics
workloads. It offers multi-mastering feature by automatically scaling
throughput, compute, and storage. This component interacts with Azure CosmosDB
through Azure SQL API"
+ "description": "To read and write records to the CosmosDB
database on Azure cloud platform."
},
"properties": {
"camel.source.path.databaseName": {
@@ -342,4 +342,4 @@
"required": "true"
}
}
-}
+}
\ No newline at end of file
diff --git
a/connectors/camel-azure-cosmosdb-kafka-connector/src/main/docs/camel-azure-cosmosdb-kafka-sink-connector.adoc
b/connectors/camel-azure-cosmosdb-kafka-connector/src/main/docs/camel-azure-cosmosdb-kafka-sink-connector.adoc
index 579b593..9da6714 100644
---
a/connectors/camel-azure-cosmosdb-kafka-connector/src/main/docs/camel-azure-cosmosdb-kafka-sink-connector.adoc
+++
b/connectors/camel-azure-cosmosdb-kafka-connector/src/main/docs/camel-azure-cosmosdb-kafka-sink-connector.adoc
@@ -2,7 +2,7 @@
[[camel-azure-cosmosdb-kafka-connector-sink]]
= camel-azure-cosmosdb-kafka-connector sink configuration
-Connector Description: Azure Cosmos DB is Microsofts globally distributed,
multi-model database service for operational and analytics workloads. It offers
multi-mastering feature by automatically scaling throughput, compute, and
storage. This component interacts with Azure CosmosDB through Azure SQL API
+Connector Description: To read and write records to the CosmosDB database on
Azure cloud platform.
When using camel-azure-cosmosdb-kafka-connector as sink make sure to use the
following Maven dependency to have support for the connector:
@@ -92,8 +92,4 @@ The camel-azure-cosmosdb sink connector has no transforms out
of the box.
The camel-azure-cosmosdb sink connector has no aggregation strategies out of
the box.
-
-
-
-
// kafka-connector options: END
diff --git
a/connectors/camel-azure-cosmosdb-kafka-connector/src/main/docs/camel-azure-cosmosdb-kafka-source-connector.adoc
b/connectors/camel-azure-cosmosdb-kafka-connector/src/main/docs/camel-azure-cosmosdb-kafka-source-connector.adoc
index e4a95e4..8490e9f 100644
---
a/connectors/camel-azure-cosmosdb-kafka-connector/src/main/docs/camel-azure-cosmosdb-kafka-source-connector.adoc
+++
b/connectors/camel-azure-cosmosdb-kafka-connector/src/main/docs/camel-azure-cosmosdb-kafka-source-connector.adoc
@@ -2,7 +2,7 @@
[[camel-azure-cosmosdb-kafka-connector-source]]
= camel-azure-cosmosdb-kafka-connector source configuration
-Connector description: Azure Cosmos DB is Microsofts globally distributed,
multi-model database service for operational and analytics workloads. It offers
multi-mastering feature by automatically scaling throughput, compute, and
storage. This component interacts with Azure CosmosDB through Azure SQL API
+Connector description: To read and write records to the CosmosDB database on
Azure cloud platform.
When using camel-azure-cosmosdb-kafka-connector as source make sure to use the
following Maven dependency to have support for the connector:
@@ -96,8 +96,4 @@ The camel-azure-cosmosdb source connector has no transforms
out of the box.
The camel-azure-cosmosdb source connector has no aggregation strategies out of
the box.
-
-
-
-
// kafka-connector options: END
diff --git
a/connectors/camel-salesforce-kafka-connector/src/generated/resources/camel-salesforce-sink.json
b/connectors/camel-salesforce-kafka-connector/src/generated/resources/camel-salesforce-sink.json
index 183b7c0..c9328fa 100644
---
a/connectors/camel-salesforce-kafka-connector/src/generated/resources/camel-salesforce-sink.json
+++
b/connectors/camel-salesforce-kafka-connector/src/generated/resources/camel-salesforce-sink.json
@@ -11,7 +11,7 @@
"properties": {
"camel.sink.path.operationName": {
"name": "camel.sink.path.operationName",
- "description": "The operation to use One of:
[getVersions] [getResources] [getGlobalObjects] [getBasicInfo] [getDescription]
[getSObject] [createSObject] [updateSObject] [deleteSObject] [getSObjectWithId]
[upsertSObject] [deleteSObjectWithId] [getBlobField] [query] [queryMore]
[queryAll] [search] [apexCall] [recent] [createJob] [getJob] [closeJob]
[abortJob] [createBatch] [getBatch] [getAllBatches] [getRequest] [getResults]
[createBatchQuery] [getQueryResultIds] [getQueryResult] [getR [...]
+ "description": "The operation to use One of:
[getVersions] [getResources] [getGlobalObjects] [getBasicInfo] [getDescription]
[getSObject] [createSObject] [updateSObject] [deleteSObject] [getSObjectWithId]
[upsertSObject] [deleteSObjectWithId] [getBlobField] [query] [queryMore]
[queryAll] [search] [apexCall] [recent] [createJob] [getJob] [closeJob]
[abortJob] [createBatch] [getBatch] [getAllBatches] [getRequest] [getResults]
[createBatchQuery] [getQueryResultIds] [getQueryResult] [getR [...]
"priority": "MEDIUM",
"required": "false",
"enum": [
@@ -78,7 +78,8 @@
"bulk2GetAllQueryJobs",
"bulk2GetQueryJobResults",
"bulk2AbortQueryJob",
- "bulk2DeleteQueryJob"
+ "bulk2DeleteQueryJob",
+ "raw"
]
},
"camel.sink.endpoint.apexMethod": {
@@ -394,6 +395,30 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.sink.endpoint.rawHttpHeaders": {
+ "name": "camel.sink.endpoint.rawHttpHeaders",
+ "description": "Comma separated list of message headers
to include as HTTP parameters for Raw operation.",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.sink.endpoint.rawMethod": {
+ "name": "camel.sink.endpoint.rawMethod",
+ "description": "HTTP method to use for the Raw
operation",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.sink.endpoint.rawPath": {
+ "name": "camel.sink.endpoint.rawPath",
+ "description": "The portion of the endpoint URL after
the domain name. E.g., '\/services\/data\/v52.0\/sobjects\/Account\/'",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.sink.endpoint.rawQueryParameters": {
+ "name": "camel.sink.endpoint.rawQueryParameters",
+ "description": "Comma separated list of message headers
to include as query parameters for Raw operation. Do not url-encode values as
this will be done automatically.",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.salesforce.apexMethod": {
"name": "camel.component.salesforce.apexMethod",
"description": "APEX method name",
@@ -758,6 +783,30 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.salesforce.rawHttpHeaders": {
+ "name": "camel.component.salesforce.rawHttpHeaders",
+ "description": "Comma separated list of message headers
to include as HTTP parameters for Raw operation.",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.component.salesforce.rawMethod": {
+ "name": "camel.component.salesforce.rawMethod",
+ "description": "HTTP method to use for the Raw
operation",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.component.salesforce.rawPath": {
+ "name": "camel.component.salesforce.rawPath",
+ "description": "The portion of the endpoint URL after
the domain name. E.g., '\/services\/data\/v52.0\/sobjects\/Account\/'",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.component.salesforce.rawQueryParameters": {
+ "name": "camel.component.salesforce.rawQueryParameters",
+ "description": "Comma separated list of message headers
to include as query parameters for Raw operation. Do not url-encode values as
this will be done automatically.",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.salesforce.autowiredEnabled": {
"name": "camel.component.salesforce.autowiredEnabled",
"description": "Whether autowiring is enabled. This is
used for automatic autowiring options (the option must be marked as autowired)
by looking up in the registry to find if there is a single instance of matching
type, which then gets configured on the component. This can be used for
automatic configuring JDBC data sources, JMS connection factories, AWS Clients,
etc.",
diff --git
a/connectors/camel-salesforce-kafka-connector/src/main/docs/camel-salesforce-kafka-sink-connector.adoc
b/connectors/camel-salesforce-kafka-connector/src/main/docs/camel-salesforce-kafka-sink-connector.adoc
index 07d2bf9..d43cb08 100644
---
a/connectors/camel-salesforce-kafka-connector/src/main/docs/camel-salesforce-kafka-sink-connector.adoc
+++
b/connectors/camel-salesforce-kafka-connector/src/main/docs/camel-salesforce-kafka-sink-connector.adoc
@@ -24,14 +24,14 @@
connector.class=org.apache.camel.kafkaconnector.salesforce.CamelSalesforceSinkCo
----
-The camel-salesforce sink connector supports 126 options, which are listed
below.
+The camel-salesforce sink connector supports 134 options, which are listed
below.
[width="100%",cols="2,5,^1,1,1",options="header"]
|===
| Name | Description | Default | Required | Priority
-| *camel.sink.path.operationName* | The operation to use One of: [getVersions]
[getResources] [getGlobalObjects] [getBasicInfo] [getDescription] [getSObject]
[createSObject] [updateSObject] [deleteSObject] [getSObjectWithId]
[upsertSObject] [deleteSObjectWithId] [getBlobField] [query] [queryMore]
[queryAll] [search] [apexCall] [recent] [createJob] [getJob] [closeJob]
[abortJob] [createBatch] [getBatch] [getAllBatches] [getRequest] [getResults]
[createBatchQuery] [getQueryResultIds] [getQ [...]
+| *camel.sink.path.operationName* | The operation to use One of: [getVersions]
[getResources] [getGlobalObjects] [getBasicInfo] [getDescription] [getSObject]
[createSObject] [updateSObject] [deleteSObject] [getSObjectWithId]
[upsertSObject] [deleteSObjectWithId] [getBlobField] [query] [queryMore]
[queryAll] [search] [apexCall] [recent] [createJob] [getJob] [closeJob]
[abortJob] [createBatch] [getBatch] [getAllBatches] [getRequest] [getResults]
[createBatchQuery] [getQueryResultIds] [getQ [...]
| *camel.sink.endpoint.apexMethod* | APEX method name | null | false | MEDIUM
| *camel.sink.endpoint.apexQueryParams* | Query params for APEX method | null
| false | MEDIUM
| *camel.sink.endpoint.apiVersion* | Salesforce API version. | "50.0" | false
| MEDIUM
@@ -78,6 +78,10 @@ The camel-salesforce sink connector supports 126 options,
which are listed below
| *camel.sink.endpoint.apexUrl* | APEX method URL | null | false | MEDIUM
| *camel.sink.endpoint.compositeMethod* | Composite (raw) method. | null |
false | MEDIUM
| *camel.sink.endpoint.lazyStartProducer* | Whether the producer should be
started lazy (on the first message). By starting lazy you can use this to allow
CamelContext and routes to startup in situations where a producer may otherwise
fail during starting and cause the route to fail being started. By deferring
this startup to be lazy then the startup failure can be handled during routing
messages via Camel's routing error handlers. Beware that when the first message
is processed then cre [...]
+| *camel.sink.endpoint.rawHttpHeaders* | Comma separated list of message
headers to include as HTTP parameters for Raw operation. | null | false | MEDIUM
+| *camel.sink.endpoint.rawMethod* | HTTP method to use for the Raw operation |
null | false | MEDIUM
+| *camel.sink.endpoint.rawPath* | The portion of the endpoint URL after the
domain name. E.g., '/services/data/v52.0/sobjects/Account/' | null | false |
MEDIUM
+| *camel.sink.endpoint.rawQueryParameters* | Comma separated list of message
headers to include as query parameters for Raw operation. Do not url-encode
values as this will be done automatically. | null | false | MEDIUM
| *camel.component.salesforce.apexMethod* | APEX method name | null | false |
MEDIUM
| *camel.component.salesforce.apexQueryParams* | Query params for APEX method
| null | false | MEDIUM
| *camel.component.salesforce.apiVersion* | Salesforce API version. | "50.0" |
false | MEDIUM
@@ -132,6 +136,10 @@ The camel-salesforce sink connector supports 126 options,
which are listed below
| *camel.component.salesforce.apexUrl* | APEX method URL | null | false |
MEDIUM
| *camel.component.salesforce.compositeMethod* | Composite (raw) method. |
null | false | MEDIUM
| *camel.component.salesforce.lazyStartProducer* | Whether the producer should
be started lazy (on the first message). By starting lazy you can use this to
allow CamelContext and routes to startup in situations where a producer may
otherwise fail during starting and cause the route to fail being started. By
deferring this startup to be lazy then the startup failure can be handled
during routing messages via Camel's routing error handlers. Beware that when
the first message is processed t [...]
+| *camel.component.salesforce.rawHttpHeaders* | Comma separated list of
message headers to include as HTTP parameters for Raw operation. | null | false
| MEDIUM
+| *camel.component.salesforce.rawMethod* | HTTP method to use for the Raw
operation | null | false | MEDIUM
+| *camel.component.salesforce.rawPath* | The portion of the endpoint URL after
the domain name. E.g., '/services/data/v52.0/sobjects/Account/' | null | false
| MEDIUM
+| *camel.component.salesforce.rawQueryParameters* | Comma separated list of
message headers to include as query parameters for Raw operation. Do not
url-encode values as this will be done automatically. | null | false | MEDIUM
| *camel.component.salesforce.autowiredEnabled* | Whether autowiring is
enabled. This is used for automatic autowiring options (the option must be
marked as autowired) by looking up in the registry to find if there is a single
instance of matching type, which then gets configured on the component. This
can be used for automatic configuring JDBC data sources, JMS connection
factories, AWS Clients, etc. | true | false | MEDIUM
| *camel.component.salesforce.httpProxyExcluded Addresses* | A list of
addresses for which HTTP proxy server should not be used. | null | false |
MEDIUM
| *camel.component.salesforce.httpProxyHost* | Hostname of the HTTP proxy
server to use. | null | false | MEDIUM
diff --git
a/connectors/camel-salesforce-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/salesforce/CamelSalesforceSinkConnectorConfig.java
b/connectors/camel-salesforce-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/salesforce/CamelSalesforceSinkConnectorConfig.java
index d6f9e4e..7a08dbf 100644
---
a/connectors/camel-salesforce-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/salesforce/CamelSalesforceSinkConnectorConfig.java
+++
b/connectors/camel-salesforce-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/salesforce/CamelSalesforceSinkConnectorConfig.java
@@ -27,7 +27,7 @@ public class CamelSalesforceSinkConnectorConfig
CamelSinkConnectorConfig {
public static final String CAMEL_SINK_SALESFORCE_PATH_OPERATION_NAME_CONF
= "camel.sink.path.operationName";
- public static final String CAMEL_SINK_SALESFORCE_PATH_OPERATION_NAME_DOC =
"The operation to use One of: [getVersions] [getResources] [getGlobalObjects]
[getBasicInfo] [getDescription] [getSObject] [createSObject] [updateSObject]
[deleteSObject] [getSObjectWithId] [upsertSObject] [deleteSObjectWithId]
[getBlobField] [query] [queryMore] [queryAll] [search] [apexCall] [recent]
[createJob] [getJob] [closeJob] [abortJob] [createBatch] [getBatch]
[getAllBatches] [getRequest] [getResults] [...]
+ public static final String CAMEL_SINK_SALESFORCE_PATH_OPERATION_NAME_DOC =
"The operation to use One of: [getVersions] [getResources] [getGlobalObjects]
[getBasicInfo] [getDescription] [getSObject] [createSObject] [updateSObject]
[deleteSObject] [getSObjectWithId] [upsertSObject] [deleteSObjectWithId]
[getBlobField] [query] [queryMore] [queryAll] [search] [apexCall] [recent]
[createJob] [getJob] [closeJob] [abortJob] [createBatch] [getBatch]
[getAllBatches] [getRequest] [getResults] [...]
public static final String
CAMEL_SINK_SALESFORCE_PATH_OPERATION_NAME_DEFAULT = null;
public static final String CAMEL_SINK_SALESFORCE_ENDPOINT_APEX_METHOD_CONF
= "camel.sink.endpoint.apexMethod";
public static final String CAMEL_SINK_SALESFORCE_ENDPOINT_APEX_METHOD_DOC
= "APEX method name";
@@ -167,6 +167,18 @@ public class CamelSalesforceSinkConnectorConfig
public static final String
CAMEL_SINK_SALESFORCE_ENDPOINT_LAZY_START_PRODUCER_CONF =
"camel.sink.endpoint.lazyStartProducer";
public static final String
CAMEL_SINK_SALESFORCE_ENDPOINT_LAZY_START_PRODUCER_DOC = "Whether the producer
should be started lazy (on the first message). By starting lazy you can use
this to allow CamelContext and routes to startup in situations where a producer
may otherwise fail during starting and cause the route to fail being started.
By deferring this startup to be lazy then the startup failure can be handled
during routing messages via Camel's routing error handlers. Beware that [...]
public static final Boolean
CAMEL_SINK_SALESFORCE_ENDPOINT_LAZY_START_PRODUCER_DEFAULT = false;
+ public static final String
CAMEL_SINK_SALESFORCE_ENDPOINT_RAW_HTTP_HEADERS_CONF =
"camel.sink.endpoint.rawHttpHeaders";
+ public static final String
CAMEL_SINK_SALESFORCE_ENDPOINT_RAW_HTTP_HEADERS_DOC = "Comma separated list of
message headers to include as HTTP parameters for Raw operation.";
+ public static final String
CAMEL_SINK_SALESFORCE_ENDPOINT_RAW_HTTP_HEADERS_DEFAULT = null;
+ public static final String CAMEL_SINK_SALESFORCE_ENDPOINT_RAW_METHOD_CONF
= "camel.sink.endpoint.rawMethod";
+ public static final String CAMEL_SINK_SALESFORCE_ENDPOINT_RAW_METHOD_DOC =
"HTTP method to use for the Raw operation";
+ public static final String
CAMEL_SINK_SALESFORCE_ENDPOINT_RAW_METHOD_DEFAULT = null;
+ public static final String CAMEL_SINK_SALESFORCE_ENDPOINT_RAW_PATH_CONF =
"camel.sink.endpoint.rawPath";
+ public static final String CAMEL_SINK_SALESFORCE_ENDPOINT_RAW_PATH_DOC =
"The portion of the endpoint URL after the domain name. E.g.,
'/services/data/v52.0/sobjects/Account/'";
+ public static final String CAMEL_SINK_SALESFORCE_ENDPOINT_RAW_PATH_DEFAULT
= null;
+ public static final String
CAMEL_SINK_SALESFORCE_ENDPOINT_RAW_QUERY_PARAMETERS_CONF =
"camel.sink.endpoint.rawQueryParameters";
+ public static final String
CAMEL_SINK_SALESFORCE_ENDPOINT_RAW_QUERY_PARAMETERS_DOC = "Comma separated list
of message headers to include as query parameters for Raw operation. Do not
url-encode values as this will be done automatically.";
+ public static final String
CAMEL_SINK_SALESFORCE_ENDPOINT_RAW_QUERY_PARAMETERS_DEFAULT = null;
public static final String
CAMEL_SINK_SALESFORCE_COMPONENT_APEX_METHOD_CONF =
"camel.component.salesforce.apexMethod";
public static final String CAMEL_SINK_SALESFORCE_COMPONENT_APEX_METHOD_DOC
= "APEX method name";
public static final String
CAMEL_SINK_SALESFORCE_COMPONENT_APEX_METHOD_DEFAULT = null;
@@ -329,6 +341,18 @@ public class CamelSalesforceSinkConnectorConfig
public static final String
CAMEL_SINK_SALESFORCE_COMPONENT_LAZY_START_PRODUCER_CONF =
"camel.component.salesforce.lazyStartProducer";
public static final String
CAMEL_SINK_SALESFORCE_COMPONENT_LAZY_START_PRODUCER_DOC = "Whether the producer
should be started lazy (on the first message). By starting lazy you can use
this to allow CamelContext and routes to startup in situations where a producer
may otherwise fail during starting and cause the route to fail being started.
By deferring this startup to be lazy then the startup failure can be handled
during routing messages via Camel's routing error handlers. Beware tha [...]
public static final Boolean
CAMEL_SINK_SALESFORCE_COMPONENT_LAZY_START_PRODUCER_DEFAULT = false;
+ public static final String
CAMEL_SINK_SALESFORCE_COMPONENT_RAW_HTTP_HEADERS_CONF =
"camel.component.salesforce.rawHttpHeaders";
+ public static final String
CAMEL_SINK_SALESFORCE_COMPONENT_RAW_HTTP_HEADERS_DOC = "Comma separated list of
message headers to include as HTTP parameters for Raw operation.";
+ public static final String
CAMEL_SINK_SALESFORCE_COMPONENT_RAW_HTTP_HEADERS_DEFAULT = null;
+ public static final String CAMEL_SINK_SALESFORCE_COMPONENT_RAW_METHOD_CONF
= "camel.component.salesforce.rawMethod";
+ public static final String CAMEL_SINK_SALESFORCE_COMPONENT_RAW_METHOD_DOC
= "HTTP method to use for the Raw operation";
+ public static final String
CAMEL_SINK_SALESFORCE_COMPONENT_RAW_METHOD_DEFAULT = null;
+ public static final String CAMEL_SINK_SALESFORCE_COMPONENT_RAW_PATH_CONF =
"camel.component.salesforce.rawPath";
+ public static final String CAMEL_SINK_SALESFORCE_COMPONENT_RAW_PATH_DOC =
"The portion of the endpoint URL after the domain name. E.g.,
'/services/data/v52.0/sobjects/Account/'";
+ public static final String
CAMEL_SINK_SALESFORCE_COMPONENT_RAW_PATH_DEFAULT = null;
+ public static final String
CAMEL_SINK_SALESFORCE_COMPONENT_RAW_QUERY_PARAMETERS_CONF =
"camel.component.salesforce.rawQueryParameters";
+ public static final String
CAMEL_SINK_SALESFORCE_COMPONENT_RAW_QUERY_PARAMETERS_DOC = "Comma separated
list of message headers to include as query parameters for Raw operation. Do
not url-encode values as this will be done automatically.";
+ public static final String
CAMEL_SINK_SALESFORCE_COMPONENT_RAW_QUERY_PARAMETERS_DEFAULT = null;
public static final String
CAMEL_SINK_SALESFORCE_COMPONENT_AUTOWIRED_ENABLED_CONF =
"camel.component.salesforce.autowiredEnabled";
public static final String
CAMEL_SINK_SALESFORCE_COMPONENT_AUTOWIRED_ENABLED_DOC = "Whether autowiring is
enabled. This is used for automatic autowiring options (the option must be
marked as autowired) by looking up in the registry to find if there is a single
instance of matching type, which then gets configured on the component. This
can be used for automatic configuring JDBC data sources, JMS connection
factories, AWS Clients, etc.";
public static final Boolean
CAMEL_SINK_SALESFORCE_COMPONENT_AUTOWIRED_ENABLED_DEFAULT = true;
@@ -464,6 +488,10 @@ public class CamelSalesforceSinkConnectorConfig
conf.define(CAMEL_SINK_SALESFORCE_ENDPOINT_APEX_URL_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SALESFORCE_ENDPOINT_APEX_URL_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SALESFORCE_ENDPOINT_APEX_URL_DOC);
conf.define(CAMEL_SINK_SALESFORCE_ENDPOINT_COMPOSITE_METHOD_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SALESFORCE_ENDPOINT_COMPOSITE_METHOD_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_SALESFORCE_ENDPOINT_COMPOSITE_METHOD_DOC);
conf.define(CAMEL_SINK_SALESFORCE_ENDPOINT_LAZY_START_PRODUCER_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_SALESFORCE_ENDPOINT_LAZY_START_PRODUCER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_SALESFORCE_ENDPOINT_LAZY_START_PRODUCER_DOC);
+ conf.define(CAMEL_SINK_SALESFORCE_ENDPOINT_RAW_HTTP_HEADERS_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SALESFORCE_ENDPOINT_RAW_HTTP_HEADERS_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_SALESFORCE_ENDPOINT_RAW_HTTP_HEADERS_DOC);
+ conf.define(CAMEL_SINK_SALESFORCE_ENDPOINT_RAW_METHOD_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SALESFORCE_ENDPOINT_RAW_METHOD_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SALESFORCE_ENDPOINT_RAW_METHOD_DOC);
+ conf.define(CAMEL_SINK_SALESFORCE_ENDPOINT_RAW_PATH_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SALESFORCE_ENDPOINT_RAW_PATH_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SALESFORCE_ENDPOINT_RAW_PATH_DOC);
+ conf.define(CAMEL_SINK_SALESFORCE_ENDPOINT_RAW_QUERY_PARAMETERS_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_SALESFORCE_ENDPOINT_RAW_QUERY_PARAMETERS_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_SALESFORCE_ENDPOINT_RAW_QUERY_PARAMETERS_DOC);
conf.define(CAMEL_SINK_SALESFORCE_COMPONENT_APEX_METHOD_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SALESFORCE_COMPONENT_APEX_METHOD_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SALESFORCE_COMPONENT_APEX_METHOD_DOC);
conf.define(CAMEL_SINK_SALESFORCE_COMPONENT_APEX_QUERY_PARAMS_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_SALESFORCE_COMPONENT_APEX_QUERY_PARAMS_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_SALESFORCE_COMPONENT_APEX_QUERY_PARAMS_DOC);
conf.define(CAMEL_SINK_SALESFORCE_COMPONENT_API_VERSION_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SALESFORCE_COMPONENT_API_VERSION_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SALESFORCE_COMPONENT_API_VERSION_DOC);
@@ -518,6 +546,10 @@ public class CamelSalesforceSinkConnectorConfig
conf.define(CAMEL_SINK_SALESFORCE_COMPONENT_APEX_URL_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SALESFORCE_COMPONENT_APEX_URL_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SALESFORCE_COMPONENT_APEX_URL_DOC);
conf.define(CAMEL_SINK_SALESFORCE_COMPONENT_COMPOSITE_METHOD_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_SALESFORCE_COMPONENT_COMPOSITE_METHOD_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_SALESFORCE_COMPONENT_COMPOSITE_METHOD_DOC);
conf.define(CAMEL_SINK_SALESFORCE_COMPONENT_LAZY_START_PRODUCER_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_SALESFORCE_COMPONENT_LAZY_START_PRODUCER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_SALESFORCE_COMPONENT_LAZY_START_PRODUCER_DOC);
+ conf.define(CAMEL_SINK_SALESFORCE_COMPONENT_RAW_HTTP_HEADERS_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_SALESFORCE_COMPONENT_RAW_HTTP_HEADERS_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_SALESFORCE_COMPONENT_RAW_HTTP_HEADERS_DOC);
+ conf.define(CAMEL_SINK_SALESFORCE_COMPONENT_RAW_METHOD_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SALESFORCE_COMPONENT_RAW_METHOD_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SALESFORCE_COMPONENT_RAW_METHOD_DOC);
+ conf.define(CAMEL_SINK_SALESFORCE_COMPONENT_RAW_PATH_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SALESFORCE_COMPONENT_RAW_PATH_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SALESFORCE_COMPONENT_RAW_PATH_DOC);
+ conf.define(CAMEL_SINK_SALESFORCE_COMPONENT_RAW_QUERY_PARAMETERS_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_SALESFORCE_COMPONENT_RAW_QUERY_PARAMETERS_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_SALESFORCE_COMPONENT_RAW_QUERY_PARAMETERS_DOC);
conf.define(CAMEL_SINK_SALESFORCE_COMPONENT_AUTOWIRED_ENABLED_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_SALESFORCE_COMPONENT_AUTOWIRED_ENABLED_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_SALESFORCE_COMPONENT_AUTOWIRED_ENABLED_DOC);
conf.define(CAMEL_SINK_SALESFORCE_COMPONENT_HTTP_PROXY_EXCLUDED_ADDRESSES_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_SALESFORCE_COMPONENT_HTTP_PROXY_EXCLUDED_ADDRESSES_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_SALESFORCE_COMPONENT_HTTP_PROXY_EXCLUDED_ADDRESSES_DOC);
conf.define(CAMEL_SINK_SALESFORCE_COMPONENT_HTTP_PROXY_HOST_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SALESFORCE_COMPONENT_HTTP_PROXY_HOST_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_SALESFORCE_COMPONENT_HTTP_PROXY_HOST_DOC);
diff --git
a/connectors/camel-smpp-kafka-connector/src/generated/resources/camel-smpp-sink.json
b/connectors/camel-smpp-kafka-connector/src/generated/resources/camel-smpp-sink.json
index 373901b..6946daa 100644
---
a/connectors/camel-smpp-kafka-connector/src/generated/resources/camel-smpp-sink.json
+++
b/connectors/camel-smpp-kafka-connector/src/generated/resources/camel-smpp-sink.json
@@ -249,6 +249,20 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.sink.endpoint.pduProcessorDegree": {
+ "name": "camel.sink.endpoint.pduProcessorDegree",
+ "description": "Sets the number of threads which can
read PDU and process them in parallel.",
+ "defaultValue": "\"3\"",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.sink.endpoint.pduProcessorQueueCapacity": {
+ "name": "camel.sink.endpoint.pduProcessorQueueCapacity",
+ "description": "Sets the capacity of the working queue
for PDU processing.",
+ "defaultValue": "\"100\"",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.sink.endpoint.sessionStateListener": {
"name": "camel.sink.endpoint.sessionStateListener",
"description": "You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed.",
@@ -576,6 +590,20 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.smpp.pduProcessorDegree": {
+ "name": "camel.component.smpp.pduProcessorDegree",
+ "description": "Sets the number of threads which can
read PDU and process them in parallel.",
+ "defaultValue": "\"3\"",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.component.smpp.pduProcessorQueueCapacity": {
+ "name":
"camel.component.smpp.pduProcessorQueueCapacity",
+ "description": "Sets the capacity of the working queue
for PDU processing.",
+ "defaultValue": "\"100\"",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.smpp.sessionStateListener": {
"name": "camel.component.smpp.sessionStateListener",
"description": "You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed.",
diff --git
a/connectors/camel-smpp-kafka-connector/src/generated/resources/camel-smpp-source.json
b/connectors/camel-smpp-kafka-connector/src/generated/resources/camel-smpp-source.json
index 140f5e5..6440e81 100644
---
a/connectors/camel-smpp-kafka-connector/src/generated/resources/camel-smpp-source.json
+++
b/connectors/camel-smpp-kafka-connector/src/generated/resources/camel-smpp-source.json
@@ -99,6 +99,20 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.source.endpoint.pduProcessorDegree": {
+ "name": "camel.source.endpoint.pduProcessorDegree",
+ "description": "Sets the number of threads which can
read PDU and process them in parallel.",
+ "defaultValue": "\"3\"",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.source.endpoint.pduProcessorQueueCapacity": {
+ "name":
"camel.source.endpoint.pduProcessorQueueCapacity",
+ "description": "Sets the capacity of the working queue
for PDU processing.",
+ "defaultValue": "\"100\"",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.source.endpoint.sessionStateListener": {
"name": "camel.source.endpoint.sessionStateListener",
"description": "You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed.",
@@ -259,6 +273,20 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.smpp.pduProcessorDegree": {
+ "name": "camel.component.smpp.pduProcessorDegree",
+ "description": "Sets the number of threads which can
read PDU and process them in parallel.",
+ "defaultValue": "\"3\"",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.component.smpp.pduProcessorQueueCapacity": {
+ "name":
"camel.component.smpp.pduProcessorQueueCapacity",
+ "description": "Sets the capacity of the working queue
for PDU processing.",
+ "defaultValue": "\"100\"",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.smpp.sessionStateListener": {
"name": "camel.component.smpp.sessionStateListener",
"description": "You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed.",
diff --git
a/connectors/camel-smpp-kafka-connector/src/main/docs/camel-smpp-kafka-sink-connector.adoc
b/connectors/camel-smpp-kafka-connector/src/main/docs/camel-smpp-kafka-sink-connector.adoc
index 76fdff8..0a071e3 100644
---
a/connectors/camel-smpp-kafka-connector/src/main/docs/camel-smpp-kafka-sink-connector.adoc
+++
b/connectors/camel-smpp-kafka-connector/src/main/docs/camel-smpp-kafka-sink-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.smpp.CamelSmppSinkConnector
----
-The camel-smpp sink connector supports 72 options, which are listed below.
+The camel-smpp sink connector supports 76 options, which are listed below.
@@ -54,6 +54,8 @@ The camel-smpp sink connector supports 72 options, which are
listed below.
| *camel.sink.endpoint.sourceAddrTon* | Defines the type of number (TON) to be
used in the SME originator address parameters. The following TON values are
defined: 0: Unknown 1: International 2: National 3: Network Specific 4:
Subscriber Number 5: Alphanumeric 6: Abbreviated One of: [0] [1] [2] [3] [4]
[5] [6] | null | false | MEDIUM
| *camel.sink.endpoint.typeOfNumber* | Defines the type of number (TON) to be
used in the SME. The following TON values are defined: 0: Unknown 1:
International 2: National 3: Network Specific 4: Subscriber Number 5:
Alphanumeric 6: Abbreviated One of: [0] [1] [2] [3] [4] [5] [6] | null | false
| MEDIUM
| *camel.sink.endpoint.enquireLinkTimer* | Defines the interval in
milliseconds between the confidence checks. The confidence check is used to
test the communication path between an ESME and an SMSC. | "60000" | false |
MEDIUM
+| *camel.sink.endpoint.pduProcessorDegree* | Sets the number of threads which
can read PDU and process them in parallel. | "3" | false | MEDIUM
+| *camel.sink.endpoint.pduProcessorQueueCapacity* | Sets the capacity of the
working queue for PDU processing. | "100" | false | MEDIUM
| *camel.sink.endpoint.sessionStateListener* | You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed. | null | false | MEDIUM
| *camel.sink.endpoint.transactionTimer* | Defines the maximum period of
inactivity allowed after a transaction, after which an SMPP entity may assume
that the session is no longer active. This timer may be active on either
communicating SMPP entity (i.e. SMSC or ESME). | "10000" | false | MEDIUM
| *camel.sink.endpoint.alphabet* | Defines encoding of data according the SMPP
3.4 specification, section 5.2.19. 0: SMSC Default Alphabet 4: 8 bit Alphabet
8: UCS2 Alphabet One of: [0] [4] [8] | null | false | MEDIUM
@@ -90,6 +92,8 @@ The camel-smpp sink connector supports 72 options, which are
listed below.
| *camel.component.smpp.autowiredEnabled* | Whether autowiring is enabled.
This is used for automatic autowiring options (the option must be marked as
autowired) by looking up in the registry to find if there is a single instance
of matching type, which then gets configured on the component. This can be used
for automatic configuring JDBC data sources, JMS connection factories, AWS
Clients, etc. | true | false | MEDIUM
| *camel.component.smpp.configuration* | To use the shared SmppConfiguration
as configuration. | null | false | MEDIUM
| *camel.component.smpp.enquireLinkTimer* | Defines the interval in
milliseconds between the confidence checks. The confidence check is used to
test the communication path between an ESME and an SMSC. | "60000" | false |
MEDIUM
+| *camel.component.smpp.pduProcessorDegree* | Sets the number of threads which
can read PDU and process them in parallel. | "3" | false | MEDIUM
+| *camel.component.smpp.pduProcessorQueueCapacity* | Sets the capacity of the
working queue for PDU processing. | "100" | false | MEDIUM
| *camel.component.smpp.sessionStateListener* | You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed. | null | false | MEDIUM
| *camel.component.smpp.transactionTimer* | Defines the maximum period of
inactivity allowed after a transaction, after which an SMPP entity may assume
that the session is no longer active. This timer may be active on either
communicating SMPP entity (i.e. SMSC or ESME). | "10000" | false | MEDIUM
| *camel.component.smpp.alphabet* | Defines encoding of data according the
SMPP 3.4 specification, section 5.2.19. 0: SMSC Default Alphabet 4: 8 bit
Alphabet 8: UCS2 Alphabet One of: [0] [4] [8] | null | false | MEDIUM
diff --git
a/connectors/camel-smpp-kafka-connector/src/main/docs/camel-smpp-kafka-source-connector.adoc
b/connectors/camel-smpp-kafka-connector/src/main/docs/camel-smpp-kafka-source-connector.adoc
index 93c0f8f..57fc067 100644
---
a/connectors/camel-smpp-kafka-connector/src/main/docs/camel-smpp-kafka-source-connector.adoc
+++
b/connectors/camel-smpp-kafka-connector/src/main/docs/camel-smpp-kafka-source-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.smpp.CamelSmppSourceConnector
----
-The camel-smpp source connector supports 48 options, which are listed below.
+The camel-smpp source connector supports 52 options, which are listed below.
@@ -43,6 +43,8 @@ The camel-smpp source connector supports 48 options, which
are listed below.
| *camel.source.endpoint.exceptionHandler* | To let the consumer use a custom
ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this
option is not in use. By default the consumer will deal with exceptions, that
will be logged at WARN or ERROR level and ignored. | null | false | MEDIUM
| *camel.source.endpoint.exchangePattern* | Sets the exchange pattern when the
consumer creates an exchange. One of: [InOnly] [InOut] [InOptionalOut] | null |
false | MEDIUM
| *camel.source.endpoint.enquireLinkTimer* | Defines the interval in
milliseconds between the confidence checks. The confidence check is used to
test the communication path between an ESME and an SMSC. | "60000" | false |
MEDIUM
+| *camel.source.endpoint.pduProcessorDegree* | Sets the number of threads
which can read PDU and process them in parallel. | "3" | false | MEDIUM
+| *camel.source.endpoint.pduProcessorQueueCapacity* | Sets the capacity of the
working queue for PDU processing. | "100" | false | MEDIUM
| *camel.source.endpoint.sessionStateListener* | You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed. | null | false | MEDIUM
| *camel.source.endpoint.transactionTimer* | Defines the maximum period of
inactivity allowed after a transaction, after which an SMPP entity may assume
that the session is no longer active. This timer may be active on either
communicating SMPP entity (i.e. SMSC or ESME). | "10000" | false | MEDIUM
| *camel.source.endpoint.alphabet* | Defines encoding of data according the
SMPP 3.4 specification, section 5.2.19. 0: SMSC Default Alphabet 4: 8 bit
Alphabet 8: UCS2 Alphabet One of: [0] [4] [8] | null | false | MEDIUM
@@ -66,6 +68,8 @@ The camel-smpp source connector supports 48 options, which
are listed below.
| *camel.component.smpp.autowiredEnabled* | Whether autowiring is enabled.
This is used for automatic autowiring options (the option must be marked as
autowired) by looking up in the registry to find if there is a single instance
of matching type, which then gets configured on the component. This can be used
for automatic configuring JDBC data sources, JMS connection factories, AWS
Clients, etc. | true | false | MEDIUM
| *camel.component.smpp.configuration* | To use the shared SmppConfiguration
as configuration. | null | false | MEDIUM
| *camel.component.smpp.enquireLinkTimer* | Defines the interval in
milliseconds between the confidence checks. The confidence check is used to
test the communication path between an ESME and an SMSC. | "60000" | false |
MEDIUM
+| *camel.component.smpp.pduProcessorDegree* | Sets the number of threads which
can read PDU and process them in parallel. | "3" | false | MEDIUM
+| *camel.component.smpp.pduProcessorQueueCapacity* | Sets the capacity of the
working queue for PDU processing. | "100" | false | MEDIUM
| *camel.component.smpp.sessionStateListener* | You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed. | null | false | MEDIUM
| *camel.component.smpp.transactionTimer* | Defines the maximum period of
inactivity allowed after a transaction, after which an SMPP entity may assume
that the session is no longer active. This timer may be active on either
communicating SMPP entity (i.e. SMSC or ESME). | "10000" | false | MEDIUM
| *camel.component.smpp.alphabet* | Defines encoding of data according the
SMPP 3.4 specification, section 5.2.19. 0: SMSC Default Alphabet 4: 8 bit
Alphabet 8: UCS2 Alphabet One of: [0] [4] [8] | null | false | MEDIUM
diff --git
a/connectors/camel-smpp-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/smpp/CamelSmppSinkConnectorConfig.java
b/connectors/camel-smpp-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/smpp/CamelSmppSinkConnectorConfig.java
index 70fd585..0799be5 100644
---
a/connectors/camel-smpp-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/smpp/CamelSmppSinkConnectorConfig.java
+++
b/connectors/camel-smpp-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/smpp/CamelSmppSinkConnectorConfig.java
@@ -93,6 +93,12 @@ public class CamelSmppSinkConnectorConfig extends
CamelSinkConnectorConfig {
public static final String
CAMEL_SINK_SMPP_ENDPOINT_ENQUIRE_LINK_TIMER_CONF =
"camel.sink.endpoint.enquireLinkTimer";
public static final String CAMEL_SINK_SMPP_ENDPOINT_ENQUIRE_LINK_TIMER_DOC
= "Defines the interval in milliseconds between the confidence checks. The
confidence check is used to test the communication path between an ESME and an
SMSC.";
public static final String
CAMEL_SINK_SMPP_ENDPOINT_ENQUIRE_LINK_TIMER_DEFAULT = "60000";
+ public static final String
CAMEL_SINK_SMPP_ENDPOINT_PDU_PROCESSOR_DEGREE_CONF =
"camel.sink.endpoint.pduProcessorDegree";
+ public static final String
CAMEL_SINK_SMPP_ENDPOINT_PDU_PROCESSOR_DEGREE_DOC = "Sets the number of threads
which can read PDU and process them in parallel.";
+ public static final String
CAMEL_SINK_SMPP_ENDPOINT_PDU_PROCESSOR_DEGREE_DEFAULT = "3";
+ public static final String
CAMEL_SINK_SMPP_ENDPOINT_PDU_PROCESSOR_QUEUE_CAPACITY_CONF =
"camel.sink.endpoint.pduProcessorQueueCapacity";
+ public static final String
CAMEL_SINK_SMPP_ENDPOINT_PDU_PROCESSOR_QUEUE_CAPACITY_DOC = "Sets the capacity
of the working queue for PDU processing.";
+ public static final String
CAMEL_SINK_SMPP_ENDPOINT_PDU_PROCESSOR_QUEUE_CAPACITY_DEFAULT = "100";
public static final String
CAMEL_SINK_SMPP_ENDPOINT_SESSION_STATE_LISTENER_CONF =
"camel.sink.endpoint.sessionStateListener";
public static final String
CAMEL_SINK_SMPP_ENDPOINT_SESSION_STATE_LISTENER_DOC = "You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed.";
public static final String
CAMEL_SINK_SMPP_ENDPOINT_SESSION_STATE_LISTENER_DEFAULT = null;
@@ -201,6 +207,12 @@ public class CamelSmppSinkConnectorConfig extends
CamelSinkConnectorConfig {
public static final String
CAMEL_SINK_SMPP_COMPONENT_ENQUIRE_LINK_TIMER_CONF =
"camel.component.smpp.enquireLinkTimer";
public static final String
CAMEL_SINK_SMPP_COMPONENT_ENQUIRE_LINK_TIMER_DOC = "Defines the interval in
milliseconds between the confidence checks. The confidence check is used to
test the communication path between an ESME and an SMSC.";
public static final String
CAMEL_SINK_SMPP_COMPONENT_ENQUIRE_LINK_TIMER_DEFAULT = "60000";
+ public static final String
CAMEL_SINK_SMPP_COMPONENT_PDU_PROCESSOR_DEGREE_CONF =
"camel.component.smpp.pduProcessorDegree";
+ public static final String
CAMEL_SINK_SMPP_COMPONENT_PDU_PROCESSOR_DEGREE_DOC = "Sets the number of
threads which can read PDU and process them in parallel.";
+ public static final String
CAMEL_SINK_SMPP_COMPONENT_PDU_PROCESSOR_DEGREE_DEFAULT = "3";
+ public static final String
CAMEL_SINK_SMPP_COMPONENT_PDU_PROCESSOR_QUEUE_CAPACITY_CONF =
"camel.component.smpp.pduProcessorQueueCapacity";
+ public static final String
CAMEL_SINK_SMPP_COMPONENT_PDU_PROCESSOR_QUEUE_CAPACITY_DOC = "Sets the capacity
of the working queue for PDU processing.";
+ public static final String
CAMEL_SINK_SMPP_COMPONENT_PDU_PROCESSOR_QUEUE_CAPACITY_DEFAULT = "100";
public static final String
CAMEL_SINK_SMPP_COMPONENT_SESSION_STATE_LISTENER_CONF =
"camel.component.smpp.sessionStateListener";
public static final String
CAMEL_SINK_SMPP_COMPONENT_SESSION_STATE_LISTENER_DOC = "You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed.";
public static final String
CAMEL_SINK_SMPP_COMPONENT_SESSION_STATE_LISTENER_DEFAULT = null;
@@ -276,6 +288,8 @@ public class CamelSmppSinkConnectorConfig extends
CamelSinkConnectorConfig {
conf.define(CAMEL_SINK_SMPP_ENDPOINT_SOURCE_ADDR_TON_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SMPP_ENDPOINT_SOURCE_ADDR_TON_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SMPP_ENDPOINT_SOURCE_ADDR_TON_DOC);
conf.define(CAMEL_SINK_SMPP_ENDPOINT_TYPE_OF_NUMBER_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SMPP_ENDPOINT_TYPE_OF_NUMBER_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SMPP_ENDPOINT_TYPE_OF_NUMBER_DOC);
conf.define(CAMEL_SINK_SMPP_ENDPOINT_ENQUIRE_LINK_TIMER_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SMPP_ENDPOINT_ENQUIRE_LINK_TIMER_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SMPP_ENDPOINT_ENQUIRE_LINK_TIMER_DOC);
+ conf.define(CAMEL_SINK_SMPP_ENDPOINT_PDU_PROCESSOR_DEGREE_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SMPP_ENDPOINT_PDU_PROCESSOR_DEGREE_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SMPP_ENDPOINT_PDU_PROCESSOR_DEGREE_DOC);
+
conf.define(CAMEL_SINK_SMPP_ENDPOINT_PDU_PROCESSOR_QUEUE_CAPACITY_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_SMPP_ENDPOINT_PDU_PROCESSOR_QUEUE_CAPACITY_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_SMPP_ENDPOINT_PDU_PROCESSOR_QUEUE_CAPACITY_DOC);
conf.define(CAMEL_SINK_SMPP_ENDPOINT_SESSION_STATE_LISTENER_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SMPP_ENDPOINT_SESSION_STATE_LISTENER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_SMPP_ENDPOINT_SESSION_STATE_LISTENER_DOC);
conf.define(CAMEL_SINK_SMPP_ENDPOINT_TRANSACTION_TIMER_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SMPP_ENDPOINT_TRANSACTION_TIMER_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SMPP_ENDPOINT_TRANSACTION_TIMER_DOC);
conf.define(CAMEL_SINK_SMPP_ENDPOINT_ALPHABET_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SMPP_ENDPOINT_ALPHABET_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SMPP_ENDPOINT_ALPHABET_DOC);
@@ -312,6 +326,8 @@ public class CamelSmppSinkConnectorConfig extends
CamelSinkConnectorConfig {
conf.define(CAMEL_SINK_SMPP_COMPONENT_AUTOWIRED_ENABLED_CONF,
ConfigDef.Type.BOOLEAN, CAMEL_SINK_SMPP_COMPONENT_AUTOWIRED_ENABLED_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SMPP_COMPONENT_AUTOWIRED_ENABLED_DOC);
conf.define(CAMEL_SINK_SMPP_COMPONENT_CONFIGURATION_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SMPP_COMPONENT_CONFIGURATION_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SMPP_COMPONENT_CONFIGURATION_DOC);
conf.define(CAMEL_SINK_SMPP_COMPONENT_ENQUIRE_LINK_TIMER_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SMPP_COMPONENT_ENQUIRE_LINK_TIMER_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SMPP_COMPONENT_ENQUIRE_LINK_TIMER_DOC);
+ conf.define(CAMEL_SINK_SMPP_COMPONENT_PDU_PROCESSOR_DEGREE_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SMPP_COMPONENT_PDU_PROCESSOR_DEGREE_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_SMPP_COMPONENT_PDU_PROCESSOR_DEGREE_DOC);
+
conf.define(CAMEL_SINK_SMPP_COMPONENT_PDU_PROCESSOR_QUEUE_CAPACITY_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_SMPP_COMPONENT_PDU_PROCESSOR_QUEUE_CAPACITY_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_SMPP_COMPONENT_PDU_PROCESSOR_QUEUE_CAPACITY_DOC);
conf.define(CAMEL_SINK_SMPP_COMPONENT_SESSION_STATE_LISTENER_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_SMPP_COMPONENT_SESSION_STATE_LISTENER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_SMPP_COMPONENT_SESSION_STATE_LISTENER_DOC);
conf.define(CAMEL_SINK_SMPP_COMPONENT_TRANSACTION_TIMER_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SMPP_COMPONENT_TRANSACTION_TIMER_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SMPP_COMPONENT_TRANSACTION_TIMER_DOC);
conf.define(CAMEL_SINK_SMPP_COMPONENT_ALPHABET_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SMPP_COMPONENT_ALPHABET_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SMPP_COMPONENT_ALPHABET_DOC);
diff --git
a/connectors/camel-smpp-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/smpp/CamelSmppSourceConnectorConfig.java
b/connectors/camel-smpp-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/smpp/CamelSmppSourceConnectorConfig.java
index 966b10e..40aec90 100644
---
a/connectors/camel-smpp-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/smpp/CamelSmppSourceConnectorConfig.java
+++
b/connectors/camel-smpp-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/smpp/CamelSmppSourceConnectorConfig.java
@@ -62,6 +62,12 @@ public class CamelSmppSourceConnectorConfig
public static final String
CAMEL_SOURCE_SMPP_ENDPOINT_ENQUIRE_LINK_TIMER_CONF =
"camel.source.endpoint.enquireLinkTimer";
public static final String
CAMEL_SOURCE_SMPP_ENDPOINT_ENQUIRE_LINK_TIMER_DOC = "Defines the interval in
milliseconds between the confidence checks. The confidence check is used to
test the communication path between an ESME and an SMSC.";
public static final String
CAMEL_SOURCE_SMPP_ENDPOINT_ENQUIRE_LINK_TIMER_DEFAULT = "60000";
+ public static final String
CAMEL_SOURCE_SMPP_ENDPOINT_PDU_PROCESSOR_DEGREE_CONF =
"camel.source.endpoint.pduProcessorDegree";
+ public static final String
CAMEL_SOURCE_SMPP_ENDPOINT_PDU_PROCESSOR_DEGREE_DOC = "Sets the number of
threads which can read PDU and process them in parallel.";
+ public static final String
CAMEL_SOURCE_SMPP_ENDPOINT_PDU_PROCESSOR_DEGREE_DEFAULT = "3";
+ public static final String
CAMEL_SOURCE_SMPP_ENDPOINT_PDU_PROCESSOR_QUEUE_CAPACITY_CONF =
"camel.source.endpoint.pduProcessorQueueCapacity";
+ public static final String
CAMEL_SOURCE_SMPP_ENDPOINT_PDU_PROCESSOR_QUEUE_CAPACITY_DOC = "Sets the
capacity of the working queue for PDU processing.";
+ public static final String
CAMEL_SOURCE_SMPP_ENDPOINT_PDU_PROCESSOR_QUEUE_CAPACITY_DEFAULT = "100";
public static final String
CAMEL_SOURCE_SMPP_ENDPOINT_SESSION_STATE_LISTENER_CONF =
"camel.source.endpoint.sessionStateListener";
public static final String
CAMEL_SOURCE_SMPP_ENDPOINT_SESSION_STATE_LISTENER_DOC = "You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed.";
public static final String
CAMEL_SOURCE_SMPP_ENDPOINT_SESSION_STATE_LISTENER_DEFAULT = null;
@@ -131,6 +137,12 @@ public class CamelSmppSourceConnectorConfig
public static final String
CAMEL_SOURCE_SMPP_COMPONENT_ENQUIRE_LINK_TIMER_CONF =
"camel.component.smpp.enquireLinkTimer";
public static final String
CAMEL_SOURCE_SMPP_COMPONENT_ENQUIRE_LINK_TIMER_DOC = "Defines the interval in
milliseconds between the confidence checks. The confidence check is used to
test the communication path between an ESME and an SMSC.";
public static final String
CAMEL_SOURCE_SMPP_COMPONENT_ENQUIRE_LINK_TIMER_DEFAULT = "60000";
+ public static final String
CAMEL_SOURCE_SMPP_COMPONENT_PDU_PROCESSOR_DEGREE_CONF =
"camel.component.smpp.pduProcessorDegree";
+ public static final String
CAMEL_SOURCE_SMPP_COMPONENT_PDU_PROCESSOR_DEGREE_DOC = "Sets the number of
threads which can read PDU and process them in parallel.";
+ public static final String
CAMEL_SOURCE_SMPP_COMPONENT_PDU_PROCESSOR_DEGREE_DEFAULT = "3";
+ public static final String
CAMEL_SOURCE_SMPP_COMPONENT_PDU_PROCESSOR_QUEUE_CAPACITY_CONF =
"camel.component.smpp.pduProcessorQueueCapacity";
+ public static final String
CAMEL_SOURCE_SMPP_COMPONENT_PDU_PROCESSOR_QUEUE_CAPACITY_DOC = "Sets the
capacity of the working queue for PDU processing.";
+ public static final String
CAMEL_SOURCE_SMPP_COMPONENT_PDU_PROCESSOR_QUEUE_CAPACITY_DEFAULT = "100";
public static final String
CAMEL_SOURCE_SMPP_COMPONENT_SESSION_STATE_LISTENER_CONF =
"camel.component.smpp.sessionStateListener";
public static final String
CAMEL_SOURCE_SMPP_COMPONENT_SESSION_STATE_LISTENER_DOC = "You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed.";
public static final String
CAMEL_SOURCE_SMPP_COMPONENT_SESSION_STATE_LISTENER_DEFAULT = null;
@@ -195,6 +207,8 @@ public class CamelSmppSourceConnectorConfig
conf.define(CAMEL_SOURCE_SMPP_ENDPOINT_EXCEPTION_HANDLER_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_SMPP_ENDPOINT_EXCEPTION_HANDLER_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SMPP_ENDPOINT_EXCEPTION_HANDLER_DOC);
conf.define(CAMEL_SOURCE_SMPP_ENDPOINT_EXCHANGE_PATTERN_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_SMPP_ENDPOINT_EXCHANGE_PATTERN_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SMPP_ENDPOINT_EXCHANGE_PATTERN_DOC);
conf.define(CAMEL_SOURCE_SMPP_ENDPOINT_ENQUIRE_LINK_TIMER_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_SMPP_ENDPOINT_ENQUIRE_LINK_TIMER_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SMPP_ENDPOINT_ENQUIRE_LINK_TIMER_DOC);
+ conf.define(CAMEL_SOURCE_SMPP_ENDPOINT_PDU_PROCESSOR_DEGREE_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_SMPP_ENDPOINT_PDU_PROCESSOR_DEGREE_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_SMPP_ENDPOINT_PDU_PROCESSOR_DEGREE_DOC);
+
conf.define(CAMEL_SOURCE_SMPP_ENDPOINT_PDU_PROCESSOR_QUEUE_CAPACITY_CONF,
ConfigDef.Type.STRING,
CAMEL_SOURCE_SMPP_ENDPOINT_PDU_PROCESSOR_QUEUE_CAPACITY_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_SMPP_ENDPOINT_PDU_PROCESSOR_QUEUE_CAPACITY_DOC);
conf.define(CAMEL_SOURCE_SMPP_ENDPOINT_SESSION_STATE_LISTENER_CONF,
ConfigDef.Type.STRING,
CAMEL_SOURCE_SMPP_ENDPOINT_SESSION_STATE_LISTENER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_SMPP_ENDPOINT_SESSION_STATE_LISTENER_DOC);
conf.define(CAMEL_SOURCE_SMPP_ENDPOINT_TRANSACTION_TIMER_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_SMPP_ENDPOINT_TRANSACTION_TIMER_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SMPP_ENDPOINT_TRANSACTION_TIMER_DOC);
conf.define(CAMEL_SOURCE_SMPP_ENDPOINT_ALPHABET_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_SMPP_ENDPOINT_ALPHABET_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SMPP_ENDPOINT_ALPHABET_DOC);
@@ -218,6 +232,8 @@ public class CamelSmppSourceConnectorConfig
conf.define(CAMEL_SOURCE_SMPP_COMPONENT_AUTOWIRED_ENABLED_CONF,
ConfigDef.Type.BOOLEAN, CAMEL_SOURCE_SMPP_COMPONENT_AUTOWIRED_ENABLED_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SMPP_COMPONENT_AUTOWIRED_ENABLED_DOC);
conf.define(CAMEL_SOURCE_SMPP_COMPONENT_CONFIGURATION_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_SMPP_COMPONENT_CONFIGURATION_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SMPP_COMPONENT_CONFIGURATION_DOC);
conf.define(CAMEL_SOURCE_SMPP_COMPONENT_ENQUIRE_LINK_TIMER_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_SMPP_COMPONENT_ENQUIRE_LINK_TIMER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_SMPP_COMPONENT_ENQUIRE_LINK_TIMER_DOC);
+ conf.define(CAMEL_SOURCE_SMPP_COMPONENT_PDU_PROCESSOR_DEGREE_CONF,
ConfigDef.Type.STRING,
CAMEL_SOURCE_SMPP_COMPONENT_PDU_PROCESSOR_DEGREE_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_SMPP_COMPONENT_PDU_PROCESSOR_DEGREE_DOC);
+
conf.define(CAMEL_SOURCE_SMPP_COMPONENT_PDU_PROCESSOR_QUEUE_CAPACITY_CONF,
ConfigDef.Type.STRING,
CAMEL_SOURCE_SMPP_COMPONENT_PDU_PROCESSOR_QUEUE_CAPACITY_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_SMPP_COMPONENT_PDU_PROCESSOR_QUEUE_CAPACITY_DOC);
conf.define(CAMEL_SOURCE_SMPP_COMPONENT_SESSION_STATE_LISTENER_CONF,
ConfigDef.Type.STRING,
CAMEL_SOURCE_SMPP_COMPONENT_SESSION_STATE_LISTENER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_SMPP_COMPONENT_SESSION_STATE_LISTENER_DOC);
conf.define(CAMEL_SOURCE_SMPP_COMPONENT_TRANSACTION_TIMER_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_SMPP_COMPONENT_TRANSACTION_TIMER_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SMPP_COMPONENT_TRANSACTION_TIMER_DOC);
conf.define(CAMEL_SOURCE_SMPP_COMPONENT_ALPHABET_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_SMPP_COMPONENT_ALPHABET_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SMPP_COMPONENT_ALPHABET_DOC);
diff --git
a/connectors/camel-smpps-kafka-connector/src/generated/resources/camel-smpps-sink.json
b/connectors/camel-smpps-kafka-connector/src/generated/resources/camel-smpps-sink.json
index 737b091..12c3967 100644
---
a/connectors/camel-smpps-kafka-connector/src/generated/resources/camel-smpps-sink.json
+++
b/connectors/camel-smpps-kafka-connector/src/generated/resources/camel-smpps-sink.json
@@ -249,6 +249,20 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.sink.endpoint.pduProcessorDegree": {
+ "name": "camel.sink.endpoint.pduProcessorDegree",
+ "description": "Sets the number of threads which can
read PDU and process them in parallel.",
+ "defaultValue": "\"3\"",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.sink.endpoint.pduProcessorQueueCapacity": {
+ "name": "camel.sink.endpoint.pduProcessorQueueCapacity",
+ "description": "Sets the capacity of the working queue
for PDU processing.",
+ "defaultValue": "\"100\"",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.sink.endpoint.sessionStateListener": {
"name": "camel.sink.endpoint.sessionStateListener",
"description": "You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed.",
@@ -576,6 +590,20 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.smpps.pduProcessorDegree": {
+ "name": "camel.component.smpps.pduProcessorDegree",
+ "description": "Sets the number of threads which can
read PDU and process them in parallel.",
+ "defaultValue": "\"3\"",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.component.smpps.pduProcessorQueueCapacity": {
+ "name":
"camel.component.smpps.pduProcessorQueueCapacity",
+ "description": "Sets the capacity of the working queue
for PDU processing.",
+ "defaultValue": "\"100\"",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.smpps.sessionStateListener": {
"name": "camel.component.smpps.sessionStateListener",
"description": "You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed.",
diff --git
a/connectors/camel-smpps-kafka-connector/src/generated/resources/camel-smpps-source.json
b/connectors/camel-smpps-kafka-connector/src/generated/resources/camel-smpps-source.json
index b6ca142..71e87c6 100644
---
a/connectors/camel-smpps-kafka-connector/src/generated/resources/camel-smpps-source.json
+++
b/connectors/camel-smpps-kafka-connector/src/generated/resources/camel-smpps-source.json
@@ -99,6 +99,20 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.source.endpoint.pduProcessorDegree": {
+ "name": "camel.source.endpoint.pduProcessorDegree",
+ "description": "Sets the number of threads which can
read PDU and process them in parallel.",
+ "defaultValue": "\"3\"",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.source.endpoint.pduProcessorQueueCapacity": {
+ "name":
"camel.source.endpoint.pduProcessorQueueCapacity",
+ "description": "Sets the capacity of the working queue
for PDU processing.",
+ "defaultValue": "\"100\"",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.source.endpoint.sessionStateListener": {
"name": "camel.source.endpoint.sessionStateListener",
"description": "You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed.",
@@ -259,6 +273,20 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.smpps.pduProcessorDegree": {
+ "name": "camel.component.smpps.pduProcessorDegree",
+ "description": "Sets the number of threads which can
read PDU and process them in parallel.",
+ "defaultValue": "\"3\"",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.component.smpps.pduProcessorQueueCapacity": {
+ "name":
"camel.component.smpps.pduProcessorQueueCapacity",
+ "description": "Sets the capacity of the working queue
for PDU processing.",
+ "defaultValue": "\"100\"",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.smpps.sessionStateListener": {
"name": "camel.component.smpps.sessionStateListener",
"description": "You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed.",
diff --git
a/connectors/camel-smpps-kafka-connector/src/main/docs/camel-smpps-kafka-sink-connector.adoc
b/connectors/camel-smpps-kafka-connector/src/main/docs/camel-smpps-kafka-sink-connector.adoc
index 8455ad3..cb86b1b 100644
---
a/connectors/camel-smpps-kafka-connector/src/main/docs/camel-smpps-kafka-sink-connector.adoc
+++
b/connectors/camel-smpps-kafka-connector/src/main/docs/camel-smpps-kafka-sink-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.smpps.CamelSmppsSinkConnector
----
-The camel-smpps sink connector supports 72 options, which are listed below.
+The camel-smpps sink connector supports 76 options, which are listed below.
@@ -54,6 +54,8 @@ The camel-smpps sink connector supports 72 options, which are
listed below.
| *camel.sink.endpoint.sourceAddrTon* | Defines the type of number (TON) to be
used in the SME originator address parameters. The following TON values are
defined: 0: Unknown 1: International 2: National 3: Network Specific 4:
Subscriber Number 5: Alphanumeric 6: Abbreviated One of: [0] [1] [2] [3] [4]
[5] [6] | null | false | MEDIUM
| *camel.sink.endpoint.typeOfNumber* | Defines the type of number (TON) to be
used in the SME. The following TON values are defined: 0: Unknown 1:
International 2: National 3: Network Specific 4: Subscriber Number 5:
Alphanumeric 6: Abbreviated One of: [0] [1] [2] [3] [4] [5] [6] | null | false
| MEDIUM
| *camel.sink.endpoint.enquireLinkTimer* | Defines the interval in
milliseconds between the confidence checks. The confidence check is used to
test the communication path between an ESME and an SMSC. | "60000" | false |
MEDIUM
+| *camel.sink.endpoint.pduProcessorDegree* | Sets the number of threads which
can read PDU and process them in parallel. | "3" | false | MEDIUM
+| *camel.sink.endpoint.pduProcessorQueueCapacity* | Sets the capacity of the
working queue for PDU processing. | "100" | false | MEDIUM
| *camel.sink.endpoint.sessionStateListener* | You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed. | null | false | MEDIUM
| *camel.sink.endpoint.transactionTimer* | Defines the maximum period of
inactivity allowed after a transaction, after which an SMPP entity may assume
that the session is no longer active. This timer may be active on either
communicating SMPP entity (i.e. SMSC or ESME). | "10000" | false | MEDIUM
| *camel.sink.endpoint.alphabet* | Defines encoding of data according the SMPP
3.4 specification, section 5.2.19. 0: SMSC Default Alphabet 4: 8 bit Alphabet
8: UCS2 Alphabet One of: [0] [4] [8] | null | false | MEDIUM
@@ -90,6 +92,8 @@ The camel-smpps sink connector supports 72 options, which are
listed below.
| *camel.component.smpps.autowiredEnabled* | Whether autowiring is enabled.
This is used for automatic autowiring options (the option must be marked as
autowired) by looking up in the registry to find if there is a single instance
of matching type, which then gets configured on the component. This can be used
for automatic configuring JDBC data sources, JMS connection factories, AWS
Clients, etc. | true | false | MEDIUM
| *camel.component.smpps.configuration* | To use the shared SmppConfiguration
as configuration. | null | false | MEDIUM
| *camel.component.smpps.enquireLinkTimer* | Defines the interval in
milliseconds between the confidence checks. The confidence check is used to
test the communication path between an ESME and an SMSC. | "60000" | false |
MEDIUM
+| *camel.component.smpps.pduProcessorDegree* | Sets the number of threads
which can read PDU and process them in parallel. | "3" | false | MEDIUM
+| *camel.component.smpps.pduProcessorQueueCapacity* | Sets the capacity of the
working queue for PDU processing. | "100" | false | MEDIUM
| *camel.component.smpps.sessionStateListener* | You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed. | null | false | MEDIUM
| *camel.component.smpps.transactionTimer* | Defines the maximum period of
inactivity allowed after a transaction, after which an SMPP entity may assume
that the session is no longer active. This timer may be active on either
communicating SMPP entity (i.e. SMSC or ESME). | "10000" | false | MEDIUM
| *camel.component.smpps.alphabet* | Defines encoding of data according the
SMPP 3.4 specification, section 5.2.19. 0: SMSC Default Alphabet 4: 8 bit
Alphabet 8: UCS2 Alphabet One of: [0] [4] [8] | null | false | MEDIUM
diff --git
a/connectors/camel-smpps-kafka-connector/src/main/docs/camel-smpps-kafka-source-connector.adoc
b/connectors/camel-smpps-kafka-connector/src/main/docs/camel-smpps-kafka-source-connector.adoc
index d2079c3..f86cc20 100644
---
a/connectors/camel-smpps-kafka-connector/src/main/docs/camel-smpps-kafka-source-connector.adoc
+++
b/connectors/camel-smpps-kafka-connector/src/main/docs/camel-smpps-kafka-source-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.smpps.CamelSmppsSourceConnector
----
-The camel-smpps source connector supports 48 options, which are listed below.
+The camel-smpps source connector supports 52 options, which are listed below.
@@ -43,6 +43,8 @@ The camel-smpps source connector supports 48 options, which
are listed below.
| *camel.source.endpoint.exceptionHandler* | To let the consumer use a custom
ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this
option is not in use. By default the consumer will deal with exceptions, that
will be logged at WARN or ERROR level and ignored. | null | false | MEDIUM
| *camel.source.endpoint.exchangePattern* | Sets the exchange pattern when the
consumer creates an exchange. One of: [InOnly] [InOut] [InOptionalOut] | null |
false | MEDIUM
| *camel.source.endpoint.enquireLinkTimer* | Defines the interval in
milliseconds between the confidence checks. The confidence check is used to
test the communication path between an ESME and an SMSC. | "60000" | false |
MEDIUM
+| *camel.source.endpoint.pduProcessorDegree* | Sets the number of threads
which can read PDU and process them in parallel. | "3" | false | MEDIUM
+| *camel.source.endpoint.pduProcessorQueueCapacity* | Sets the capacity of the
working queue for PDU processing. | "100" | false | MEDIUM
| *camel.source.endpoint.sessionStateListener* | You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed. | null | false | MEDIUM
| *camel.source.endpoint.transactionTimer* | Defines the maximum period of
inactivity allowed after a transaction, after which an SMPP entity may assume
that the session is no longer active. This timer may be active on either
communicating SMPP entity (i.e. SMSC or ESME). | "10000" | false | MEDIUM
| *camel.source.endpoint.alphabet* | Defines encoding of data according the
SMPP 3.4 specification, section 5.2.19. 0: SMSC Default Alphabet 4: 8 bit
Alphabet 8: UCS2 Alphabet One of: [0] [4] [8] | null | false | MEDIUM
@@ -66,6 +68,8 @@ The camel-smpps source connector supports 48 options, which
are listed below.
| *camel.component.smpps.autowiredEnabled* | Whether autowiring is enabled.
This is used for automatic autowiring options (the option must be marked as
autowired) by looking up in the registry to find if there is a single instance
of matching type, which then gets configured on the component. This can be used
for automatic configuring JDBC data sources, JMS connection factories, AWS
Clients, etc. | true | false | MEDIUM
| *camel.component.smpps.configuration* | To use the shared SmppConfiguration
as configuration. | null | false | MEDIUM
| *camel.component.smpps.enquireLinkTimer* | Defines the interval in
milliseconds between the confidence checks. The confidence check is used to
test the communication path between an ESME and an SMSC. | "60000" | false |
MEDIUM
+| *camel.component.smpps.pduProcessorDegree* | Sets the number of threads
which can read PDU and process them in parallel. | "3" | false | MEDIUM
+| *camel.component.smpps.pduProcessorQueueCapacity* | Sets the capacity of the
working queue for PDU processing. | "100" | false | MEDIUM
| *camel.component.smpps.sessionStateListener* | You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed. | null | false | MEDIUM
| *camel.component.smpps.transactionTimer* | Defines the maximum period of
inactivity allowed after a transaction, after which an SMPP entity may assume
that the session is no longer active. This timer may be active on either
communicating SMPP entity (i.e. SMSC or ESME). | "10000" | false | MEDIUM
| *camel.component.smpps.alphabet* | Defines encoding of data according the
SMPP 3.4 specification, section 5.2.19. 0: SMSC Default Alphabet 4: 8 bit
Alphabet 8: UCS2 Alphabet One of: [0] [4] [8] | null | false | MEDIUM
diff --git
a/connectors/camel-smpps-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/smpps/CamelSmppsSinkConnectorConfig.java
b/connectors/camel-smpps-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/smpps/CamelSmppsSinkConnectorConfig.java
index 9004755..8beef58 100644
---
a/connectors/camel-smpps-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/smpps/CamelSmppsSinkConnectorConfig.java
+++
b/connectors/camel-smpps-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/smpps/CamelSmppsSinkConnectorConfig.java
@@ -93,6 +93,12 @@ public class CamelSmppsSinkConnectorConfig extends
CamelSinkConnectorConfig {
public static final String
CAMEL_SINK_SMPPS_ENDPOINT_ENQUIRE_LINK_TIMER_CONF =
"camel.sink.endpoint.enquireLinkTimer";
public static final String
CAMEL_SINK_SMPPS_ENDPOINT_ENQUIRE_LINK_TIMER_DOC = "Defines the interval in
milliseconds between the confidence checks. The confidence check is used to
test the communication path between an ESME and an SMSC.";
public static final String
CAMEL_SINK_SMPPS_ENDPOINT_ENQUIRE_LINK_TIMER_DEFAULT = "60000";
+ public static final String
CAMEL_SINK_SMPPS_ENDPOINT_PDU_PROCESSOR_DEGREE_CONF =
"camel.sink.endpoint.pduProcessorDegree";
+ public static final String
CAMEL_SINK_SMPPS_ENDPOINT_PDU_PROCESSOR_DEGREE_DOC = "Sets the number of
threads which can read PDU and process them in parallel.";
+ public static final String
CAMEL_SINK_SMPPS_ENDPOINT_PDU_PROCESSOR_DEGREE_DEFAULT = "3";
+ public static final String
CAMEL_SINK_SMPPS_ENDPOINT_PDU_PROCESSOR_QUEUE_CAPACITY_CONF =
"camel.sink.endpoint.pduProcessorQueueCapacity";
+ public static final String
CAMEL_SINK_SMPPS_ENDPOINT_PDU_PROCESSOR_QUEUE_CAPACITY_DOC = "Sets the capacity
of the working queue for PDU processing.";
+ public static final String
CAMEL_SINK_SMPPS_ENDPOINT_PDU_PROCESSOR_QUEUE_CAPACITY_DEFAULT = "100";
public static final String
CAMEL_SINK_SMPPS_ENDPOINT_SESSION_STATE_LISTENER_CONF =
"camel.sink.endpoint.sessionStateListener";
public static final String
CAMEL_SINK_SMPPS_ENDPOINT_SESSION_STATE_LISTENER_DOC = "You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed.";
public static final String
CAMEL_SINK_SMPPS_ENDPOINT_SESSION_STATE_LISTENER_DEFAULT = null;
@@ -201,6 +207,12 @@ public class CamelSmppsSinkConnectorConfig extends
CamelSinkConnectorConfig {
public static final String
CAMEL_SINK_SMPPS_COMPONENT_ENQUIRE_LINK_TIMER_CONF =
"camel.component.smpps.enquireLinkTimer";
public static final String
CAMEL_SINK_SMPPS_COMPONENT_ENQUIRE_LINK_TIMER_DOC = "Defines the interval in
milliseconds between the confidence checks. The confidence check is used to
test the communication path between an ESME and an SMSC.";
public static final String
CAMEL_SINK_SMPPS_COMPONENT_ENQUIRE_LINK_TIMER_DEFAULT = "60000";
+ public static final String
CAMEL_SINK_SMPPS_COMPONENT_PDU_PROCESSOR_DEGREE_CONF =
"camel.component.smpps.pduProcessorDegree";
+ public static final String
CAMEL_SINK_SMPPS_COMPONENT_PDU_PROCESSOR_DEGREE_DOC = "Sets the number of
threads which can read PDU and process them in parallel.";
+ public static final String
CAMEL_SINK_SMPPS_COMPONENT_PDU_PROCESSOR_DEGREE_DEFAULT = "3";
+ public static final String
CAMEL_SINK_SMPPS_COMPONENT_PDU_PROCESSOR_QUEUE_CAPACITY_CONF =
"camel.component.smpps.pduProcessorQueueCapacity";
+ public static final String
CAMEL_SINK_SMPPS_COMPONENT_PDU_PROCESSOR_QUEUE_CAPACITY_DOC = "Sets the
capacity of the working queue for PDU processing.";
+ public static final String
CAMEL_SINK_SMPPS_COMPONENT_PDU_PROCESSOR_QUEUE_CAPACITY_DEFAULT = "100";
public static final String
CAMEL_SINK_SMPPS_COMPONENT_SESSION_STATE_LISTENER_CONF =
"camel.component.smpps.sessionStateListener";
public static final String
CAMEL_SINK_SMPPS_COMPONENT_SESSION_STATE_LISTENER_DOC = "You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed.";
public static final String
CAMEL_SINK_SMPPS_COMPONENT_SESSION_STATE_LISTENER_DEFAULT = null;
@@ -276,6 +288,8 @@ public class CamelSmppsSinkConnectorConfig extends
CamelSinkConnectorConfig {
conf.define(CAMEL_SINK_SMPPS_ENDPOINT_SOURCE_ADDR_TON_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SMPPS_ENDPOINT_SOURCE_ADDR_TON_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SMPPS_ENDPOINT_SOURCE_ADDR_TON_DOC);
conf.define(CAMEL_SINK_SMPPS_ENDPOINT_TYPE_OF_NUMBER_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SMPPS_ENDPOINT_TYPE_OF_NUMBER_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SMPPS_ENDPOINT_TYPE_OF_NUMBER_DOC);
conf.define(CAMEL_SINK_SMPPS_ENDPOINT_ENQUIRE_LINK_TIMER_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SMPPS_ENDPOINT_ENQUIRE_LINK_TIMER_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SMPPS_ENDPOINT_ENQUIRE_LINK_TIMER_DOC);
+ conf.define(CAMEL_SINK_SMPPS_ENDPOINT_PDU_PROCESSOR_DEGREE_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SMPPS_ENDPOINT_PDU_PROCESSOR_DEGREE_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_SMPPS_ENDPOINT_PDU_PROCESSOR_DEGREE_DOC);
+
conf.define(CAMEL_SINK_SMPPS_ENDPOINT_PDU_PROCESSOR_QUEUE_CAPACITY_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_SMPPS_ENDPOINT_PDU_PROCESSOR_QUEUE_CAPACITY_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_SMPPS_ENDPOINT_PDU_PROCESSOR_QUEUE_CAPACITY_DOC);
conf.define(CAMEL_SINK_SMPPS_ENDPOINT_SESSION_STATE_LISTENER_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_SMPPS_ENDPOINT_SESSION_STATE_LISTENER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_SMPPS_ENDPOINT_SESSION_STATE_LISTENER_DOC);
conf.define(CAMEL_SINK_SMPPS_ENDPOINT_TRANSACTION_TIMER_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SMPPS_ENDPOINT_TRANSACTION_TIMER_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SMPPS_ENDPOINT_TRANSACTION_TIMER_DOC);
conf.define(CAMEL_SINK_SMPPS_ENDPOINT_ALPHABET_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SMPPS_ENDPOINT_ALPHABET_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SMPPS_ENDPOINT_ALPHABET_DOC);
@@ -312,6 +326,8 @@ public class CamelSmppsSinkConnectorConfig extends
CamelSinkConnectorConfig {
conf.define(CAMEL_SINK_SMPPS_COMPONENT_AUTOWIRED_ENABLED_CONF,
ConfigDef.Type.BOOLEAN, CAMEL_SINK_SMPPS_COMPONENT_AUTOWIRED_ENABLED_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SMPPS_COMPONENT_AUTOWIRED_ENABLED_DOC);
conf.define(CAMEL_SINK_SMPPS_COMPONENT_CONFIGURATION_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SMPPS_COMPONENT_CONFIGURATION_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SMPPS_COMPONENT_CONFIGURATION_DOC);
conf.define(CAMEL_SINK_SMPPS_COMPONENT_ENQUIRE_LINK_TIMER_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SMPPS_COMPONENT_ENQUIRE_LINK_TIMER_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SMPPS_COMPONENT_ENQUIRE_LINK_TIMER_DOC);
+ conf.define(CAMEL_SINK_SMPPS_COMPONENT_PDU_PROCESSOR_DEGREE_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SMPPS_COMPONENT_PDU_PROCESSOR_DEGREE_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_SMPPS_COMPONENT_PDU_PROCESSOR_DEGREE_DOC);
+
conf.define(CAMEL_SINK_SMPPS_COMPONENT_PDU_PROCESSOR_QUEUE_CAPACITY_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_SMPPS_COMPONENT_PDU_PROCESSOR_QUEUE_CAPACITY_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_SMPPS_COMPONENT_PDU_PROCESSOR_QUEUE_CAPACITY_DOC);
conf.define(CAMEL_SINK_SMPPS_COMPONENT_SESSION_STATE_LISTENER_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_SMPPS_COMPONENT_SESSION_STATE_LISTENER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_SMPPS_COMPONENT_SESSION_STATE_LISTENER_DOC);
conf.define(CAMEL_SINK_SMPPS_COMPONENT_TRANSACTION_TIMER_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SMPPS_COMPONENT_TRANSACTION_TIMER_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SMPPS_COMPONENT_TRANSACTION_TIMER_DOC);
conf.define(CAMEL_SINK_SMPPS_COMPONENT_ALPHABET_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SMPPS_COMPONENT_ALPHABET_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SMPPS_COMPONENT_ALPHABET_DOC);
diff --git
a/connectors/camel-smpps-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/smpps/CamelSmppsSourceConnectorConfig.java
b/connectors/camel-smpps-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/smpps/CamelSmppsSourceConnectorConfig.java
index 9f4e2f1..26d9181 100644
---
a/connectors/camel-smpps-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/smpps/CamelSmppsSourceConnectorConfig.java
+++
b/connectors/camel-smpps-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/smpps/CamelSmppsSourceConnectorConfig.java
@@ -62,6 +62,12 @@ public class CamelSmppsSourceConnectorConfig
public static final String
CAMEL_SOURCE_SMPPS_ENDPOINT_ENQUIRE_LINK_TIMER_CONF =
"camel.source.endpoint.enquireLinkTimer";
public static final String
CAMEL_SOURCE_SMPPS_ENDPOINT_ENQUIRE_LINK_TIMER_DOC = "Defines the interval in
milliseconds between the confidence checks. The confidence check is used to
test the communication path between an ESME and an SMSC.";
public static final String
CAMEL_SOURCE_SMPPS_ENDPOINT_ENQUIRE_LINK_TIMER_DEFAULT = "60000";
+ public static final String
CAMEL_SOURCE_SMPPS_ENDPOINT_PDU_PROCESSOR_DEGREE_CONF =
"camel.source.endpoint.pduProcessorDegree";
+ public static final String
CAMEL_SOURCE_SMPPS_ENDPOINT_PDU_PROCESSOR_DEGREE_DOC = "Sets the number of
threads which can read PDU and process them in parallel.";
+ public static final String
CAMEL_SOURCE_SMPPS_ENDPOINT_PDU_PROCESSOR_DEGREE_DEFAULT = "3";
+ public static final String
CAMEL_SOURCE_SMPPS_ENDPOINT_PDU_PROCESSOR_QUEUE_CAPACITY_CONF =
"camel.source.endpoint.pduProcessorQueueCapacity";
+ public static final String
CAMEL_SOURCE_SMPPS_ENDPOINT_PDU_PROCESSOR_QUEUE_CAPACITY_DOC = "Sets the
capacity of the working queue for PDU processing.";
+ public static final String
CAMEL_SOURCE_SMPPS_ENDPOINT_PDU_PROCESSOR_QUEUE_CAPACITY_DEFAULT = "100";
public static final String
CAMEL_SOURCE_SMPPS_ENDPOINT_SESSION_STATE_LISTENER_CONF =
"camel.source.endpoint.sessionStateListener";
public static final String
CAMEL_SOURCE_SMPPS_ENDPOINT_SESSION_STATE_LISTENER_DOC = "You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed.";
public static final String
CAMEL_SOURCE_SMPPS_ENDPOINT_SESSION_STATE_LISTENER_DEFAULT = null;
@@ -131,6 +137,12 @@ public class CamelSmppsSourceConnectorConfig
public static final String
CAMEL_SOURCE_SMPPS_COMPONENT_ENQUIRE_LINK_TIMER_CONF =
"camel.component.smpps.enquireLinkTimer";
public static final String
CAMEL_SOURCE_SMPPS_COMPONENT_ENQUIRE_LINK_TIMER_DOC = "Defines the interval in
milliseconds between the confidence checks. The confidence check is used to
test the communication path between an ESME and an SMSC.";
public static final String
CAMEL_SOURCE_SMPPS_COMPONENT_ENQUIRE_LINK_TIMER_DEFAULT = "60000";
+ public static final String
CAMEL_SOURCE_SMPPS_COMPONENT_PDU_PROCESSOR_DEGREE_CONF =
"camel.component.smpps.pduProcessorDegree";
+ public static final String
CAMEL_SOURCE_SMPPS_COMPONENT_PDU_PROCESSOR_DEGREE_DOC = "Sets the number of
threads which can read PDU and process them in parallel.";
+ public static final String
CAMEL_SOURCE_SMPPS_COMPONENT_PDU_PROCESSOR_DEGREE_DEFAULT = "3";
+ public static final String
CAMEL_SOURCE_SMPPS_COMPONENT_PDU_PROCESSOR_QUEUE_CAPACITY_CONF =
"camel.component.smpps.pduProcessorQueueCapacity";
+ public static final String
CAMEL_SOURCE_SMPPS_COMPONENT_PDU_PROCESSOR_QUEUE_CAPACITY_DOC = "Sets the
capacity of the working queue for PDU processing.";
+ public static final String
CAMEL_SOURCE_SMPPS_COMPONENT_PDU_PROCESSOR_QUEUE_CAPACITY_DEFAULT = "100";
public static final String
CAMEL_SOURCE_SMPPS_COMPONENT_SESSION_STATE_LISTENER_CONF =
"camel.component.smpps.sessionStateListener";
public static final String
CAMEL_SOURCE_SMPPS_COMPONENT_SESSION_STATE_LISTENER_DOC = "You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed.";
public static final String
CAMEL_SOURCE_SMPPS_COMPONENT_SESSION_STATE_LISTENER_DEFAULT = null;
@@ -195,6 +207,8 @@ public class CamelSmppsSourceConnectorConfig
conf.define(CAMEL_SOURCE_SMPPS_ENDPOINT_EXCEPTION_HANDLER_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_SMPPS_ENDPOINT_EXCEPTION_HANDLER_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SMPPS_ENDPOINT_EXCEPTION_HANDLER_DOC);
conf.define(CAMEL_SOURCE_SMPPS_ENDPOINT_EXCHANGE_PATTERN_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_SMPPS_ENDPOINT_EXCHANGE_PATTERN_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SMPPS_ENDPOINT_EXCHANGE_PATTERN_DOC);
conf.define(CAMEL_SOURCE_SMPPS_ENDPOINT_ENQUIRE_LINK_TIMER_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_SMPPS_ENDPOINT_ENQUIRE_LINK_TIMER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_SMPPS_ENDPOINT_ENQUIRE_LINK_TIMER_DOC);
+ conf.define(CAMEL_SOURCE_SMPPS_ENDPOINT_PDU_PROCESSOR_DEGREE_CONF,
ConfigDef.Type.STRING,
CAMEL_SOURCE_SMPPS_ENDPOINT_PDU_PROCESSOR_DEGREE_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_SMPPS_ENDPOINT_PDU_PROCESSOR_DEGREE_DOC);
+
conf.define(CAMEL_SOURCE_SMPPS_ENDPOINT_PDU_PROCESSOR_QUEUE_CAPACITY_CONF,
ConfigDef.Type.STRING,
CAMEL_SOURCE_SMPPS_ENDPOINT_PDU_PROCESSOR_QUEUE_CAPACITY_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_SMPPS_ENDPOINT_PDU_PROCESSOR_QUEUE_CAPACITY_DOC);
conf.define(CAMEL_SOURCE_SMPPS_ENDPOINT_SESSION_STATE_LISTENER_CONF,
ConfigDef.Type.STRING,
CAMEL_SOURCE_SMPPS_ENDPOINT_SESSION_STATE_LISTENER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_SMPPS_ENDPOINT_SESSION_STATE_LISTENER_DOC);
conf.define(CAMEL_SOURCE_SMPPS_ENDPOINT_TRANSACTION_TIMER_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_SMPPS_ENDPOINT_TRANSACTION_TIMER_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SMPPS_ENDPOINT_TRANSACTION_TIMER_DOC);
conf.define(CAMEL_SOURCE_SMPPS_ENDPOINT_ALPHABET_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_SMPPS_ENDPOINT_ALPHABET_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SMPPS_ENDPOINT_ALPHABET_DOC);
@@ -218,6 +232,8 @@ public class CamelSmppsSourceConnectorConfig
conf.define(CAMEL_SOURCE_SMPPS_COMPONENT_AUTOWIRED_ENABLED_CONF,
ConfigDef.Type.BOOLEAN, CAMEL_SOURCE_SMPPS_COMPONENT_AUTOWIRED_ENABLED_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_SMPPS_COMPONENT_AUTOWIRED_ENABLED_DOC);
conf.define(CAMEL_SOURCE_SMPPS_COMPONENT_CONFIGURATION_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_SMPPS_COMPONENT_CONFIGURATION_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SMPPS_COMPONENT_CONFIGURATION_DOC);
conf.define(CAMEL_SOURCE_SMPPS_COMPONENT_ENQUIRE_LINK_TIMER_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_SMPPS_COMPONENT_ENQUIRE_LINK_TIMER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_SMPPS_COMPONENT_ENQUIRE_LINK_TIMER_DOC);
+ conf.define(CAMEL_SOURCE_SMPPS_COMPONENT_PDU_PROCESSOR_DEGREE_CONF,
ConfigDef.Type.STRING,
CAMEL_SOURCE_SMPPS_COMPONENT_PDU_PROCESSOR_DEGREE_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_SMPPS_COMPONENT_PDU_PROCESSOR_DEGREE_DOC);
+
conf.define(CAMEL_SOURCE_SMPPS_COMPONENT_PDU_PROCESSOR_QUEUE_CAPACITY_CONF,
ConfigDef.Type.STRING,
CAMEL_SOURCE_SMPPS_COMPONENT_PDU_PROCESSOR_QUEUE_CAPACITY_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_SMPPS_COMPONENT_PDU_PROCESSOR_QUEUE_CAPACITY_DOC);
conf.define(CAMEL_SOURCE_SMPPS_COMPONENT_SESSION_STATE_LISTENER_CONF,
ConfigDef.Type.STRING,
CAMEL_SOURCE_SMPPS_COMPONENT_SESSION_STATE_LISTENER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_SMPPS_COMPONENT_SESSION_STATE_LISTENER_DOC);
conf.define(CAMEL_SOURCE_SMPPS_COMPONENT_TRANSACTION_TIMER_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_SMPPS_COMPONENT_TRANSACTION_TIMER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_SMPPS_COMPONENT_TRANSACTION_TIMER_DOC);
conf.define(CAMEL_SOURCE_SMPPS_COMPONENT_ALPHABET_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_SMPPS_COMPONENT_ALPHABET_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SMPPS_COMPONENT_ALPHABET_DOC);
diff --git
a/docs/modules/ROOT/pages/connectors/camel-azure-cosmosdb-kafka-sink-connector.adoc
b/docs/modules/ROOT/pages/connectors/camel-azure-cosmosdb-kafka-sink-connector.adoc
index 579b593..9da6714 100644
---
a/docs/modules/ROOT/pages/connectors/camel-azure-cosmosdb-kafka-sink-connector.adoc
+++
b/docs/modules/ROOT/pages/connectors/camel-azure-cosmosdb-kafka-sink-connector.adoc
@@ -2,7 +2,7 @@
[[camel-azure-cosmosdb-kafka-connector-sink]]
= camel-azure-cosmosdb-kafka-connector sink configuration
-Connector Description: Azure Cosmos DB is Microsofts globally distributed,
multi-model database service for operational and analytics workloads. It offers
multi-mastering feature by automatically scaling throughput, compute, and
storage. This component interacts with Azure CosmosDB through Azure SQL API
+Connector Description: To read and write records to the CosmosDB database on
Azure cloud platform.
When using camel-azure-cosmosdb-kafka-connector as sink make sure to use the
following Maven dependency to have support for the connector:
@@ -92,8 +92,4 @@ The camel-azure-cosmosdb sink connector has no transforms out
of the box.
The camel-azure-cosmosdb sink connector has no aggregation strategies out of
the box.
-
-
-
-
// kafka-connector options: END
diff --git
a/docs/modules/ROOT/pages/connectors/camel-azure-cosmosdb-kafka-source-connector.adoc
b/docs/modules/ROOT/pages/connectors/camel-azure-cosmosdb-kafka-source-connector.adoc
index e4a95e4..8490e9f 100644
---
a/docs/modules/ROOT/pages/connectors/camel-azure-cosmosdb-kafka-source-connector.adoc
+++
b/docs/modules/ROOT/pages/connectors/camel-azure-cosmosdb-kafka-source-connector.adoc
@@ -2,7 +2,7 @@
[[camel-azure-cosmosdb-kafka-connector-source]]
= camel-azure-cosmosdb-kafka-connector source configuration
-Connector description: Azure Cosmos DB is Microsofts globally distributed,
multi-model database service for operational and analytics workloads. It offers
multi-mastering feature by automatically scaling throughput, compute, and
storage. This component interacts with Azure CosmosDB through Azure SQL API
+Connector description: To read and write records to the CosmosDB database on
Azure cloud platform.
When using camel-azure-cosmosdb-kafka-connector as source make sure to use the
following Maven dependency to have support for the connector:
@@ -96,8 +96,4 @@ The camel-azure-cosmosdb source connector has no transforms
out of the box.
The camel-azure-cosmosdb source connector has no aggregation strategies out of
the box.
-
-
-
-
// kafka-connector options: END
diff --git
a/docs/modules/ROOT/pages/connectors/camel-salesforce-kafka-sink-connector.adoc
b/docs/modules/ROOT/pages/connectors/camel-salesforce-kafka-sink-connector.adoc
index 07d2bf9..d43cb08 100644
---
a/docs/modules/ROOT/pages/connectors/camel-salesforce-kafka-sink-connector.adoc
+++
b/docs/modules/ROOT/pages/connectors/camel-salesforce-kafka-sink-connector.adoc
@@ -24,14 +24,14 @@
connector.class=org.apache.camel.kafkaconnector.salesforce.CamelSalesforceSinkCo
----
-The camel-salesforce sink connector supports 126 options, which are listed
below.
+The camel-salesforce sink connector supports 134 options, which are listed
below.
[width="100%",cols="2,5,^1,1,1",options="header"]
|===
| Name | Description | Default | Required | Priority
-| *camel.sink.path.operationName* | The operation to use One of: [getVersions]
[getResources] [getGlobalObjects] [getBasicInfo] [getDescription] [getSObject]
[createSObject] [updateSObject] [deleteSObject] [getSObjectWithId]
[upsertSObject] [deleteSObjectWithId] [getBlobField] [query] [queryMore]
[queryAll] [search] [apexCall] [recent] [createJob] [getJob] [closeJob]
[abortJob] [createBatch] [getBatch] [getAllBatches] [getRequest] [getResults]
[createBatchQuery] [getQueryResultIds] [getQ [...]
+| *camel.sink.path.operationName* | The operation to use One of: [getVersions]
[getResources] [getGlobalObjects] [getBasicInfo] [getDescription] [getSObject]
[createSObject] [updateSObject] [deleteSObject] [getSObjectWithId]
[upsertSObject] [deleteSObjectWithId] [getBlobField] [query] [queryMore]
[queryAll] [search] [apexCall] [recent] [createJob] [getJob] [closeJob]
[abortJob] [createBatch] [getBatch] [getAllBatches] [getRequest] [getResults]
[createBatchQuery] [getQueryResultIds] [getQ [...]
| *camel.sink.endpoint.apexMethod* | APEX method name | null | false | MEDIUM
| *camel.sink.endpoint.apexQueryParams* | Query params for APEX method | null
| false | MEDIUM
| *camel.sink.endpoint.apiVersion* | Salesforce API version. | "50.0" | false
| MEDIUM
@@ -78,6 +78,10 @@ The camel-salesforce sink connector supports 126 options,
which are listed below
| *camel.sink.endpoint.apexUrl* | APEX method URL | null | false | MEDIUM
| *camel.sink.endpoint.compositeMethod* | Composite (raw) method. | null |
false | MEDIUM
| *camel.sink.endpoint.lazyStartProducer* | Whether the producer should be
started lazy (on the first message). By starting lazy you can use this to allow
CamelContext and routes to startup in situations where a producer may otherwise
fail during starting and cause the route to fail being started. By deferring
this startup to be lazy then the startup failure can be handled during routing
messages via Camel's routing error handlers. Beware that when the first message
is processed then cre [...]
+| *camel.sink.endpoint.rawHttpHeaders* | Comma separated list of message
headers to include as HTTP parameters for Raw operation. | null | false | MEDIUM
+| *camel.sink.endpoint.rawMethod* | HTTP method to use for the Raw operation |
null | false | MEDIUM
+| *camel.sink.endpoint.rawPath* | The portion of the endpoint URL after the
domain name. E.g., '/services/data/v52.0/sobjects/Account/' | null | false |
MEDIUM
+| *camel.sink.endpoint.rawQueryParameters* | Comma separated list of message
headers to include as query parameters for Raw operation. Do not url-encode
values as this will be done automatically. | null | false | MEDIUM
| *camel.component.salesforce.apexMethod* | APEX method name | null | false |
MEDIUM
| *camel.component.salesforce.apexQueryParams* | Query params for APEX method
| null | false | MEDIUM
| *camel.component.salesforce.apiVersion* | Salesforce API version. | "50.0" |
false | MEDIUM
@@ -132,6 +136,10 @@ The camel-salesforce sink connector supports 126 options,
which are listed below
| *camel.component.salesforce.apexUrl* | APEX method URL | null | false |
MEDIUM
| *camel.component.salesforce.compositeMethod* | Composite (raw) method. |
null | false | MEDIUM
| *camel.component.salesforce.lazyStartProducer* | Whether the producer should
be started lazy (on the first message). By starting lazy you can use this to
allow CamelContext and routes to startup in situations where a producer may
otherwise fail during starting and cause the route to fail being started. By
deferring this startup to be lazy then the startup failure can be handled
during routing messages via Camel's routing error handlers. Beware that when
the first message is processed t [...]
+| *camel.component.salesforce.rawHttpHeaders* | Comma separated list of
message headers to include as HTTP parameters for Raw operation. | null | false
| MEDIUM
+| *camel.component.salesforce.rawMethod* | HTTP method to use for the Raw
operation | null | false | MEDIUM
+| *camel.component.salesforce.rawPath* | The portion of the endpoint URL after
the domain name. E.g., '/services/data/v52.0/sobjects/Account/' | null | false
| MEDIUM
+| *camel.component.salesforce.rawQueryParameters* | Comma separated list of
message headers to include as query parameters for Raw operation. Do not
url-encode values as this will be done automatically. | null | false | MEDIUM
| *camel.component.salesforce.autowiredEnabled* | Whether autowiring is
enabled. This is used for automatic autowiring options (the option must be
marked as autowired) by looking up in the registry to find if there is a single
instance of matching type, which then gets configured on the component. This
can be used for automatic configuring JDBC data sources, JMS connection
factories, AWS Clients, etc. | true | false | MEDIUM
| *camel.component.salesforce.httpProxyExcluded Addresses* | A list of
addresses for which HTTP proxy server should not be used. | null | false |
MEDIUM
| *camel.component.salesforce.httpProxyHost* | Hostname of the HTTP proxy
server to use. | null | false | MEDIUM
diff --git
a/docs/modules/ROOT/pages/connectors/camel-smpp-kafka-sink-connector.adoc
b/docs/modules/ROOT/pages/connectors/camel-smpp-kafka-sink-connector.adoc
index 76fdff8..0a071e3 100644
--- a/docs/modules/ROOT/pages/connectors/camel-smpp-kafka-sink-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-smpp-kafka-sink-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.smpp.CamelSmppSinkConnector
----
-The camel-smpp sink connector supports 72 options, which are listed below.
+The camel-smpp sink connector supports 76 options, which are listed below.
@@ -54,6 +54,8 @@ The camel-smpp sink connector supports 72 options, which are
listed below.
| *camel.sink.endpoint.sourceAddrTon* | Defines the type of number (TON) to be
used in the SME originator address parameters. The following TON values are
defined: 0: Unknown 1: International 2: National 3: Network Specific 4:
Subscriber Number 5: Alphanumeric 6: Abbreviated One of: [0] [1] [2] [3] [4]
[5] [6] | null | false | MEDIUM
| *camel.sink.endpoint.typeOfNumber* | Defines the type of number (TON) to be
used in the SME. The following TON values are defined: 0: Unknown 1:
International 2: National 3: Network Specific 4: Subscriber Number 5:
Alphanumeric 6: Abbreviated One of: [0] [1] [2] [3] [4] [5] [6] | null | false
| MEDIUM
| *camel.sink.endpoint.enquireLinkTimer* | Defines the interval in
milliseconds between the confidence checks. The confidence check is used to
test the communication path between an ESME and an SMSC. | "60000" | false |
MEDIUM
+| *camel.sink.endpoint.pduProcessorDegree* | Sets the number of threads which
can read PDU and process them in parallel. | "3" | false | MEDIUM
+| *camel.sink.endpoint.pduProcessorQueueCapacity* | Sets the capacity of the
working queue for PDU processing. | "100" | false | MEDIUM
| *camel.sink.endpoint.sessionStateListener* | You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed. | null | false | MEDIUM
| *camel.sink.endpoint.transactionTimer* | Defines the maximum period of
inactivity allowed after a transaction, after which an SMPP entity may assume
that the session is no longer active. This timer may be active on either
communicating SMPP entity (i.e. SMSC or ESME). | "10000" | false | MEDIUM
| *camel.sink.endpoint.alphabet* | Defines encoding of data according the SMPP
3.4 specification, section 5.2.19. 0: SMSC Default Alphabet 4: 8 bit Alphabet
8: UCS2 Alphabet One of: [0] [4] [8] | null | false | MEDIUM
@@ -90,6 +92,8 @@ The camel-smpp sink connector supports 72 options, which are
listed below.
| *camel.component.smpp.autowiredEnabled* | Whether autowiring is enabled.
This is used for automatic autowiring options (the option must be marked as
autowired) by looking up in the registry to find if there is a single instance
of matching type, which then gets configured on the component. This can be used
for automatic configuring JDBC data sources, JMS connection factories, AWS
Clients, etc. | true | false | MEDIUM
| *camel.component.smpp.configuration* | To use the shared SmppConfiguration
as configuration. | null | false | MEDIUM
| *camel.component.smpp.enquireLinkTimer* | Defines the interval in
milliseconds between the confidence checks. The confidence check is used to
test the communication path between an ESME and an SMSC. | "60000" | false |
MEDIUM
+| *camel.component.smpp.pduProcessorDegree* | Sets the number of threads which
can read PDU and process them in parallel. | "3" | false | MEDIUM
+| *camel.component.smpp.pduProcessorQueueCapacity* | Sets the capacity of the
working queue for PDU processing. | "100" | false | MEDIUM
| *camel.component.smpp.sessionStateListener* | You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed. | null | false | MEDIUM
| *camel.component.smpp.transactionTimer* | Defines the maximum period of
inactivity allowed after a transaction, after which an SMPP entity may assume
that the session is no longer active. This timer may be active on either
communicating SMPP entity (i.e. SMSC or ESME). | "10000" | false | MEDIUM
| *camel.component.smpp.alphabet* | Defines encoding of data according the
SMPP 3.4 specification, section 5.2.19. 0: SMSC Default Alphabet 4: 8 bit
Alphabet 8: UCS2 Alphabet One of: [0] [4] [8] | null | false | MEDIUM
diff --git
a/docs/modules/ROOT/pages/connectors/camel-smpp-kafka-source-connector.adoc
b/docs/modules/ROOT/pages/connectors/camel-smpp-kafka-source-connector.adoc
index 93c0f8f..57fc067 100644
--- a/docs/modules/ROOT/pages/connectors/camel-smpp-kafka-source-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-smpp-kafka-source-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.smpp.CamelSmppSourceConnector
----
-The camel-smpp source connector supports 48 options, which are listed below.
+The camel-smpp source connector supports 52 options, which are listed below.
@@ -43,6 +43,8 @@ The camel-smpp source connector supports 48 options, which
are listed below.
| *camel.source.endpoint.exceptionHandler* | To let the consumer use a custom
ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this
option is not in use. By default the consumer will deal with exceptions, that
will be logged at WARN or ERROR level and ignored. | null | false | MEDIUM
| *camel.source.endpoint.exchangePattern* | Sets the exchange pattern when the
consumer creates an exchange. One of: [InOnly] [InOut] [InOptionalOut] | null |
false | MEDIUM
| *camel.source.endpoint.enquireLinkTimer* | Defines the interval in
milliseconds between the confidence checks. The confidence check is used to
test the communication path between an ESME and an SMSC. | "60000" | false |
MEDIUM
+| *camel.source.endpoint.pduProcessorDegree* | Sets the number of threads
which can read PDU and process them in parallel. | "3" | false | MEDIUM
+| *camel.source.endpoint.pduProcessorQueueCapacity* | Sets the capacity of the
working queue for PDU processing. | "100" | false | MEDIUM
| *camel.source.endpoint.sessionStateListener* | You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed. | null | false | MEDIUM
| *camel.source.endpoint.transactionTimer* | Defines the maximum period of
inactivity allowed after a transaction, after which an SMPP entity may assume
that the session is no longer active. This timer may be active on either
communicating SMPP entity (i.e. SMSC or ESME). | "10000" | false | MEDIUM
| *camel.source.endpoint.alphabet* | Defines encoding of data according the
SMPP 3.4 specification, section 5.2.19. 0: SMSC Default Alphabet 4: 8 bit
Alphabet 8: UCS2 Alphabet One of: [0] [4] [8] | null | false | MEDIUM
@@ -66,6 +68,8 @@ The camel-smpp source connector supports 48 options, which
are listed below.
| *camel.component.smpp.autowiredEnabled* | Whether autowiring is enabled.
This is used for automatic autowiring options (the option must be marked as
autowired) by looking up in the registry to find if there is a single instance
of matching type, which then gets configured on the component. This can be used
for automatic configuring JDBC data sources, JMS connection factories, AWS
Clients, etc. | true | false | MEDIUM
| *camel.component.smpp.configuration* | To use the shared SmppConfiguration
as configuration. | null | false | MEDIUM
| *camel.component.smpp.enquireLinkTimer* | Defines the interval in
milliseconds between the confidence checks. The confidence check is used to
test the communication path between an ESME and an SMSC. | "60000" | false |
MEDIUM
+| *camel.component.smpp.pduProcessorDegree* | Sets the number of threads which
can read PDU and process them in parallel. | "3" | false | MEDIUM
+| *camel.component.smpp.pduProcessorQueueCapacity* | Sets the capacity of the
working queue for PDU processing. | "100" | false | MEDIUM
| *camel.component.smpp.sessionStateListener* | You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed. | null | false | MEDIUM
| *camel.component.smpp.transactionTimer* | Defines the maximum period of
inactivity allowed after a transaction, after which an SMPP entity may assume
that the session is no longer active. This timer may be active on either
communicating SMPP entity (i.e. SMSC or ESME). | "10000" | false | MEDIUM
| *camel.component.smpp.alphabet* | Defines encoding of data according the
SMPP 3.4 specification, section 5.2.19. 0: SMSC Default Alphabet 4: 8 bit
Alphabet 8: UCS2 Alphabet One of: [0] [4] [8] | null | false | MEDIUM
diff --git
a/docs/modules/ROOT/pages/connectors/camel-smpps-kafka-sink-connector.adoc
b/docs/modules/ROOT/pages/connectors/camel-smpps-kafka-sink-connector.adoc
index 8455ad3..cb86b1b 100644
--- a/docs/modules/ROOT/pages/connectors/camel-smpps-kafka-sink-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-smpps-kafka-sink-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.smpps.CamelSmppsSinkConnector
----
-The camel-smpps sink connector supports 72 options, which are listed below.
+The camel-smpps sink connector supports 76 options, which are listed below.
@@ -54,6 +54,8 @@ The camel-smpps sink connector supports 72 options, which are
listed below.
| *camel.sink.endpoint.sourceAddrTon* | Defines the type of number (TON) to be
used in the SME originator address parameters. The following TON values are
defined: 0: Unknown 1: International 2: National 3: Network Specific 4:
Subscriber Number 5: Alphanumeric 6: Abbreviated One of: [0] [1] [2] [3] [4]
[5] [6] | null | false | MEDIUM
| *camel.sink.endpoint.typeOfNumber* | Defines the type of number (TON) to be
used in the SME. The following TON values are defined: 0: Unknown 1:
International 2: National 3: Network Specific 4: Subscriber Number 5:
Alphanumeric 6: Abbreviated One of: [0] [1] [2] [3] [4] [5] [6] | null | false
| MEDIUM
| *camel.sink.endpoint.enquireLinkTimer* | Defines the interval in
milliseconds between the confidence checks. The confidence check is used to
test the communication path between an ESME and an SMSC. | "60000" | false |
MEDIUM
+| *camel.sink.endpoint.pduProcessorDegree* | Sets the number of threads which
can read PDU and process them in parallel. | "3" | false | MEDIUM
+| *camel.sink.endpoint.pduProcessorQueueCapacity* | Sets the capacity of the
working queue for PDU processing. | "100" | false | MEDIUM
| *camel.sink.endpoint.sessionStateListener* | You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed. | null | false | MEDIUM
| *camel.sink.endpoint.transactionTimer* | Defines the maximum period of
inactivity allowed after a transaction, after which an SMPP entity may assume
that the session is no longer active. This timer may be active on either
communicating SMPP entity (i.e. SMSC or ESME). | "10000" | false | MEDIUM
| *camel.sink.endpoint.alphabet* | Defines encoding of data according the SMPP
3.4 specification, section 5.2.19. 0: SMSC Default Alphabet 4: 8 bit Alphabet
8: UCS2 Alphabet One of: [0] [4] [8] | null | false | MEDIUM
@@ -90,6 +92,8 @@ The camel-smpps sink connector supports 72 options, which are
listed below.
| *camel.component.smpps.autowiredEnabled* | Whether autowiring is enabled.
This is used for automatic autowiring options (the option must be marked as
autowired) by looking up in the registry to find if there is a single instance
of matching type, which then gets configured on the component. This can be used
for automatic configuring JDBC data sources, JMS connection factories, AWS
Clients, etc. | true | false | MEDIUM
| *camel.component.smpps.configuration* | To use the shared SmppConfiguration
as configuration. | null | false | MEDIUM
| *camel.component.smpps.enquireLinkTimer* | Defines the interval in
milliseconds between the confidence checks. The confidence check is used to
test the communication path between an ESME and an SMSC. | "60000" | false |
MEDIUM
+| *camel.component.smpps.pduProcessorDegree* | Sets the number of threads
which can read PDU and process them in parallel. | "3" | false | MEDIUM
+| *camel.component.smpps.pduProcessorQueueCapacity* | Sets the capacity of the
working queue for PDU processing. | "100" | false | MEDIUM
| *camel.component.smpps.sessionStateListener* | You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed. | null | false | MEDIUM
| *camel.component.smpps.transactionTimer* | Defines the maximum period of
inactivity allowed after a transaction, after which an SMPP entity may assume
that the session is no longer active. This timer may be active on either
communicating SMPP entity (i.e. SMSC or ESME). | "10000" | false | MEDIUM
| *camel.component.smpps.alphabet* | Defines encoding of data according the
SMPP 3.4 specification, section 5.2.19. 0: SMSC Default Alphabet 4: 8 bit
Alphabet 8: UCS2 Alphabet One of: [0] [4] [8] | null | false | MEDIUM
diff --git
a/docs/modules/ROOT/pages/connectors/camel-smpps-kafka-source-connector.adoc
b/docs/modules/ROOT/pages/connectors/camel-smpps-kafka-source-connector.adoc
index d2079c3..f86cc20 100644
--- a/docs/modules/ROOT/pages/connectors/camel-smpps-kafka-source-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-smpps-kafka-source-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.smpps.CamelSmppsSourceConnector
----
-The camel-smpps source connector supports 48 options, which are listed below.
+The camel-smpps source connector supports 52 options, which are listed below.
@@ -43,6 +43,8 @@ The camel-smpps source connector supports 48 options, which
are listed below.
| *camel.source.endpoint.exceptionHandler* | To let the consumer use a custom
ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this
option is not in use. By default the consumer will deal with exceptions, that
will be logged at WARN or ERROR level and ignored. | null | false | MEDIUM
| *camel.source.endpoint.exchangePattern* | Sets the exchange pattern when the
consumer creates an exchange. One of: [InOnly] [InOut] [InOptionalOut] | null |
false | MEDIUM
| *camel.source.endpoint.enquireLinkTimer* | Defines the interval in
milliseconds between the confidence checks. The confidence check is used to
test the communication path between an ESME and an SMSC. | "60000" | false |
MEDIUM
+| *camel.source.endpoint.pduProcessorDegree* | Sets the number of threads
which can read PDU and process them in parallel. | "3" | false | MEDIUM
+| *camel.source.endpoint.pduProcessorQueueCapacity* | Sets the capacity of the
working queue for PDU processing. | "100" | false | MEDIUM
| *camel.source.endpoint.sessionStateListener* | You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed. | null | false | MEDIUM
| *camel.source.endpoint.transactionTimer* | Defines the maximum period of
inactivity allowed after a transaction, after which an SMPP entity may assume
that the session is no longer active. This timer may be active on either
communicating SMPP entity (i.e. SMSC or ESME). | "10000" | false | MEDIUM
| *camel.source.endpoint.alphabet* | Defines encoding of data according the
SMPP 3.4 specification, section 5.2.19. 0: SMSC Default Alphabet 4: 8 bit
Alphabet 8: UCS2 Alphabet One of: [0] [4] [8] | null | false | MEDIUM
@@ -66,6 +68,8 @@ The camel-smpps source connector supports 48 options, which
are listed below.
| *camel.component.smpps.autowiredEnabled* | Whether autowiring is enabled.
This is used for automatic autowiring options (the option must be marked as
autowired) by looking up in the registry to find if there is a single instance
of matching type, which then gets configured on the component. This can be used
for automatic configuring JDBC data sources, JMS connection factories, AWS
Clients, etc. | true | false | MEDIUM
| *camel.component.smpps.configuration* | To use the shared SmppConfiguration
as configuration. | null | false | MEDIUM
| *camel.component.smpps.enquireLinkTimer* | Defines the interval in
milliseconds between the confidence checks. The confidence check is used to
test the communication path between an ESME and an SMSC. | "60000" | false |
MEDIUM
+| *camel.component.smpps.pduProcessorDegree* | Sets the number of threads
which can read PDU and process them in parallel. | "3" | false | MEDIUM
+| *camel.component.smpps.pduProcessorQueueCapacity* | Sets the capacity of the
working queue for PDU processing. | "100" | false | MEDIUM
| *camel.component.smpps.sessionStateListener* | You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed. | null | false | MEDIUM
| *camel.component.smpps.transactionTimer* | Defines the maximum period of
inactivity allowed after a transaction, after which an SMPP entity may assume
that the session is no longer active. This timer may be active on either
communicating SMPP entity (i.e. SMSC or ESME). | "10000" | false | MEDIUM
| *camel.component.smpps.alphabet* | Defines encoding of data according the
SMPP 3.4 specification, section 5.2.19. 0: SMSC Default Alphabet 4: 8 bit
Alphabet 8: UCS2 Alphabet One of: [0] [4] [8] | null | false | MEDIUM
