This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch camel-master in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
The following commit(s) were added to refs/heads/camel-master by this push: new 107535d [create-pull-request] automated change 107535d is described below commit 107535d8582af457ef56f041a1e3181293002880 Author: github-actions[bot] <41898282+github-actions[bot]@users.noreply.github.com> AuthorDate: Fri Dec 11 03:24:14 2020 +0000 [create-pull-request] automated change --- .../connectors/camel-salesforce-sink.json | 36 ++++++++++++++-------- .../connectors/camel-salesforce-source.json | 12 -------- .../generated/resources/camel-salesforce-sink.json | 36 ++++++++++++++-------- .../resources/camel-salesforce-source.json | 12 -------- .../camel-salesforce-kafka-sink-connector.adoc | 8 +++-- .../camel-salesforce-kafka-source-connector.adoc | 4 +-- .../CamelSalesforceSinkConnectorConfig.java | 24 ++++++++++----- .../CamelSalesforceSourceConnectorConfig.java | 8 ----- .../camel-salesforce-kafka-sink-connector.adoc | 8 +++-- .../camel-salesforce-kafka-source-connector.adoc | 4 +-- 10 files changed, 76 insertions(+), 76 deletions(-) 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 66fbea2..129be83 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 @@ -27,12 +27,6 @@ "priority": "MEDIUM", "required": "false" }, - "camel.sink.endpoint.apexUrl": { - "name": "camel.sink.endpoint.apexUrl", - "description": "APEX method URL", - "priority": "MEDIUM", - "required": "false" - }, "camel.sink.endpoint.apiVersion": { "name": "camel.sink.endpoint.apiVersion", "description": "Salesforce API version.", @@ -250,6 +244,18 @@ "priority": "MEDIUM", "required": "false" }, + "camel.sink.endpoint.apexUrl": { + "name": "camel.sink.endpoint.apexUrl", + "description": "APEX method URL", + "priority": "MEDIUM", + "required": "false" + }, + "camel.sink.endpoint.compositeMethod": { + "name": "camel.sink.endpoint.compositeMethod", + "description": "Composite (raw) method.", + "priority": "MEDIUM", + "required": "false" + }, "camel.sink.endpoint.lazyStartProducer": { "name": "camel.sink.endpoint.lazyStartProducer", "description": "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 creating and starting the pr [...] @@ -276,12 +282,6 @@ "priority": "MEDIUM", "required": "false" }, - "camel.component.salesforce.apexUrl": { - "name": "camel.component.salesforce.apexUrl", - "description": "APEX method URL", - "priority": "MEDIUM", - "required": "false" - }, "camel.component.salesforce.apiVersion": { "name": "camel.component.salesforce.apiVersion", "description": "Salesforce API version.", @@ -550,6 +550,18 @@ "priority": "MEDIUM", "required": "false" }, + "camel.component.salesforce.apexUrl": { + "name": "camel.component.salesforce.apexUrl", + "description": "APEX method URL", + "priority": "MEDIUM", + "required": "false" + }, + "camel.component.salesforce.compositeMethod": { + "name": "camel.component.salesforce.compositeMethod", + "description": "Composite (raw) method.", + "priority": "MEDIUM", + "required": "false" + }, "camel.component.salesforce.lazyStartProducer": { "name": "camel.component.salesforce.lazyStartProducer", "description": "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 creating and starting the pr [...] diff --git a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-salesforce-source.json b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-salesforce-source.json index 91f1200..9160b32 100644 --- a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-salesforce-source.json +++ b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-salesforce-source.json @@ -27,12 +27,6 @@ "priority": "MEDIUM", "required": "false" }, - "camel.source.endpoint.apexUrl": { - "name": "camel.source.endpoint.apexUrl", - "description": "APEX method URL", - "priority": "MEDIUM", - "required": "false" - }, "camel.source.endpoint.apiVersion": { "name": "camel.source.endpoint.apiVersion", "description": "Salesforce API version.", @@ -294,12 +288,6 @@ "priority": "MEDIUM", "required": "false" }, - "camel.component.salesforce.apexUrl": { - "name": "camel.component.salesforce.apexUrl", - "description": "APEX method URL", - "priority": "MEDIUM", - "required": "false" - }, "camel.component.salesforce.apiVersion": { "name": "camel.component.salesforce.apiVersion", "description": "Salesforce API version.", 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 66fbea2..129be83 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 @@ -27,12 +27,6 @@ "priority": "MEDIUM", "required": "false" }, - "camel.sink.endpoint.apexUrl": { - "name": "camel.sink.endpoint.apexUrl", - "description": "APEX method URL", - "priority": "MEDIUM", - "required": "false" - }, "camel.sink.endpoint.apiVersion": { "name": "camel.sink.endpoint.apiVersion", "description": "Salesforce API version.", @@ -250,6 +244,18 @@ "priority": "MEDIUM", "required": "false" }, + "camel.sink.endpoint.apexUrl": { + "name": "camel.sink.endpoint.apexUrl", + "description": "APEX method URL", + "priority": "MEDIUM", + "required": "false" + }, + "camel.sink.endpoint.compositeMethod": { + "name": "camel.sink.endpoint.compositeMethod", + "description": "Composite (raw) method.", + "priority": "MEDIUM", + "required": "false" + }, "camel.sink.endpoint.lazyStartProducer": { "name": "camel.sink.endpoint.lazyStartProducer", "description": "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 creating and starting the pr [...] @@ -276,12 +282,6 @@ "priority": "MEDIUM", "required": "false" }, - "camel.component.salesforce.apexUrl": { - "name": "camel.component.salesforce.apexUrl", - "description": "APEX method URL", - "priority": "MEDIUM", - "required": "false" - }, "camel.component.salesforce.apiVersion": { "name": "camel.component.salesforce.apiVersion", "description": "Salesforce API version.", @@ -550,6 +550,18 @@ "priority": "MEDIUM", "required": "false" }, + "camel.component.salesforce.apexUrl": { + "name": "camel.component.salesforce.apexUrl", + "description": "APEX method URL", + "priority": "MEDIUM", + "required": "false" + }, + "camel.component.salesforce.compositeMethod": { + "name": "camel.component.salesforce.compositeMethod", + "description": "Composite (raw) method.", + "priority": "MEDIUM", + "required": "false" + }, "camel.component.salesforce.lazyStartProducer": { "name": "camel.component.salesforce.lazyStartProducer", "description": "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 creating and starting the pr [...] diff --git a/connectors/camel-salesforce-kafka-connector/src/generated/resources/camel-salesforce-source.json b/connectors/camel-salesforce-kafka-connector/src/generated/resources/camel-salesforce-source.json index 91f1200..9160b32 100644 --- a/connectors/camel-salesforce-kafka-connector/src/generated/resources/camel-salesforce-source.json +++ b/connectors/camel-salesforce-kafka-connector/src/generated/resources/camel-salesforce-source.json @@ -27,12 +27,6 @@ "priority": "MEDIUM", "required": "false" }, - "camel.source.endpoint.apexUrl": { - "name": "camel.source.endpoint.apexUrl", - "description": "APEX method URL", - "priority": "MEDIUM", - "required": "false" - }, "camel.source.endpoint.apiVersion": { "name": "camel.source.endpoint.apiVersion", "description": "Salesforce API version.", @@ -294,12 +288,6 @@ "priority": "MEDIUM", "required": "false" }, - "camel.component.salesforce.apexUrl": { - "name": "camel.component.salesforce.apexUrl", - "description": "APEX method URL", - "priority": "MEDIUM", - "required": "false" - }, "camel.component.salesforce.apiVersion": { "name": "camel.component.salesforce.apiVersion", "description": "Salesforce API version.", 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 5750222..465bb97 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 @@ -22,7 +22,7 @@ connector.class=org.apache.camel.kafkaconnector.salesforce.CamelSalesforceSinkCo ---- -The camel-salesforce sink connector supports 113 options, which are listed below. +The camel-salesforce sink connector supports 115 options, which are listed below. @@ -32,7 +32,6 @@ The camel-salesforce sink connector supports 113 options, which are listed below | *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.apexUrl* | APEX method URL | null | false | MEDIUM | *camel.sink.endpoint.apiVersion* | Salesforce API version. | "50.0" | false | MEDIUM | *camel.sink.endpoint.backoffIncrement* | Backoff interval increment for Streaming connection restart attempts for failures beyond CometD auto-reconnect. | 1000L | false | MEDIUM | *camel.sink.endpoint.batchId* | Bulk API Batch ID | null | false | MEDIUM @@ -68,11 +67,12 @@ The camel-salesforce sink connector supports 113 options, which are listed below | *camel.sink.endpoint.sObjectQuery* | Salesforce SOQL query string | null | false | MEDIUM | *camel.sink.endpoint.sObjectSearch* | Salesforce SOSL search string | null | false | MEDIUM | *camel.sink.endpoint.updateTopic* | Whether to update an existing Push Topic when using the Streaming API, defaults to false | false | false | MEDIUM +| *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.synchronous* | Sets whether synchronous processing should be strictly used, or Camel is allowed to use asynchronous processing (if supported). | false | 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.apexUrl* | APEX method URL | null | false | MEDIUM | *camel.component.salesforce.apiVersion* | Salesforce API version. | "50.0" | false | MEDIUM | *camel.component.salesforce.backoffIncrement* | Backoff interval increment for Streaming connection restart attempts for failures beyond CometD auto-reconnect. | 1000L | false | MEDIUM | *camel.component.salesforce.batchId* | Bulk API Batch ID | null | false | MEDIUM @@ -116,6 +116,8 @@ The camel-salesforce sink connector supports 113 options, which are listed below | *camel.component.salesforce.config* | Global endpoint configuration - use to set values that are common to all endpoints | null | false | MEDIUM | *camel.component.salesforce.httpClientProperties* | Used to set any properties that can be configured on the underlying HTTP client. Have a look at properties of SalesforceHttpClient and the Jetty HttpClient for all available options. | null | false | MEDIUM | *camel.component.salesforce.longPollingTransport Properties* | Used to set any properties that can be configured on the LongPollingTransport used by the BayeuxClient (CometD) used by the streaming api | null | false | MEDIUM +| *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.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 diff --git a/connectors/camel-salesforce-kafka-connector/src/main/docs/camel-salesforce-kafka-source-connector.adoc b/connectors/camel-salesforce-kafka-connector/src/main/docs/camel-salesforce-kafka-source-connector.adoc index 4fca6bc..f57838f 100644 --- a/connectors/camel-salesforce-kafka-connector/src/main/docs/camel-salesforce-kafka-source-connector.adoc +++ b/connectors/camel-salesforce-kafka-connector/src/main/docs/camel-salesforce-kafka-source-connector.adoc @@ -22,7 +22,7 @@ connector.class=org.apache.camel.kafkaconnector.salesforce.CamelSalesforceSource ---- -The camel-salesforce source connector supports 116 options, which are listed below. +The camel-salesforce source connector supports 114 options, which are listed below. @@ -32,7 +32,6 @@ The camel-salesforce source connector supports 116 options, which are listed bel | *camel.source.path.topicName* | The name of the topic/channel to use | null | false | MEDIUM | *camel.source.endpoint.apexMethod* | APEX method name | null | false | MEDIUM | *camel.source.endpoint.apexQueryParams* | Query params for APEX method | null | false | MEDIUM -| *camel.source.endpoint.apexUrl* | APEX method URL | null | false | MEDIUM | *camel.source.endpoint.apiVersion* | Salesforce API version. | "50.0" | false | MEDIUM | *camel.source.endpoint.backoffIncrement* | Backoff interval increment for Streaming connection restart attempts for failures beyond CometD auto-reconnect. | 1000L | false | MEDIUM | *camel.source.endpoint.batchId* | Bulk API Batch ID | null | false | MEDIUM @@ -75,7 +74,6 @@ The camel-salesforce source connector supports 116 options, which are listed bel | *camel.source.endpoint.synchronous* | Sets whether synchronous processing should be strictly used, or Camel is allowed to use asynchronous processing (if supported). | false | 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.apexUrl* | APEX method URL | null | false | MEDIUM | *camel.component.salesforce.apiVersion* | Salesforce API version. | "50.0" | false | MEDIUM | *camel.component.salesforce.backoffIncrement* | Backoff interval increment for Streaming connection restart attempts for failures beyond CometD auto-reconnect. | 1000L | false | MEDIUM | *camel.component.salesforce.batchId* | Bulk API Batch ID | 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 66e02ae..8b3b6f3 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 @@ -35,9 +35,6 @@ public class CamelSalesforceSinkConnectorConfig public static final String CAMEL_SINK_SALESFORCE_ENDPOINT_APEX_QUERY_PARAMS_CONF = "camel.sink.endpoint.apexQueryParams"; public static final String CAMEL_SINK_SALESFORCE_ENDPOINT_APEX_QUERY_PARAMS_DOC = "Query params for APEX method"; public static final String CAMEL_SINK_SALESFORCE_ENDPOINT_APEX_QUERY_PARAMS_DEFAULT = null; - public static final String CAMEL_SINK_SALESFORCE_ENDPOINT_APEX_URL_CONF = "camel.sink.endpoint.apexUrl"; - public static final String CAMEL_SINK_SALESFORCE_ENDPOINT_APEX_URL_DOC = "APEX method URL"; - public static final String CAMEL_SINK_SALESFORCE_ENDPOINT_APEX_URL_DEFAULT = null; public static final String CAMEL_SINK_SALESFORCE_ENDPOINT_API_VERSION_CONF = "camel.sink.endpoint.apiVersion"; public static final String CAMEL_SINK_SALESFORCE_ENDPOINT_API_VERSION_DOC = "Salesforce API version."; public static final String CAMEL_SINK_SALESFORCE_ENDPOINT_API_VERSION_DEFAULT = "50.0"; @@ -143,6 +140,12 @@ public class CamelSalesforceSinkConnectorConfig public static final String CAMEL_SINK_SALESFORCE_ENDPOINT_UPDATE_TOPIC_CONF = "camel.sink.endpoint.updateTopic"; public static final String CAMEL_SINK_SALESFORCE_ENDPOINT_UPDATE_TOPIC_DOC = "Whether to update an existing Push Topic when using the Streaming API, defaults to false"; public static final Boolean CAMEL_SINK_SALESFORCE_ENDPOINT_UPDATE_TOPIC_DEFAULT = false; + public static final String CAMEL_SINK_SALESFORCE_ENDPOINT_APEX_URL_CONF = "camel.sink.endpoint.apexUrl"; + public static final String CAMEL_SINK_SALESFORCE_ENDPOINT_APEX_URL_DOC = "APEX method URL"; + public static final String CAMEL_SINK_SALESFORCE_ENDPOINT_APEX_URL_DEFAULT = null; + public static final String CAMEL_SINK_SALESFORCE_ENDPOINT_COMPOSITE_METHOD_CONF = "camel.sink.endpoint.compositeMethod"; + public static final String CAMEL_SINK_SALESFORCE_ENDPOINT_COMPOSITE_METHOD_DOC = "Composite (raw) method."; + public static final String CAMEL_SINK_SALESFORCE_ENDPOINT_COMPOSITE_METHOD_DEFAULT = null; 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; @@ -155,9 +158,6 @@ public class CamelSalesforceSinkConnectorConfig public static final String CAMEL_SINK_SALESFORCE_COMPONENT_APEX_QUERY_PARAMS_CONF = "camel.component.salesforce.apexQueryParams"; public static final String CAMEL_SINK_SALESFORCE_COMPONENT_APEX_QUERY_PARAMS_DOC = "Query params for APEX method"; public static final String CAMEL_SINK_SALESFORCE_COMPONENT_APEX_QUERY_PARAMS_DEFAULT = null; - public static final String CAMEL_SINK_SALESFORCE_COMPONENT_APEX_URL_CONF = "camel.component.salesforce.apexUrl"; - public static final String CAMEL_SINK_SALESFORCE_COMPONENT_APEX_URL_DOC = "APEX method URL"; - public static final String CAMEL_SINK_SALESFORCE_COMPONENT_APEX_URL_DEFAULT = null; public static final String CAMEL_SINK_SALESFORCE_COMPONENT_API_VERSION_CONF = "camel.component.salesforce.apiVersion"; public static final String CAMEL_SINK_SALESFORCE_COMPONENT_API_VERSION_DOC = "Salesforce API version."; public static final String CAMEL_SINK_SALESFORCE_COMPONENT_API_VERSION_DEFAULT = "50.0"; @@ -287,6 +287,12 @@ public class CamelSalesforceSinkConnectorConfig public static final String CAMEL_SINK_SALESFORCE_COMPONENT_LONG_POLLING_TRANSPORT_PROPERTIES_CONF = "camel.component.salesforce.longPollingTransportProperties"; public static final String CAMEL_SINK_SALESFORCE_COMPONENT_LONG_POLLING_TRANSPORT_PROPERTIES_DOC = "Used to set any properties that can be configured on the LongPollingTransport used by the BayeuxClient (CometD) used by the streaming api"; public static final String CAMEL_SINK_SALESFORCE_COMPONENT_LONG_POLLING_TRANSPORT_PROPERTIES_DEFAULT = null; + public static final String CAMEL_SINK_SALESFORCE_COMPONENT_APEX_URL_CONF = "camel.component.salesforce.apexUrl"; + public static final String CAMEL_SINK_SALESFORCE_COMPONENT_APEX_URL_DOC = "APEX method URL"; + public static final String CAMEL_SINK_SALESFORCE_COMPONENT_APEX_URL_DEFAULT = null; + public static final String CAMEL_SINK_SALESFORCE_COMPONENT_COMPOSITE_METHOD_CONF = "camel.component.salesforce.compositeMethod"; + public static final String CAMEL_SINK_SALESFORCE_COMPONENT_COMPOSITE_METHOD_DOC = "Composite (raw) method."; + public static final String CAMEL_SINK_SALESFORCE_COMPONENT_COMPOSITE_METHOD_DEFAULT = null; 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; @@ -381,7 +387,6 @@ public class CamelSalesforceSinkConnectorConfig conf.define(CAMEL_SINK_SALESFORCE_PATH_OPERATION_NAME_CONF, ConfigDef.Type.STRING, CAMEL_SINK_SALESFORCE_PATH_OPERATION_NAME_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_SALESFORCE_PATH_OPERATION_NAME_DOC); conf.define(CAMEL_SINK_SALESFORCE_ENDPOINT_APEX_METHOD_CONF, ConfigDef.Type.STRING, CAMEL_SINK_SALESFORCE_ENDPOINT_APEX_METHOD_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_SALESFORCE_ENDPOINT_APEX_METHOD_DOC); conf.define(CAMEL_SINK_SALESFORCE_ENDPOINT_APEX_QUERY_PARAMS_CONF, ConfigDef.Type.STRING, CAMEL_SINK_SALESFORCE_ENDPOINT_APEX_QUERY_PARAMS_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_SALESFORCE_ENDPOINT_APEX_QUERY_PARAMS_DOC); - 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_API_VERSION_CONF, ConfigDef.Type.STRING, CAMEL_SINK_SALESFORCE_ENDPOINT_API_VERSION_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_SALESFORCE_ENDPOINT_API_VERSION_DOC); conf.define(CAMEL_SINK_SALESFORCE_ENDPOINT_BACKOFF_INCREMENT_CONF, ConfigDef.Type.LONG, CAMEL_SINK_SALESFORCE_ENDPOINT_BACKOFF_INCREMENT_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_SALESFORCE_ENDPOINT_BACKOFF_INCREMENT_DOC); conf.define(CAMEL_SINK_SALESFORCE_ENDPOINT_BATCH_ID_CONF, ConfigDef.Type.STRING, CAMEL_SINK_SALESFORCE_ENDPOINT_BATCH_ID_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_SALESFORCE_ENDPOINT_BATCH_ID_DOC); @@ -417,11 +422,12 @@ public class CamelSalesforceSinkConnectorConfig conf.define(CAMEL_SINK_SALESFORCE_ENDPOINT_SOBJECT_QUERY_CONF, ConfigDef.Type.STRING, CAMEL_SINK_SALESFORCE_ENDPOINT_SOBJECT_QUERY_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_SALESFORCE_ENDPOINT_SOBJECT_QUERY_DOC); conf.define(CAMEL_SINK_SALESFORCE_ENDPOINT_SOBJECT_SEARCH_CONF, ConfigDef.Type.STRING, CAMEL_SINK_SALESFORCE_ENDPOINT_SOBJECT_SEARCH_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_SALESFORCE_ENDPOINT_SOBJECT_SEARCH_DOC); conf.define(CAMEL_SINK_SALESFORCE_ENDPOINT_UPDATE_TOPIC_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SINK_SALESFORCE_ENDPOINT_UPDATE_TOPIC_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_SALESFORCE_ENDPOINT_UPDATE_TOPIC_DOC); + 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_SYNCHRONOUS_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SINK_SALESFORCE_ENDPOINT_SYNCHRONOUS_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_SALESFORCE_ENDPOINT_SYNCHRONOUS_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_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_API_VERSION_CONF, ConfigDef.Type.STRING, CAMEL_SINK_SALESFORCE_COMPONENT_API_VERSION_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_SALESFORCE_COMPONENT_API_VERSION_DOC); conf.define(CAMEL_SINK_SALESFORCE_COMPONENT_BACKOFF_INCREMENT_CONF, ConfigDef.Type.LONG, CAMEL_SINK_SALESFORCE_COMPONENT_BACKOFF_INCREMENT_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_SALESFORCE_COMPONENT_BACKOFF_INCREMENT_DOC); conf.define(CAMEL_SINK_SALESFORCE_COMPONENT_BATCH_ID_CONF, ConfigDef.Type.STRING, CAMEL_SINK_SALESFORCE_COMPONENT_BATCH_ID_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_SALESFORCE_COMPONENT_BATCH_ID_DOC); @@ -465,6 +471,8 @@ public class CamelSalesforceSinkConnectorConfig conf.define(CAMEL_SINK_SALESFORCE_COMPONENT_CONFIG_CONF, ConfigDef.Type.STRING, CAMEL_SINK_SALESFORCE_COMPONENT_CONFIG_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_SALESFORCE_COMPONENT_CONFIG_DOC); conf.define(CAMEL_SINK_SALESFORCE_COMPONENT_HTTP_CLIENT_PROPERTIES_CONF, ConfigDef.Type.STRING, CAMEL_SINK_SALESFORCE_COMPONENT_HTTP_CLIENT_PROPERTIES_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_SALESFORCE_COMPONENT_HTTP_CLIENT_PROPERTIES_DOC); conf.define(CAMEL_SINK_SALESFORCE_COMPONENT_LONG_POLLING_TRANSPORT_PROPERTIES_CONF, ConfigDef.Type.STRING, CAMEL_SINK_SALESFORCE_COMPONENT_LONG_POLLING_TRANSPORT_PROPERTIES_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_SALESFORCE_COMPONENT_LONG_POLLING_TRANSPORT_PROPERTIES_DOC); + 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_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); diff --git a/connectors/camel-salesforce-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/salesforce/CamelSalesforceSourceConnectorConfig.java b/connectors/camel-salesforce-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/salesforce/CamelSalesforceSourceConnectorConfig.java index 56f8df9..81c71ef 100644 --- a/connectors/camel-salesforce-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/salesforce/CamelSalesforceSourceConnectorConfig.java +++ b/connectors/camel-salesforce-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/salesforce/CamelSalesforceSourceConnectorConfig.java @@ -35,9 +35,6 @@ public class CamelSalesforceSourceConnectorConfig public static final String CAMEL_SOURCE_SALESFORCE_ENDPOINT_APEX_QUERY_PARAMS_CONF = "camel.source.endpoint.apexQueryParams"; public static final String CAMEL_SOURCE_SALESFORCE_ENDPOINT_APEX_QUERY_PARAMS_DOC = "Query params for APEX method"; public static final String CAMEL_SOURCE_SALESFORCE_ENDPOINT_APEX_QUERY_PARAMS_DEFAULT = null; - public static final String CAMEL_SOURCE_SALESFORCE_ENDPOINT_APEX_URL_CONF = "camel.source.endpoint.apexUrl"; - public static final String CAMEL_SOURCE_SALESFORCE_ENDPOINT_APEX_URL_DOC = "APEX method URL"; - public static final String CAMEL_SOURCE_SALESFORCE_ENDPOINT_APEX_URL_DEFAULT = null; public static final String CAMEL_SOURCE_SALESFORCE_ENDPOINT_API_VERSION_CONF = "camel.source.endpoint.apiVersion"; public static final String CAMEL_SOURCE_SALESFORCE_ENDPOINT_API_VERSION_DOC = "Salesforce API version."; public static final String CAMEL_SOURCE_SALESFORCE_ENDPOINT_API_VERSION_DEFAULT = "50.0"; @@ -164,9 +161,6 @@ public class CamelSalesforceSourceConnectorConfig public static final String CAMEL_SOURCE_SALESFORCE_COMPONENT_APEX_QUERY_PARAMS_CONF = "camel.component.salesforce.apexQueryParams"; public static final String CAMEL_SOURCE_SALESFORCE_COMPONENT_APEX_QUERY_PARAMS_DOC = "Query params for APEX method"; public static final String CAMEL_SOURCE_SALESFORCE_COMPONENT_APEX_QUERY_PARAMS_DEFAULT = null; - public static final String CAMEL_SOURCE_SALESFORCE_COMPONENT_APEX_URL_CONF = "camel.component.salesforce.apexUrl"; - public static final String CAMEL_SOURCE_SALESFORCE_COMPONENT_APEX_URL_DOC = "APEX method URL"; - public static final String CAMEL_SOURCE_SALESFORCE_COMPONENT_APEX_URL_DEFAULT = null; public static final String CAMEL_SOURCE_SALESFORCE_COMPONENT_API_VERSION_CONF = "camel.component.salesforce.apiVersion"; public static final String CAMEL_SOURCE_SALESFORCE_COMPONENT_API_VERSION_DOC = "Salesforce API version."; public static final String CAMEL_SOURCE_SALESFORCE_COMPONENT_API_VERSION_DEFAULT = "50.0"; @@ -390,7 +384,6 @@ public class CamelSalesforceSourceConnectorConfig conf.define(CAMEL_SOURCE_SALESFORCE_PATH_TOPIC_NAME_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_SALESFORCE_PATH_TOPIC_NAME_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SALESFORCE_PATH_TOPIC_NAME_DOC); conf.define(CAMEL_SOURCE_SALESFORCE_ENDPOINT_APEX_METHOD_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_SALESFORCE_ENDPOINT_APEX_METHOD_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SALESFORCE_ENDPOINT_APEX_METHOD_DOC); conf.define(CAMEL_SOURCE_SALESFORCE_ENDPOINT_APEX_QUERY_PARAMS_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_SALESFORCE_ENDPOINT_APEX_QUERY_PARAMS_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SALESFORCE_ENDPOINT_APEX_QUERY_PARAMS_DOC); - conf.define(CAMEL_SOURCE_SALESFORCE_ENDPOINT_APEX_URL_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_SALESFORCE_ENDPOINT_APEX_URL_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SALESFORCE_ENDPOINT_APEX_URL_DOC); conf.define(CAMEL_SOURCE_SALESFORCE_ENDPOINT_API_VERSION_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_SALESFORCE_ENDPOINT_API_VERSION_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SALESFORCE_ENDPOINT_API_VERSION_DOC); conf.define(CAMEL_SOURCE_SALESFORCE_ENDPOINT_BACKOFF_INCREMENT_CONF, ConfigDef.Type.LONG, CAMEL_SOURCE_SALESFORCE_ENDPOINT_BACKOFF_INCREMENT_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SALESFORCE_ENDPOINT_BACKOFF_INCREMENT_DOC); conf.define(CAMEL_SOURCE_SALESFORCE_ENDPOINT_BATCH_ID_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_SALESFORCE_ENDPOINT_BATCH_ID_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SALESFORCE_ENDPOINT_BATCH_ID_DOC); @@ -433,7 +426,6 @@ public class CamelSalesforceSourceConnectorConfig conf.define(CAMEL_SOURCE_SALESFORCE_ENDPOINT_SYNCHRONOUS_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SOURCE_SALESFORCE_ENDPOINT_SYNCHRONOUS_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SALESFORCE_ENDPOINT_SYNCHRONOUS_DOC); conf.define(CAMEL_SOURCE_SALESFORCE_COMPONENT_APEX_METHOD_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_SALESFORCE_COMPONENT_APEX_METHOD_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SALESFORCE_COMPONENT_APEX_METHOD_DOC); conf.define(CAMEL_SOURCE_SALESFORCE_COMPONENT_APEX_QUERY_PARAMS_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_SALESFORCE_COMPONENT_APEX_QUERY_PARAMS_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SALESFORCE_COMPONENT_APEX_QUERY_PARAMS_DOC); - conf.define(CAMEL_SOURCE_SALESFORCE_COMPONENT_APEX_URL_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_SALESFORCE_COMPONENT_APEX_URL_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SALESFORCE_COMPONENT_APEX_URL_DOC); conf.define(CAMEL_SOURCE_SALESFORCE_COMPONENT_API_VERSION_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_SALESFORCE_COMPONENT_API_VERSION_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SALESFORCE_COMPONENT_API_VERSION_DOC); conf.define(CAMEL_SOURCE_SALESFORCE_COMPONENT_BACKOFF_INCREMENT_CONF, ConfigDef.Type.LONG, CAMEL_SOURCE_SALESFORCE_COMPONENT_BACKOFF_INCREMENT_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SALESFORCE_COMPONENT_BACKOFF_INCREMENT_DOC); conf.define(CAMEL_SOURCE_SALESFORCE_COMPONENT_BATCH_ID_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_SALESFORCE_COMPONENT_BATCH_ID_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SALESFORCE_COMPONENT_BATCH_ID_DOC); 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 5750222..465bb97 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 @@ -22,7 +22,7 @@ connector.class=org.apache.camel.kafkaconnector.salesforce.CamelSalesforceSinkCo ---- -The camel-salesforce sink connector supports 113 options, which are listed below. +The camel-salesforce sink connector supports 115 options, which are listed below. @@ -32,7 +32,6 @@ The camel-salesforce sink connector supports 113 options, which are listed below | *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.apexUrl* | APEX method URL | null | false | MEDIUM | *camel.sink.endpoint.apiVersion* | Salesforce API version. | "50.0" | false | MEDIUM | *camel.sink.endpoint.backoffIncrement* | Backoff interval increment for Streaming connection restart attempts for failures beyond CometD auto-reconnect. | 1000L | false | MEDIUM | *camel.sink.endpoint.batchId* | Bulk API Batch ID | null | false | MEDIUM @@ -68,11 +67,12 @@ The camel-salesforce sink connector supports 113 options, which are listed below | *camel.sink.endpoint.sObjectQuery* | Salesforce SOQL query string | null | false | MEDIUM | *camel.sink.endpoint.sObjectSearch* | Salesforce SOSL search string | null | false | MEDIUM | *camel.sink.endpoint.updateTopic* | Whether to update an existing Push Topic when using the Streaming API, defaults to false | false | false | MEDIUM +| *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.synchronous* | Sets whether synchronous processing should be strictly used, or Camel is allowed to use asynchronous processing (if supported). | false | 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.apexUrl* | APEX method URL | null | false | MEDIUM | *camel.component.salesforce.apiVersion* | Salesforce API version. | "50.0" | false | MEDIUM | *camel.component.salesforce.backoffIncrement* | Backoff interval increment for Streaming connection restart attempts for failures beyond CometD auto-reconnect. | 1000L | false | MEDIUM | *camel.component.salesforce.batchId* | Bulk API Batch ID | null | false | MEDIUM @@ -116,6 +116,8 @@ The camel-salesforce sink connector supports 113 options, which are listed below | *camel.component.salesforce.config* | Global endpoint configuration - use to set values that are common to all endpoints | null | false | MEDIUM | *camel.component.salesforce.httpClientProperties* | Used to set any properties that can be configured on the underlying HTTP client. Have a look at properties of SalesforceHttpClient and the Jetty HttpClient for all available options. | null | false | MEDIUM | *camel.component.salesforce.longPollingTransport Properties* | Used to set any properties that can be configured on the LongPollingTransport used by the BayeuxClient (CometD) used by the streaming api | null | false | MEDIUM +| *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.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 diff --git a/docs/modules/ROOT/pages/connectors/camel-salesforce-kafka-source-connector.adoc b/docs/modules/ROOT/pages/connectors/camel-salesforce-kafka-source-connector.adoc index 4fca6bc..f57838f 100644 --- a/docs/modules/ROOT/pages/connectors/camel-salesforce-kafka-source-connector.adoc +++ b/docs/modules/ROOT/pages/connectors/camel-salesforce-kafka-source-connector.adoc @@ -22,7 +22,7 @@ connector.class=org.apache.camel.kafkaconnector.salesforce.CamelSalesforceSource ---- -The camel-salesforce source connector supports 116 options, which are listed below. +The camel-salesforce source connector supports 114 options, which are listed below. @@ -32,7 +32,6 @@ The camel-salesforce source connector supports 116 options, which are listed bel | *camel.source.path.topicName* | The name of the topic/channel to use | null | false | MEDIUM | *camel.source.endpoint.apexMethod* | APEX method name | null | false | MEDIUM | *camel.source.endpoint.apexQueryParams* | Query params for APEX method | null | false | MEDIUM -| *camel.source.endpoint.apexUrl* | APEX method URL | null | false | MEDIUM | *camel.source.endpoint.apiVersion* | Salesforce API version. | "50.0" | false | MEDIUM | *camel.source.endpoint.backoffIncrement* | Backoff interval increment for Streaming connection restart attempts for failures beyond CometD auto-reconnect. | 1000L | false | MEDIUM | *camel.source.endpoint.batchId* | Bulk API Batch ID | null | false | MEDIUM @@ -75,7 +74,6 @@ The camel-salesforce source connector supports 116 options, which are listed bel | *camel.source.endpoint.synchronous* | Sets whether synchronous processing should be strictly used, or Camel is allowed to use asynchronous processing (if supported). | false | 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.apexUrl* | APEX method URL | null | false | MEDIUM | *camel.component.salesforce.apiVersion* | Salesforce API version. | "50.0" | false | MEDIUM | *camel.component.salesforce.backoffIncrement* | Backoff interval increment for Streaming connection restart attempts for failures beyond CometD auto-reconnect. | 1000L | false | MEDIUM | *camel.component.salesforce.batchId* | Bulk API Batch ID | null | false | MEDIUM