You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by je...@apache.org on 2024/01/04 20:26:11 UTC
(camel) branch main updated (031d6b0fe22 -> 682a7de070c)
This is an automated email from the ASF dual-hosted git repository.
jeremyross pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
from 031d6b0fe22 Bump io.smallrye:smallrye-health from 4.0.4 to 4.1.0
new 0267211e9b5 CAMEL-17719: camel-salesforce: Add operation to get event schemas
new 682a7de070c CAMEL-17719: camel-salesforce: Add operation to get event schemas
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../salesforce/SalesforceComponentConfigurer.java | 18 +++++
.../salesforce/SalesforceEndpointConfigurer.java | 18 +++++
.../salesforce/SalesforceEndpointUriFactory.java | 5 +-
.../camel/component/salesforce/salesforce.json | 84 ++++++++++++----------
.../src/main/docs/salesforce-component.adoc | 20 ++++++
.../component/salesforce/SalesforceEndpoint.java | 4 +-
.../salesforce/SalesforceEndpointConfig.java | 55 +++++++++++++-
.../component/salesforce/SalesforceProducer.java | 2 +-
.../component/salesforce/api/utils/JsonUtils.java | 75 +++++++++++++++++--
.../salesforce/internal/OperationName.java | 1 +
.../internal/client/DefaultRestClient.java | 37 ++++++++++
.../salesforce/internal/client/RestClient.java | 18 +++++
...rFieldsEnum.java => EventSchemaFormatEnum.java} | 29 +++-----
.../internal/processor/AbstractRestProcessor.java | 26 +++++++
.../internal/processor/SalesforceProcessor.java | 2 -
.../salesforce/RestApiIntegrationTest.java | 31 ++++++++
16 files changed, 354 insertions(+), 71 deletions(-)
copy components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/dto/{NotifyForFieldsEnum.java => EventSchemaFormatEnum.java} (67%)
(camel) 02/02: CAMEL-17719: camel-salesforce: Add operation to get event schemas
Posted by je...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
jeremyross pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 682a7de070c9110093f763b00db59d9966bfab82
Author: Jeremy Ross <je...@gmail.com>
AuthorDate: Thu Jan 4 14:25:52 2024 -0600
CAMEL-17719: camel-salesforce: Add operation to get event schemas
Event schemas are Avro schemas and support Platform Events,
Change Data Capture events, and custom events.
---
.../org/apache/camel/component/salesforce/RestApiIntegrationTest.java | 1 -
1 file changed, 1 deletion(-)
diff --git a/components/camel-salesforce/camel-salesforce-component/src/test/java/org/apache/camel/component/salesforce/RestApiIntegrationTest.java b/components/camel-salesforce/camel-salesforce-component/src/test/java/org/apache/camel/component/salesforce/RestApiIntegrationTest.java
index e8fa5e95704..a4b91c047a9 100644
--- a/components/camel-salesforce/camel-salesforce-component/src/test/java/org/apache/camel/component/salesforce/RestApiIntegrationTest.java
+++ b/components/camel-salesforce/camel-salesforce-component/src/test/java/org/apache/camel/component/salesforce/RestApiIntegrationTest.java
@@ -554,7 +554,6 @@ public class RestApiIntegrationTest extends AbstractSalesforceTestBase {
final String schemaId = (String) map.get("uuid");
final Object idResult = template.requestBodyAndHeader("salesforce:getEventSchema", "", EVENT_SCHEMA_ID, schemaId);
- System.out.println(idResult);
assertNotNull(idResult);
}
(camel) 01/02: CAMEL-17719: camel-salesforce: Add operation to get event schemas
Posted by je...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
jeremyross pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 0267211e9b5bb1be8628331bb6ac07293e692037
Author: Jeremy Ross <je...@gmail.com>
AuthorDate: Fri Apr 15 10:21:42 2022 -0500
CAMEL-17719: camel-salesforce: Add operation to get event schemas
Event schemas are Avro schemas and support Platform Events,
Change Data Capture events, and custom events.
---
.../salesforce/SalesforceComponentConfigurer.java | 18 +++++
.../salesforce/SalesforceEndpointConfigurer.java | 18 +++++
.../salesforce/SalesforceEndpointUriFactory.java | 5 +-
.../camel/component/salesforce/salesforce.json | 84 ++++++++++++----------
.../src/main/docs/salesforce-component.adoc | 20 ++++++
.../component/salesforce/SalesforceEndpoint.java | 4 +-
.../salesforce/SalesforceEndpointConfig.java | 55 +++++++++++++-
.../component/salesforce/SalesforceProducer.java | 2 +-
.../component/salesforce/api/utils/JsonUtils.java | 75 +++++++++++++++++--
.../salesforce/internal/OperationName.java | 1 +
.../internal/client/DefaultRestClient.java | 37 ++++++++++
.../salesforce/internal/client/RestClient.java | 18 +++++
.../internal/dto/EventSchemaFormatEnum.java | 44 ++++++++++++
.../internal/processor/AbstractRestProcessor.java | 26 +++++++
.../internal/processor/SalesforceProcessor.java | 2 -
.../salesforce/RestApiIntegrationTest.java | 32 +++++++++
16 files changed, 391 insertions(+), 50 deletions(-)
diff --git a/components/camel-salesforce/camel-salesforce-component/src/generated/java/org/apache/camel/component/salesforce/SalesforceComponentConfigurer.java b/components/camel-salesforce/camel-salesforce-component/src/generated/java/org/apache/camel/component/salesforce/SalesforceComponentConfigurer.java
index 41fe36cac2a..93e4abef2d8 100644
--- a/components/camel-salesforce/camel-salesforce-component/src/generated/java/org/apache/camel/component/salesforce/SalesforceComponentConfigurer.java
+++ b/components/camel-salesforce/camel-salesforce-component/src/generated/java/org/apache/camel/component/salesforce/SalesforceComponentConfigurer.java
@@ -59,6 +59,12 @@ public class SalesforceComponentConfigurer extends PropertyConfigurerSupport imp
case "contentType": getOrCreateConfig(target).setContentType(property(camelContext, org.apache.camel.component.salesforce.api.dto.bulk.ContentType.class, value)); return true;
case "defaultreplayid":
case "defaultReplayId": getOrCreateConfig(target).setDefaultReplayId(property(camelContext, java.lang.Long.class, value)); return true;
+ case "eventname":
+ case "eventName": getOrCreateConfig(target).setEventName(property(camelContext, java.lang.String.class, value)); return true;
+ case "eventschemaformat":
+ case "eventSchemaFormat": getOrCreateConfig(target).setEventSchemaFormat(property(camelContext, org.apache.camel.component.salesforce.internal.dto.EventSchemaFormatEnum.class, value)); return true;
+ case "eventschemaid":
+ case "eventSchemaId": getOrCreateConfig(target).setEventSchemaId(property(camelContext, java.lang.String.class, value)); return true;
case "fallbackreplayid":
case "fallBackReplayId": getOrCreateConfig(target).setFallBackReplayId(property(camelContext, java.lang.Long.class, value)); return true;
case "format": getOrCreateConfig(target).setFormat(property(camelContext, org.apache.camel.component.salesforce.internal.PayloadFormat.class, value)); return true;
@@ -255,6 +261,12 @@ public class SalesforceComponentConfigurer extends PropertyConfigurerSupport imp
case "contentType": return org.apache.camel.component.salesforce.api.dto.bulk.ContentType.class;
case "defaultreplayid":
case "defaultReplayId": return java.lang.Long.class;
+ case "eventname":
+ case "eventName": return java.lang.String.class;
+ case "eventschemaformat":
+ case "eventSchemaFormat": return org.apache.camel.component.salesforce.internal.dto.EventSchemaFormatEnum.class;
+ case "eventschemaid":
+ case "eventSchemaId": return java.lang.String.class;
case "fallbackreplayid":
case "fallBackReplayId": return java.lang.Long.class;
case "format": return org.apache.camel.component.salesforce.internal.PayloadFormat.class;
@@ -452,6 +464,12 @@ public class SalesforceComponentConfigurer extends PropertyConfigurerSupport imp
case "contentType": return getOrCreateConfig(target).getContentType();
case "defaultreplayid":
case "defaultReplayId": return getOrCreateConfig(target).getDefaultReplayId();
+ case "eventname":
+ case "eventName": return getOrCreateConfig(target).getEventName();
+ case "eventschemaformat":
+ case "eventSchemaFormat": return getOrCreateConfig(target).getEventSchemaFormat();
+ case "eventschemaid":
+ case "eventSchemaId": return getOrCreateConfig(target).getEventSchemaId();
case "fallbackreplayid":
case "fallBackReplayId": return getOrCreateConfig(target).getFallBackReplayId();
case "format": return getOrCreateConfig(target).getFormat();
diff --git a/components/camel-salesforce/camel-salesforce-component/src/generated/java/org/apache/camel/component/salesforce/SalesforceEndpointConfigurer.java b/components/camel-salesforce/camel-salesforce-component/src/generated/java/org/apache/camel/component/salesforce/SalesforceEndpointConfigurer.java
index e58c53ad0d8..cd06d67e5e1 100644
--- a/components/camel-salesforce/camel-salesforce-component/src/generated/java/org/apache/camel/component/salesforce/SalesforceEndpointConfigurer.java
+++ b/components/camel-salesforce/camel-salesforce-component/src/generated/java/org/apache/camel/component/salesforce/SalesforceEndpointConfigurer.java
@@ -43,6 +43,12 @@ public class SalesforceEndpointConfigurer extends PropertyConfigurerSupport impl
case "contentType": target.getConfiguration().setContentType(property(camelContext, org.apache.camel.component.salesforce.api.dto.bulk.ContentType.class, value)); return true;
case "defaultreplayid":
case "defaultReplayId": target.getConfiguration().setDefaultReplayId(property(camelContext, java.lang.Long.class, value)); return true;
+ case "eventname":
+ case "eventName": target.getConfiguration().setEventName(property(camelContext, java.lang.String.class, value)); return true;
+ case "eventschemaformat":
+ case "eventSchemaFormat": target.getConfiguration().setEventSchemaFormat(property(camelContext, org.apache.camel.component.salesforce.internal.dto.EventSchemaFormatEnum.class, value)); return true;
+ case "eventschemaid":
+ case "eventSchemaId": target.getConfiguration().setEventSchemaId(property(camelContext, java.lang.String.class, value)); return true;
case "exceptionhandler":
case "exceptionHandler": target.setExceptionHandler(property(camelContext, org.apache.camel.spi.ExceptionHandler.class, value)); return true;
case "exchangepattern":
@@ -173,6 +179,12 @@ public class SalesforceEndpointConfigurer extends PropertyConfigurerSupport impl
case "contentType": return org.apache.camel.component.salesforce.api.dto.bulk.ContentType.class;
case "defaultreplayid":
case "defaultReplayId": return java.lang.Long.class;
+ case "eventname":
+ case "eventName": return java.lang.String.class;
+ case "eventschemaformat":
+ case "eventSchemaFormat": return org.apache.camel.component.salesforce.internal.dto.EventSchemaFormatEnum.class;
+ case "eventschemaid":
+ case "eventSchemaId": return java.lang.String.class;
case "exceptionhandler":
case "exceptionHandler": return org.apache.camel.spi.ExceptionHandler.class;
case "exchangepattern":
@@ -304,6 +316,12 @@ public class SalesforceEndpointConfigurer extends PropertyConfigurerSupport impl
case "contentType": return target.getConfiguration().getContentType();
case "defaultreplayid":
case "defaultReplayId": return target.getConfiguration().getDefaultReplayId();
+ case "eventname":
+ case "eventName": return target.getConfiguration().getEventName();
+ case "eventschemaformat":
+ case "eventSchemaFormat": return target.getConfiguration().getEventSchemaFormat();
+ case "eventschemaid":
+ case "eventSchemaId": return target.getConfiguration().getEventSchemaId();
case "exceptionhandler":
case "exceptionHandler": return target.getExceptionHandler();
case "exchangepattern":
diff --git a/components/camel-salesforce/camel-salesforce-component/src/generated/java/org/apache/camel/component/salesforce/SalesforceEndpointUriFactory.java b/components/camel-salesforce/camel-salesforce-component/src/generated/java/org/apache/camel/component/salesforce/SalesforceEndpointUriFactory.java
index c9c22e45cd6..eef07fb409a 100644
--- a/components/camel-salesforce/camel-salesforce-component/src/generated/java/org/apache/camel/component/salesforce/SalesforceEndpointUriFactory.java
+++ b/components/camel-salesforce/camel-salesforce-component/src/generated/java/org/apache/camel/component/salesforce/SalesforceEndpointUriFactory.java
@@ -21,7 +21,7 @@ public class SalesforceEndpointUriFactory extends org.apache.camel.support.compo
private static final Set<String> SECRET_PROPERTY_NAMES;
private static final Set<String> MULTI_VALUE_PREFIXES;
static {
- Set<String> props = new HashSet<>(65);
+ Set<String> props = new HashSet<>(68);
props.add("allOrNone");
props.add("apexMethod");
props.add("apexQueryParams");
@@ -33,6 +33,9 @@ public class SalesforceEndpointUriFactory extends org.apache.camel.support.compo
props.add("compositeMethod");
props.add("contentType");
props.add("defaultReplayId");
+ props.add("eventName");
+ props.add("eventSchemaFormat");
+ props.add("eventSchemaId");
props.add("exceptionHandler");
props.add("exchangePattern");
props.add("fallBackReplayId");
diff --git a/components/camel-salesforce/camel-salesforce-component/src/generated/resources/org/apache/camel/component/salesforce/salesforce.json b/components/camel-salesforce/camel-salesforce-component/src/generated/resources/org/apache/camel/component/salesforce/salesforce.json
index 959c872f7d4..858cda6d268 100644
--- a/components/camel-salesforce/camel-salesforce-component/src/generated/resources/org/apache/camel/component/salesforce/salesforce.json
+++ b/components/camel-salesforce/camel-salesforce-component/src/generated/resources/org/apache/camel/component/salesforce/salesforce.json
@@ -89,39 +89,42 @@
"allOrNone": { "index": 62, "kind": "property", "displayName": "All Or None", "group": "producer", "label": "producer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.salesforce.SalesforceEndpointConfig", "configurationField": "config", "description": "Composite API option to indicate to rollback all records if any are not successful." },
"apexUrl": { "index": 63, "kind": "property", "displayName": "Apex Url", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.salesforce.SalesforceEndpointConfig", "configurationField": "config", "description": "APEX method URL" },
"compositeMethod": { "index": 64, "kind": "property", "displayName": "Composite Method", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.salesforce.SalesforceEndpointConfig", "configurationField": "config", "description": "Composite (raw) method." },
- "lazyStartProducer": { "index": 65, "kind": "property", "displayName": "Lazy Start Producer", "group": "producer", "label": "producer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "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 fai [...]
- "rawHttpHeaders": { "index": 66, "kind": "property", "displayName": "Raw Http Headers", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.salesforce.SalesforceEndpointConfig", "configurationField": "config", "description": "Comma separated list of message headers to include as HTTP parameters for Raw operation." },
- "rawMethod": { "index": 67, "kind": "property", "displayName": "Raw Method", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.salesforce.SalesforceEndpointConfig", "configurationField": "config", "description": "HTTP method to use for the Raw operation" },
- "rawPath": { "index": 68, "kind": "property", "displayName": "Raw Path", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.salesforce.SalesforceEndpointConfig", "configurationField": "config", "description": "The portion of the endpoint URL after the domain name. E.g., '\/services\/data\/v52.0\/sobjects\/Account\/'" },
- "rawQueryParameters": { "index": 69, "kind": "property", "displayName": "Raw Query Parameters", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.salesforce.SalesforceEndpointConfig", "configurationField": "config", "description": "Comma separated list of message headers to include as query parameters for Raw operatio [...]
- "autowiredEnabled": { "index": 70, "kind": "property", "displayName": "Autowired Enabled", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "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 [...]
- "httpProxyExcludedAddresses": { "index": 71, "kind": "property", "displayName": "Http Proxy Excluded Addresses", "group": "proxy", "label": "common,proxy", "required": false, "type": "object", "javaType": "java.util.Set<java.lang.String>", "deprecated": false, "autowired": false, "secret": false, "description": "A list of addresses for which HTTP proxy server should not be used." },
- "httpProxyHost": { "index": 72, "kind": "property", "displayName": "Http Proxy Host", "group": "proxy", "label": "common,proxy", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Hostname of the HTTP proxy server to use." },
- "httpProxyIncludedAddresses": { "index": 73, "kind": "property", "displayName": "Http Proxy Included Addresses", "group": "proxy", "label": "common,proxy", "required": false, "type": "object", "javaType": "java.util.Set<java.lang.String>", "deprecated": false, "autowired": false, "secret": false, "description": "A list of addresses for which HTTP proxy server should be used." },
- "httpProxyPort": { "index": 74, "kind": "property", "displayName": "Http Proxy Port", "group": "proxy", "label": "common,proxy", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "description": "Port number of the HTTP proxy server to use." },
- "httpProxySocks4": { "index": 75, "kind": "property", "displayName": "Http Proxy Socks4", "group": "proxy", "label": "common,proxy", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "If set to true the configures the HTTP proxy to use as a SOCKS4 proxy." },
- "authenticationType": { "index": 76, "kind": "property", "displayName": "Authentication Type", "group": "security", "label": "common,security", "required": false, "type": "object", "javaType": "org.apache.camel.component.salesforce.AuthenticationType", "enum": [ "USERNAME_PASSWORD", "REFRESH_TOKEN", "JWT" ], "deprecated": false, "autowired": false, "secret": false, "description": "Explicit authentication method to be used, one of USERNAME_PASSWORD, REFRESH_TOKEN or JWT. Salesforce co [...]
- "clientId": { "index": 77, "kind": "property", "displayName": "Client Id", "group": "security", "label": "common,security", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "OAuth Consumer Key of the connected app configured in the Salesforce instance setup. Typically a connected app needs to be configured but one can be provided by installing a package." },
- "clientSecret": { "index": 78, "kind": "property", "displayName": "Client Secret", "group": "security", "label": "common,security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": true, "description": "OAuth Consumer Secret of the connected app configured in the Salesforce instance setup." },
- "httpProxyAuthUri": { "index": 79, "kind": "property", "displayName": "Http Proxy Auth Uri", "group": "security", "label": "common,proxy,security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Used in authentication against the HTTP proxy server, needs to match the URI of the proxy server in order for the httpProxyUsername and httpProxyPassword to be used for authentication." },
- "httpProxyPassword": { "index": 80, "kind": "property", "displayName": "Http Proxy Password", "group": "security", "label": "common,proxy,security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": true, "description": "Password to use to authenticate against the HTTP proxy server." },
- "httpProxyRealm": { "index": 81, "kind": "property", "displayName": "Http Proxy Realm", "group": "security", "label": "common,proxy,security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Realm of the proxy server, used in preemptive Basic\/Digest authentication methods against the HTTP proxy server." },
- "httpProxySecure": { "index": 82, "kind": "property", "displayName": "Http Proxy Secure", "group": "security", "label": "common,proxy,security", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "description": "If set to false disables the use of TLS when accessing the HTTP proxy." },
- "httpProxyUseDigestAuth": { "index": 83, "kind": "property", "displayName": "Http Proxy Use Digest Auth", "group": "security", "label": "common,proxy,security", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "If set to true Digest authentication will be used when authenticating to the HTTP proxy, otherwise Basic authorization method will be used" },
- "httpProxyUsername": { "index": 84, "kind": "property", "displayName": "Http Proxy Username", "group": "security", "label": "common,proxy,security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Username to use to authenticate against the HTTP proxy server." },
- "instanceUrl": { "index": 85, "kind": "property", "displayName": "Instance Url", "group": "security", "label": "common,security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "URL of the Salesforce instance used after authentication, by default received from Salesforce on successful authentication" },
- "jwtAudience": { "index": 86, "kind": "property", "displayName": "Jwt Audience", "group": "security", "label": "common,security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Value to use for the Audience claim (aud) when using OAuth JWT flow. If not set, the login URL will be used, which is appropriate in most cases." },
- "keystore": { "index": 87, "kind": "property", "displayName": "Keystore", "group": "security", "label": "common,security", "required": false, "type": "object", "javaType": "org.apache.camel.support.jsse.KeyStoreParameters", "deprecated": false, "autowired": false, "secret": true, "description": "KeyStore parameters to use in OAuth JWT flow. The KeyStore should contain only one entry with private key and certificate. Salesforce does not verify the certificate chain, so this can easily [...]
- "lazyLogin": { "index": 88, "kind": "property", "displayName": "Lazy Login", "group": "security", "label": "common,security", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "If set to true prevents the component from authenticating to Salesforce with the start of the component. You would generally set this to the (default) false and authenticate early and be immediately aware [...]
- "loginConfig": { "index": 89, "kind": "property", "displayName": "Login Config", "group": "security", "label": "common,security", "required": false, "type": "object", "javaType": "org.apache.camel.component.salesforce.SalesforceLoginConfig", "deprecated": false, "autowired": false, "secret": false, "description": "All authentication configuration in one nested bean, all properties set there can be set directly on the component as well" },
- "loginUrl": { "index": 90, "kind": "property", "displayName": "Login Url", "group": "security", "label": "common,security", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "https:\/\/login.salesforce.com", "description": "URL of the Salesforce instance used for authentication, by default set to https:\/\/login.salesforce.com" },
- "password": { "index": 91, "kind": "property", "displayName": "Password", "group": "security", "label": "common,security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": true, "description": "Password used in OAuth flow to gain access to access token. It's easy to get started with password OAuth flow, but in general one should avoid it as it is deemed less secure than other flows. Make sure that you append secur [...]
- "pubSubHost": { "index": 92, "kind": "property", "displayName": "Pub Sub Host", "group": "security", "label": "common,security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "api.pubsub.salesforce.com", "description": "Pub\/Sub host" },
- "pubSubPort": { "index": 93, "kind": "property", "displayName": "Pub Sub Port", "group": "security", "label": "common,security", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 7443, "description": "Pub\/Sub port" },
- "refreshToken": { "index": 94, "kind": "property", "displayName": "Refresh Token", "group": "security", "label": "common,security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": true, "description": "Refresh token already obtained in the refresh token OAuth flow. One needs to setup a web application and configure a callback URL to receive the refresh token, or configure using the builtin callback at https:\/\/l [...]
- "sslContextParameters": { "index": 95, "kind": "property", "displayName": "Ssl Context Parameters", "group": "security", "label": "common,security", "required": false, "type": "object", "javaType": "org.apache.camel.support.jsse.SSLContextParameters", "deprecated": false, "autowired": false, "secret": false, "description": "SSL parameters to use, see SSLContextParameters class for all available options." },
- "useGlobalSslContextParameters": { "index": 96, "kind": "property", "displayName": "Use Global Ssl Context Parameters", "group": "security", "label": "security", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Enable usage of global SSL context parameters" },
- "userName": { "index": 97, "kind": "property", "displayName": "User Name", "group": "security", "label": "common,security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Username used in OAuth flow to gain access to access token. It's easy to get started with password OAuth flow, but in general one should avoid it as it is deemed less secure than other flows." }
+ "eventName": { "index": 65, "kind": "property", "displayName": "Event Name", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.salesforce.SalesforceEndpointConfig", "configurationField": "config", "description": "Name of Platform Event, Change Data Capture Event, custom event, etc." },
+ "eventSchemaFormat": { "index": 66, "kind": "property", "displayName": "Event Schema Format", "group": "producer", "label": "producer", "required": false, "type": "object", "javaType": "org.apache.camel.component.salesforce.internal.dto.EventSchemaFormatEnum", "enum": [ "EXPANDED", "COMPACT" ], "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.salesforce.SalesforceEndpointConfig", "configurationField": "config", "description": [...]
+ "eventSchemaId": { "index": 67, "kind": "property", "displayName": "Event Schema Id", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.salesforce.SalesforceEndpointConfig", "configurationField": "config", "description": "The ID of the event schema." },
+ "lazyStartProducer": { "index": 68, "kind": "property", "displayName": "Lazy Start Producer", "group": "producer", "label": "producer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "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 fai [...]
+ "rawHttpHeaders": { "index": 69, "kind": "property", "displayName": "Raw Http Headers", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.salesforce.SalesforceEndpointConfig", "configurationField": "config", "description": "Comma separated list of message headers to include as HTTP parameters for Raw operation." },
+ "rawMethod": { "index": 70, "kind": "property", "displayName": "Raw Method", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.salesforce.SalesforceEndpointConfig", "configurationField": "config", "description": "HTTP method to use for the Raw operation" },
+ "rawPath": { "index": 71, "kind": "property", "displayName": "Raw Path", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.salesforce.SalesforceEndpointConfig", "configurationField": "config", "description": "The portion of the endpoint URL after the domain name. E.g., '\/services\/data\/v52.0\/sobjects\/Account\/'" },
+ "rawQueryParameters": { "index": 72, "kind": "property", "displayName": "Raw Query Parameters", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.salesforce.SalesforceEndpointConfig", "configurationField": "config", "description": "Comma separated list of message headers to include as query parameters for Raw operatio [...]
+ "autowiredEnabled": { "index": 73, "kind": "property", "displayName": "Autowired Enabled", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "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 [...]
+ "httpProxyExcludedAddresses": { "index": 74, "kind": "property", "displayName": "Http Proxy Excluded Addresses", "group": "proxy", "label": "common,proxy", "required": false, "type": "object", "javaType": "java.util.Set<java.lang.String>", "deprecated": false, "autowired": false, "secret": false, "description": "A list of addresses for which HTTP proxy server should not be used." },
+ "httpProxyHost": { "index": 75, "kind": "property", "displayName": "Http Proxy Host", "group": "proxy", "label": "common,proxy", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Hostname of the HTTP proxy server to use." },
+ "httpProxyIncludedAddresses": { "index": 76, "kind": "property", "displayName": "Http Proxy Included Addresses", "group": "proxy", "label": "common,proxy", "required": false, "type": "object", "javaType": "java.util.Set<java.lang.String>", "deprecated": false, "autowired": false, "secret": false, "description": "A list of addresses for which HTTP proxy server should be used." },
+ "httpProxyPort": { "index": 77, "kind": "property", "displayName": "Http Proxy Port", "group": "proxy", "label": "common,proxy", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "description": "Port number of the HTTP proxy server to use." },
+ "httpProxySocks4": { "index": 78, "kind": "property", "displayName": "Http Proxy Socks4", "group": "proxy", "label": "common,proxy", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "If set to true the configures the HTTP proxy to use as a SOCKS4 proxy." },
+ "authenticationType": { "index": 79, "kind": "property", "displayName": "Authentication Type", "group": "security", "label": "common,security", "required": false, "type": "object", "javaType": "org.apache.camel.component.salesforce.AuthenticationType", "enum": [ "USERNAME_PASSWORD", "REFRESH_TOKEN", "JWT" ], "deprecated": false, "autowired": false, "secret": false, "description": "Explicit authentication method to be used, one of USERNAME_PASSWORD, REFRESH_TOKEN or JWT. Salesforce co [...]
+ "clientId": { "index": 80, "kind": "property", "displayName": "Client Id", "group": "security", "label": "common,security", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "OAuth Consumer Key of the connected app configured in the Salesforce instance setup. Typically a connected app needs to be configured but one can be provided by installing a package." },
+ "clientSecret": { "index": 81, "kind": "property", "displayName": "Client Secret", "group": "security", "label": "common,security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": true, "description": "OAuth Consumer Secret of the connected app configured in the Salesforce instance setup." },
+ "httpProxyAuthUri": { "index": 82, "kind": "property", "displayName": "Http Proxy Auth Uri", "group": "security", "label": "common,proxy,security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Used in authentication against the HTTP proxy server, needs to match the URI of the proxy server in order for the httpProxyUsername and httpProxyPassword to be used for authentication." },
+ "httpProxyPassword": { "index": 83, "kind": "property", "displayName": "Http Proxy Password", "group": "security", "label": "common,proxy,security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": true, "description": "Password to use to authenticate against the HTTP proxy server." },
+ "httpProxyRealm": { "index": 84, "kind": "property", "displayName": "Http Proxy Realm", "group": "security", "label": "common,proxy,security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Realm of the proxy server, used in preemptive Basic\/Digest authentication methods against the HTTP proxy server." },
+ "httpProxySecure": { "index": 85, "kind": "property", "displayName": "Http Proxy Secure", "group": "security", "label": "common,proxy,security", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "description": "If set to false disables the use of TLS when accessing the HTTP proxy." },
+ "httpProxyUseDigestAuth": { "index": 86, "kind": "property", "displayName": "Http Proxy Use Digest Auth", "group": "security", "label": "common,proxy,security", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "If set to true Digest authentication will be used when authenticating to the HTTP proxy, otherwise Basic authorization method will be used" },
+ "httpProxyUsername": { "index": 87, "kind": "property", "displayName": "Http Proxy Username", "group": "security", "label": "common,proxy,security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Username to use to authenticate against the HTTP proxy server." },
+ "instanceUrl": { "index": 88, "kind": "property", "displayName": "Instance Url", "group": "security", "label": "common,security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "URL of the Salesforce instance used after authentication, by default received from Salesforce on successful authentication" },
+ "jwtAudience": { "index": 89, "kind": "property", "displayName": "Jwt Audience", "group": "security", "label": "common,security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Value to use for the Audience claim (aud) when using OAuth JWT flow. If not set, the login URL will be used, which is appropriate in most cases." },
+ "keystore": { "index": 90, "kind": "property", "displayName": "Keystore", "group": "security", "label": "common,security", "required": false, "type": "object", "javaType": "org.apache.camel.support.jsse.KeyStoreParameters", "deprecated": false, "autowired": false, "secret": true, "description": "KeyStore parameters to use in OAuth JWT flow. The KeyStore should contain only one entry with private key and certificate. Salesforce does not verify the certificate chain, so this can easily [...]
+ "lazyLogin": { "index": 91, "kind": "property", "displayName": "Lazy Login", "group": "security", "label": "common,security", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "If set to true prevents the component from authenticating to Salesforce with the start of the component. You would generally set this to the (default) false and authenticate early and be immediately aware [...]
+ "loginConfig": { "index": 92, "kind": "property", "displayName": "Login Config", "group": "security", "label": "common,security", "required": false, "type": "object", "javaType": "org.apache.camel.component.salesforce.SalesforceLoginConfig", "deprecated": false, "autowired": false, "secret": false, "description": "All authentication configuration in one nested bean, all properties set there can be set directly on the component as well" },
+ "loginUrl": { "index": 93, "kind": "property", "displayName": "Login Url", "group": "security", "label": "common,security", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "https:\/\/login.salesforce.com", "description": "URL of the Salesforce instance used for authentication, by default set to https:\/\/login.salesforce.com" },
+ "password": { "index": 94, "kind": "property", "displayName": "Password", "group": "security", "label": "common,security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": true, "description": "Password used in OAuth flow to gain access to access token. It's easy to get started with password OAuth flow, but in general one should avoid it as it is deemed less secure than other flows. Make sure that you append secur [...]
+ "pubSubHost": { "index": 95, "kind": "property", "displayName": "Pub Sub Host", "group": "security", "label": "common,security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "api.pubsub.salesforce.com", "description": "Pub\/Sub host" },
+ "pubSubPort": { "index": 96, "kind": "property", "displayName": "Pub Sub Port", "group": "security", "label": "common,security", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 7443, "description": "Pub\/Sub port" },
+ "refreshToken": { "index": 97, "kind": "property", "displayName": "Refresh Token", "group": "security", "label": "common,security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": true, "description": "Refresh token already obtained in the refresh token OAuth flow. One needs to setup a web application and configure a callback URL to receive the refresh token, or configure using the builtin callback at https:\/\/l [...]
+ "sslContextParameters": { "index": 98, "kind": "property", "displayName": "Ssl Context Parameters", "group": "security", "label": "common,security", "required": false, "type": "object", "javaType": "org.apache.camel.support.jsse.SSLContextParameters", "deprecated": false, "autowired": false, "secret": false, "description": "SSL parameters to use, see SSLContextParameters class for all available options." },
+ "useGlobalSslContextParameters": { "index": 99, "kind": "property", "displayName": "Use Global Ssl Context Parameters", "group": "security", "label": "security", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Enable usage of global SSL context parameters" },
+ "userName": { "index": 100, "kind": "property", "displayName": "User Name", "group": "security", "label": "common,security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Username used in OAuth flow to gain access to access token. It's easy to get started with password OAuth flow, but in general one should avoid it as it is deemed less secure than other flows." }
},
"headers": {
"CamelSalesforceReplayId": { "index": 0, "kind": "header", "displayName": "", "group": "consumer", "label": "consumer", "required": false, "javaType": "Object", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The Streaming API replayId.", "constantName": "org.apache.camel.component.salesforce.SalesforceConstants#HEADER_SALESFORCE_REPLAY_ID" },
@@ -146,7 +149,7 @@
"CamelSalesforceQueryResultTotalSize": { "index": 19, "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "int", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "Total number of records matching a query.", "constantName": "org.apache.camel.component.salesforce.SalesforceConstants#HEADER_SALESFORCE_QUERY_RESULT_TOTAL_SIZE" }
},
"properties": {
- "operationName": { "index": 0, "kind": "path", "displayName": "Operation Name", "group": "common", "label": "common", "required": true, "type": "object", "javaType": "org.apache.camel.component.salesforce.internal.OperationName", "enum": [ "getVersions", "getResources", "getGlobalObjects", "getBasicInfo", "getDescription", "getSObject", "createSObject", "updateSObject", "deleteSObject", "getSObjectWithId", "upsertSObject", "deleteSObjectWithId", "getBlobField", "query", "queryMore", [...]
+ "operationName": { "index": 0, "kind": "path", "displayName": "Operation Name", "group": "common", "label": "common", "required": true, "type": "object", "javaType": "org.apache.camel.component.salesforce.internal.OperationName", "enum": [ "getVersions", "getResources", "getGlobalObjects", "getBasicInfo", "getDescription", "getSObject", "createSObject", "updateSObject", "deleteSObject", "getSObjectWithId", "upsertSObject", "deleteSObjectWithId", "getBlobField", "query", "queryMore", [...]
"topicName": { "index": 1, "kind": "path", "displayName": "Topic Name", "group": "producer", "label": "consumer,producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "The name of the topic\/channel to use" },
"apexMethod": { "index": 2, "kind": "parameter", "displayName": "Apex Method", "group": "common", "label": "", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.salesforce.SalesforceEndpointConfig", "configurationField": "configuration", "description": "APEX method name" },
"apexQueryParams": { "index": 3, "kind": "parameter", "displayName": "Apex Query Params", "group": "common", "label": "", "required": false, "type": "object", "javaType": "java.util.Map<java.lang.String, java.lang.Object>", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.salesforce.SalesforceEndpointConfig", "configurationField": "configuration", "description": "Query params for APEX method" },
@@ -206,10 +209,13 @@
"allOrNone": { "index": 57, "kind": "parameter", "displayName": "All Or None", "group": "producer", "label": "producer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.salesforce.SalesforceEndpointConfig", "configurationField": "configuration", "description": "Composite API option to indicate to rollback all records if any are not successful." },
"apexUrl": { "index": 58, "kind": "parameter", "displayName": "Apex Url", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.salesforce.SalesforceEndpointConfig", "configurationField": "configuration", "description": "APEX method URL" },
"compositeMethod": { "index": 59, "kind": "parameter", "displayName": "Composite Method", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.salesforce.SalesforceEndpointConfig", "configurationField": "configuration", "description": "Composite (raw) method." },
- "rawHttpHeaders": { "index": 60, "kind": "parameter", "displayName": "Raw Http Headers", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.salesforce.SalesforceEndpointConfig", "configurationField": "configuration", "description": "Comma separated list of message headers to include as HTTP parameters for Raw operation." },
- "rawMethod": { "index": 61, "kind": "parameter", "displayName": "Raw Method", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.salesforce.SalesforceEndpointConfig", "configurationField": "configuration", "description": "HTTP method to use for the Raw operation" },
- "rawPath": { "index": 62, "kind": "parameter", "displayName": "Raw Path", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.salesforce.SalesforceEndpointConfig", "configurationField": "configuration", "description": "The portion of the endpoint URL after the domain name. E.g., '\/services\/data\/v52.0\/sobjects\/Accou [...]
- "rawQueryParameters": { "index": 63, "kind": "parameter", "displayName": "Raw Query Parameters", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.salesforce.SalesforceEndpointConfig", "configurationField": "configuration", "description": "Comma separated list of message headers to include as query parameters for Raw [...]
- "lazyStartProducer": { "index": 64, "kind": "parameter", "displayName": "Lazy Start Producer", "group": "producer (advanced)", "label": "producer,advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "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 produ [...]
+ "eventName": { "index": 60, "kind": "parameter", "displayName": "Event Name", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.salesforce.SalesforceEndpointConfig", "configurationField": "configuration", "description": "Name of Platform Event, Change Data Capture Event, custom event, etc." },
+ "eventSchemaFormat": { "index": 61, "kind": "parameter", "displayName": "Event Schema Format", "group": "producer", "label": "producer", "required": false, "type": "object", "javaType": "org.apache.camel.component.salesforce.internal.dto.EventSchemaFormatEnum", "enum": [ "EXPANDED", "COMPACT" ], "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.salesforce.SalesforceEndpointConfig", "configurationField": "configuration", "descr [...]
+ "eventSchemaId": { "index": 62, "kind": "parameter", "displayName": "Event Schema Id", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.salesforce.SalesforceEndpointConfig", "configurationField": "configuration", "description": "The ID of the event schema." },
+ "rawHttpHeaders": { "index": 63, "kind": "parameter", "displayName": "Raw Http Headers", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.salesforce.SalesforceEndpointConfig", "configurationField": "configuration", "description": "Comma separated list of message headers to include as HTTP parameters for Raw operation." },
+ "rawMethod": { "index": 64, "kind": "parameter", "displayName": "Raw Method", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.salesforce.SalesforceEndpointConfig", "configurationField": "configuration", "description": "HTTP method to use for the Raw operation" },
+ "rawPath": { "index": 65, "kind": "parameter", "displayName": "Raw Path", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.salesforce.SalesforceEndpointConfig", "configurationField": "configuration", "description": "The portion of the endpoint URL after the domain name. E.g., '\/services\/data\/v52.0\/sobjects\/Accou [...]
+ "rawQueryParameters": { "index": 66, "kind": "parameter", "displayName": "Raw Query Parameters", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.salesforce.SalesforceEndpointConfig", "configurationField": "configuration", "description": "Comma separated list of message headers to include as query parameters for Raw [...]
+ "lazyStartProducer": { "index": 67, "kind": "parameter", "displayName": "Lazy Start Producer", "group": "producer (advanced)", "label": "producer,advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "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 produ [...]
}
}
diff --git a/components/camel-salesforce/camel-salesforce-component/src/main/docs/salesforce-component.adoc b/components/camel-salesforce/camel-salesforce-component/src/main/docs/salesforce-component.adoc
index 3fb381fb74e..9ad13e05c4e 100644
--- a/components/camel-salesforce/camel-salesforce-component/src/main/docs/salesforce-component.adoc
+++ b/components/camel-salesforce/camel-salesforce-component/src/main/docs/salesforce-component.adoc
@@ -225,6 +225,7 @@ request as the input to a subsequent request.
* <<compositeUpdateSObjectCollections,compositeUpdateSObjectCollections>> - Update up to 200 records.
* <<compositeUpsertSObjectCollections,compositeUpsertSObjectCollections>> - Creates or updates up to 200 records based on an External Id field.
* <<compositeDeleteSObjectCollections,compositeDeleteSObjectCollections>> - Deletes up to 200 records.
+* <<getEventSchema, getEventSchema>> - Gets the event schema for Plaform Events, Change Data Capture events, etc.
Unless otherwise specified, DTO types for the following options are from `org.apache.camel.component.salesforce.api.dto` or one if its sub-packages.
@@ -997,6 +998,25 @@ Delete up to 200 records. Mixed SObject types is supported.
Type: `List<DeleteSObjectResult>`
+[[getEventSchema]]
+==== Get Event Schema
+
+`getEventSchema`
+
+Gets the definition of a Platform Event in JSON format. Other types of events such as Change Data Capture events or custom events are also supported. This operation is available in REST API version 40.0 and later.
+
+|===
+| Parameter | Type | Description | Default | Required
+
+| `eventName` | String | Name of event | | `eventName` or `eventSchemaId` is required
+| `eventSchemaId` | String | ID of a schema | | `eventName` or `eventSchemaId` is required
+| `eventSchemaFormat` | EventSchemaFormatEnum | `EXPANDED`: Apache Avro format but doesn’t strictly adhere to the record complex type. `COMPACT`: Apache Avro, adheres to the specification for the record complex type. This parameter is available in API version 43.0 and later. | `EXPANDED` |
+|===
+
+*Output*
+
+Type: `InputStream`
+
[[ApexRESTAPI]]
=== Apex REST API
diff --git a/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/SalesforceEndpoint.java b/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/SalesforceEndpoint.java
index 55ec2080469..bd35c02d620 100644
--- a/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/SalesforceEndpoint.java
+++ b/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/SalesforceEndpoint.java
@@ -44,8 +44,8 @@ public class SalesforceEndpoint extends DefaultEndpoint {
@UriPath(label = "common", description = "The operation to use", enums = "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,"
+ + "getBlobField,query,queryMore,queryAll,search,apexCall,recent,getEventSchema,createJob,"
+ + "getJob,closeJob,abortJob,createBatch,getBatch,getAllBatches,getRequest,getResults,"
+ "createBatchQuery,getQueryResultIds,getQueryResult,getRecentReports,"
+ "getReportDescription,executeSyncReport,executeAsyncReport,getReportInstances,"
+ "getReportResults,limits,approval,approvals,composite-tree,composite-batch,composite,"
diff --git a/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/SalesforceEndpointConfig.java b/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/SalesforceEndpointConfig.java
index cf05df142b1..2db0e7c24ee 100644
--- a/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/SalesforceEndpointConfig.java
+++ b/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/SalesforceEndpointConfig.java
@@ -30,6 +30,7 @@ import org.apache.camel.component.salesforce.api.dto.approval.ApprovalRequest;
import org.apache.camel.component.salesforce.api.dto.approval.ApprovalRequest.Action;
import org.apache.camel.component.salesforce.api.dto.bulk.ContentType;
import org.apache.camel.component.salesforce.internal.PayloadFormat;
+import org.apache.camel.component.salesforce.internal.dto.EventSchemaFormatEnum;
import org.apache.camel.component.salesforce.internal.dto.NotifyForFieldsEnum;
import org.apache.camel.component.salesforce.internal.dto.NotifyForOperationsEnum;
import org.apache.camel.spi.UriParam;
@@ -67,6 +68,9 @@ public class SalesforceEndpointConfig implements Cloneable {
public static final String COMPOSITE_METHOD = "compositeMethod";
public static final String LIMIT = "limit";
public static final String ALL_OR_NONE = "allOrNone";
+ public static final String EVENT_NAME = "eventName";
+ public static final String EVENT_SCHEMA_ID = "eventSchemaId";
+ public static final String EVENT_SCHEMA_FORMAT = "eventSchemaFormat";
// prefix for parameters in headers
public static final String APEX_QUERY_PARAM_PREFIX = "apexQueryParam.";
@@ -151,6 +155,12 @@ public class SalesforceEndpointConfig implements Cloneable {
private String sObjectSearch;
@UriParam
private String apexMethod;
+ @UriParam(displayName = "Event Name", label = "producer")
+ private String eventName;
+ @UriParam(displayName = "Event Schema Format", label = "producer")
+ private EventSchemaFormatEnum eventSchemaFormat;
+ @UriParam(displayName = "Event Schema Id", label = "producer")
+ private String eventSchemaId;
@UriParam(label = "producer")
private String compositeMethod;
@UriParam(label = "producer", defaultValue = "false", description = "Composite API option to indicate" +
@@ -813,10 +823,13 @@ public class SalesforceEndpointConfig implements Cloneable {
valueMap.put(SOBJECT_SEARCH, sObjectSearch);
valueMap.put(APEX_METHOD, apexMethod);
valueMap.put(APEX_URL, apexUrl);
+ // apexQueryParams are handled explicitly in AbstractRestProcessor
valueMap.put(COMPOSITE_METHOD, compositeMethod);
valueMap.put(LIMIT, limit);
valueMap.put(APPROVAL, approval);
- // apexQueryParams are handled explicitly in AbstractRestProcessor
+ valueMap.put(EVENT_NAME, eventName);
+ valueMap.put(EVENT_SCHEMA_FORMAT, eventSchemaFormat);
+ valueMap.put(EVENT_SCHEMA_ID, eventSchemaId);
// add bulk API properties
if (contentType != null) {
@@ -1174,4 +1187,44 @@ public class SalesforceEndpointConfig implements Cloneable {
this.pubSubBatchSize = pubSubBatchSize;
}
+ public String getEventName() {
+ return eventName;
+ }
+
+ /**
+ * Name of Platform Event, Change Data Capture Event, custom event, etc.
+ *
+ * @param eventName
+ */
+ public void setEventName(String eventName) {
+ this.eventName = eventName;
+ }
+
+ public EventSchemaFormatEnum getEventSchemaFormat() {
+ return eventSchemaFormat;
+ }
+
+ /**
+ * EXPANDED: Apache Avro format but doesn’t strictly adhere to the record complex type. COMPACT: Apache Avro,
+ * adheres to the specification for the record complex type. This parameter is available in API version 43.0 and
+ * later.
+ *
+ * @param eventSchemaFormat
+ */
+ public void setEventSchemaFormat(EventSchemaFormatEnum eventSchemaFormat) {
+ this.eventSchemaFormat = eventSchemaFormat;
+ }
+
+ public String getEventSchemaId() {
+ return eventSchemaId;
+ }
+
+ /**
+ * The ID of the event schema.
+ *
+ * @param eventSchemaId
+ */
+ public void setEventSchemaId(String eventSchemaId) {
+ this.eventSchemaId = eventSchemaId;
+ }
}
diff --git a/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/SalesforceProducer.java b/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/SalesforceProducer.java
index 6ef4ff027f8..77a12e7c060 100644
--- a/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/SalesforceProducer.java
+++ b/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/SalesforceProducer.java
@@ -48,7 +48,7 @@ public class SalesforceProducer extends DefaultAsyncProducer {
public SalesforceProducer(SalesforceEndpoint endpoint) throws SalesforceException {
super(endpoint);
- // check if its a Bulk Operation
+ // check if it's a Bulk Operation
final OperationName operationName = endpoint.getOperationName();
if (isBulkOperation(operationName)) {
processor = new BulkApiProcessor(endpoint);
diff --git a/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/api/utils/JsonUtils.java b/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/api/utils/JsonUtils.java
index 3c7a134372b..3d1d1511797 100644
--- a/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/api/utils/JsonUtils.java
+++ b/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/api/utils/JsonUtils.java
@@ -148,18 +148,20 @@ public final class JsonUtils {
throws JsonProcessingException {
ObjectMapper schemaObjectMapper = createSchemaObjectMapper();
return getJsonSchemaString(schemaObjectMapper,
- getSObjectJsonSchema(schemaObjectMapper, description, DEFAULT_ID_PREFIX, addQuerySchema), DEFAULT_ID_PREFIX);
+ getSObjectJsonSchema(schemaObjectMapper, description, DEFAULT_ID_PREFIX, addQuerySchema, false),
+ DEFAULT_ID_PREFIX);
}
public static JsonSchema getSObjectJsonSchemaAsSchema(SObjectDescription description, boolean addQuerySchema)
throws JsonProcessingException {
ObjectMapper schemaObjectMapper = createSchemaObjectMapper();
- return getJsonSchemaAsSchema(getSObjectJsonSchema(schemaObjectMapper, description, DEFAULT_ID_PREFIX, addQuerySchema),
+ return getJsonSchemaAsSchema(
+ getSObjectJsonSchema(schemaObjectMapper, description, DEFAULT_ID_PREFIX, addQuerySchema, false),
DEFAULT_ID_PREFIX);
}
public static Set<JsonSchema> getSObjectJsonSchema(
- ObjectMapper objectMapper, SObjectDescription description, String idPrefix, boolean addQuerySchema)
+ ObjectMapper objectMapper, SObjectDescription description, String idPrefix, boolean addQuerySchema, boolean forCdc)
throws JsonProcessingException {
Set<JsonSchema> allSchemas = new HashSet<>();
@@ -280,7 +282,7 @@ public final class JsonUtils {
fieldSchema.setDescription(descriptionText);
// add property to sobject schema
- if (field.isNillable()) {
+ if (field.isNillable() || forCdc) {
sobjectSchema.putOptionalProperty(field.getName(), fieldSchema);
} else {
sobjectSchema.putProperty(field.getName(), fieldSchema);
@@ -308,6 +310,71 @@ public final class JsonUtils {
return allSchemas;
}
+ public static JsonSchema getCdcSchema(
+ ObjectMapper objectMapper, Iterable<SObjectDescription> descriptions,
+ String idPrefix)
+ throws JsonProcessingException {
+ ObjectSchema cdcSchema = new ObjectSchema();
+ cdcSchema.set$schema(SCHEMA4);
+ cdcSchema.setId(idPrefix + ":cdc");
+ cdcSchema.setTitle("CDC Change Events");
+
+ ObjectSchema header = new ObjectSchema();
+ header.putProperty("entityName", new StringSchema());
+
+ ArraySchema recordIds = new ArraySchema();
+ recordIds.setItems(new ArraySchema.SingleItems(new StringSchema()));
+ header.putProperty("recordIds", recordIds);
+
+ ArraySchema changedFields = new ArraySchema();
+ changedFields.setItems(new ArraySchema.SingleItems(new StringSchema()));
+ header.putProperty("changedFields", changedFields);
+
+ StringSchema changeType = new StringSchema();
+ changeType.setEnums(Set.of(
+ "CREATE",
+ "UPDATE",
+ "DELETE",
+ "UNDELETE",
+ "GAP_CREATE",
+ "GAP_UPDATE",
+ "GAP_DELETE",
+ "GAP_UNDELETE",
+ "GAP_OVERFLOW"));
+ header.putProperty("changeType", changeType);
+
+ header.putProperty("changeOrigin", new StringSchema());
+ header.putProperty("transactionKey", new StringSchema());
+ header.putProperty("sequenceNumber", new IntegerSchema());
+ header.putProperty("commitTimestamp", new IntegerSchema());
+ header.putProperty("commitUser", new StringSchema());
+ header.putProperty("commitNumber", new IntegerSchema());
+
+ ObjectSchema data = new ObjectSchema();
+ data.putProperty("schema", new StringSchema());
+
+ ObjectSchema event = new ObjectSchema();
+ event.putProperty("replayId", new IntegerSchema());
+ data.putProperty("event", event);
+
+ cdcSchema.putProperty("data", data);
+ cdcSchema.putProperty("channel", new StringSchema());
+
+ Set<Object> sObjectSchemas = new HashSet<>();
+ for (SObjectDescription d : descriptions) {
+ final ObjectSchema schema
+ = (ObjectSchema) getSObjectJsonSchema(objectMapper, d, idPrefix, false, true).toArray()[0];
+ schema.putProperty("ChangeEventHeader", header);
+ sObjectSchemas.add(schema);
+ }
+
+ ObjectSchema payload = new ObjectSchema();
+ payload.setOneOf(sObjectSchemas);
+ data.putProperty("payload", payload);
+
+ return cdcSchema;
+ }
+
public static ObjectMapper createSchemaObjectMapper() {
ObjectMapper objectMapper = createObjectMapper();
objectMapper.configure(SerializationFeature.WRITE_ENUMS_USING_TO_STRING, true);
diff --git a/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/OperationName.java b/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/OperationName.java
index ea87d77b600..f6c24e7a29b 100644
--- a/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/OperationName.java
+++ b/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/OperationName.java
@@ -41,6 +41,7 @@ public enum OperationName {
SEARCH("search"),
APEX_CALL("apexCall"),
RECENT("recent"),
+ GET_EVENT_SCHEMA("getEventSchema"),
// bulk API
CREATE_JOB("createJob"),
diff --git a/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/client/DefaultRestClient.java b/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/client/DefaultRestClient.java
index 1722e00b76a..c88de491804 100644
--- a/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/client/DefaultRestClient.java
+++ b/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/client/DefaultRestClient.java
@@ -29,6 +29,7 @@ import java.util.Optional;
import org.apache.camel.component.salesforce.SalesforceHttpClient;
import org.apache.camel.component.salesforce.SalesforceLoginConfig;
import org.apache.camel.component.salesforce.api.SalesforceException;
+import org.apache.camel.component.salesforce.api.utils.Version;
import org.apache.camel.component.salesforce.internal.SalesforceSession;
import org.apache.camel.util.ObjectHelper;
import org.apache.camel.util.URISupport;
@@ -43,6 +44,7 @@ public class DefaultRestClient extends AbstractClientBase implements RestClient
private static final String TOKEN_HEADER = "Authorization";
private static final String TOKEN_PREFIX = "Bearer ";
private static final String SERVICES_APEXREST = "/services/apexrest/";
+ private static final String GET_SCHEMA_MINIMUM_VERSION = "40.0";
public DefaultRestClient(final SalesforceHttpClient httpClient, final String version,
final SalesforceSession session,
@@ -344,6 +346,34 @@ public class DefaultRestClient extends AbstractClientBase implements RestClient
}
}
+ @Override
+ public void getEventSchemaByEventName(
+ String eventName, String payloadFormat, Map<String, List<String>> headers, ResponseCallback callback) {
+ validateMinimumVersion(GET_SCHEMA_MINIMUM_VERSION);
+ final Request request;
+ request = getRequest(HttpMethod.GET, sobjectsUrl(eventName) + "/eventSchema" + "?payloadFormat=" + payloadFormat,
+ headers);
+
+ // requires authorization token
+ setAccessToken(request);
+
+ doHttpRequest(request, new DelegatingClientCallback(callback));
+ }
+
+ @Override
+ public void getEventSchemaBySchemaId(
+ String schemaId, String payloadFormat, Map<String, List<String>> headers, ResponseCallback callback) {
+ validateMinimumVersion(GET_SCHEMA_MINIMUM_VERSION);
+ final Request request;
+ request = getRequest(HttpMethod.GET, versionUrl() + "event/eventSchema/" + schemaId + "?payloadFormat=" + payloadFormat,
+ headers);
+
+ // requires authorization token
+ setAccessToken(request);
+
+ doHttpRequest(request, new DelegatingClientCallback(callback));
+ }
+
private String apexCallUrl(String apexUrl, Map<String, Object> queryParams)
throws UnsupportedEncodingException, URISyntaxException {
@@ -380,6 +410,13 @@ public class DefaultRestClient extends AbstractClientBase implements RestClient
return instanceUrl + SERVICES_DATA;
}
+ private void validateMinimumVersion(String minimumVersion) {
+ if (Version.create(version).compareTo(Version.create(minimumVersion)) < 0) {
+ throw new IllegalArgumentException(
+ "Salesforce API version " + minimumVersion + " or newer is required, version " + version + " was detected");
+ }
+ }
+
private String versionUrl() {
ObjectHelper.notNull(version, "version");
return servicesDataUrl() + "v" + version + "/";
diff --git a/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/client/RestClient.java b/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/client/RestClient.java
index 53c2e921c44..c8bf525ff1a 100644
--- a/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/client/RestClient.java
+++ b/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/client/RestClient.java
@@ -250,4 +250,22 @@ public interface RestClient {
* @param callback {@link ResponseCallback} to handle response or exception
*/
void approvals(Map<String, List<String>> headers, ResponseCallback callback);
+
+ /**
+ *
+ * @param eventName Name of event
+ * @param headers additional HTTP headers to send
+ * @param callback {@link ResponseCallback} to handle response or exception
+ */
+ void getEventSchemaByEventName(
+ String eventName, String payloadFormat, Map<String, List<String>> headers, ResponseCallback callback);
+
+ /**
+ *
+ * @param schemaId Id of Schema
+ * @param headers additional HTTP headers to send
+ * @param callback {@link ResponseCallback} to handle response or exception
+ */
+ void getEventSchemaBySchemaId(
+ String schemaId, String payloadFormat, Map<String, List<String>> headers, ResponseCallback callback);
}
diff --git a/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/dto/EventSchemaFormatEnum.java b/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/dto/EventSchemaFormatEnum.java
new file mode 100644
index 00000000000..4f889256dcb
--- /dev/null
+++ b/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/dto/EventSchemaFormatEnum.java
@@ -0,0 +1,44 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.component.salesforce.internal.dto;
+
+public enum EventSchemaFormatEnum {
+
+ // Apache Avro format but doesn't strictly adhere to the record complex type.
+ EXPANDED("EXPANDED"),
+ // Adheres to the Apache Avro specification for the record complex type
+ COMPACT("COMPACT");
+
+ final String value;
+
+ EventSchemaFormatEnum(String value) {
+ this.value = value;
+ }
+
+ public String value() {
+ return this.value;
+ }
+
+ public static EventSchemaFormatEnum fromValue(String value) {
+ for (EventSchemaFormatEnum e : EventSchemaFormatEnum.values()) {
+ if (e.value.equals(value)) {
+ return e;
+ }
+ }
+ throw new IllegalArgumentException(value);
+ }
+}
diff --git a/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/processor/AbstractRestProcessor.java b/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/processor/AbstractRestProcessor.java
index cecd9fd630f..724386879a2 100644
--- a/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/processor/AbstractRestProcessor.java
+++ b/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/processor/AbstractRestProcessor.java
@@ -45,11 +45,14 @@ import org.apache.camel.component.salesforce.api.dto.approval.ApprovalRequest;
import org.apache.camel.component.salesforce.api.dto.approval.ApprovalRequests;
import org.apache.camel.component.salesforce.internal.client.RestClient;
import org.apache.camel.component.salesforce.internal.client.RestClient.ResponseCallback;
+import org.apache.camel.component.salesforce.internal.dto.EventSchemaFormatEnum;
import org.apache.camel.support.service.ServiceHelper;
import static org.apache.camel.component.salesforce.SalesforceEndpointConfig.APEX_METHOD;
import static org.apache.camel.component.salesforce.SalesforceEndpointConfig.APEX_QUERY_PARAM_PREFIX;
import static org.apache.camel.component.salesforce.SalesforceEndpointConfig.APEX_URL;
+import static org.apache.camel.component.salesforce.SalesforceEndpointConfig.EVENT_NAME;
+import static org.apache.camel.component.salesforce.SalesforceEndpointConfig.EVENT_SCHEMA_ID;
import static org.apache.camel.component.salesforce.SalesforceEndpointConfig.SOBJECT_BLOB_FIELD_NAME;
import static org.apache.camel.component.salesforce.SalesforceEndpointConfig.SOBJECT_EXT_ID_NAME;
import static org.apache.camel.component.salesforce.SalesforceEndpointConfig.SOBJECT_EXT_ID_VALUE;
@@ -192,6 +195,9 @@ public abstract class AbstractRestProcessor extends AbstractSalesforceProcessor
case APPROVALS:
processApprovals(exchange, callback);
break;
+ case GET_EVENT_SCHEMA:
+ processGetEventSchema(exchange, callback);
+ break;
default:
throw new SalesforceException("Unknown operation name: " + operationName.value(), null);
}
@@ -212,6 +218,26 @@ public abstract class AbstractRestProcessor extends AbstractSalesforceProcessor
return false;
}
+ private void processGetEventSchema(Exchange exchange, AsyncCallback callback) throws SalesforceException {
+ endpointConfigMap.get(SalesforceEndpointConfig.API_VERSION);
+ final String eventName = getParameter(EVENT_NAME, exchange, IGNORE_BODY, IS_OPTIONAL);
+ final String schemaId = getParameter(EVENT_SCHEMA_ID, exchange, IGNORE_BODY, IS_OPTIONAL);
+ final EventSchemaFormatEnum eventSchemaFormat
+ = getParameter(SalesforceEndpointConfig.EVENT_SCHEMA_FORMAT, exchange, IGNORE_BODY,
+ IS_OPTIONAL, EventSchemaFormatEnum.class);
+ final String payloadFormat
+ = eventSchemaFormat != null ? eventSchemaFormat.value() : EventSchemaFormatEnum.EXPANDED.value();
+ if (eventName != null) {
+ restClient.getEventSchemaByEventName(eventName, payloadFormat, determineHeaders(exchange),
+ processWithResponseCallback(exchange, callback));
+ } else if (schemaId != null) {
+ restClient.getEventSchemaBySchemaId(schemaId, payloadFormat, determineHeaders(exchange),
+ processWithResponseCallback(exchange, callback));
+ } else {
+ throw new SalesforceException("Either " + EVENT_NAME + " or " + EVENT_SCHEMA_ID + " is required.", 0);
+ }
+ }
+
final void processApproval(final Exchange exchange, final AsyncCallback callback) throws SalesforceException {
final TypeConverter converter = exchange.getContext().getTypeConverter();
diff --git a/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/processor/SalesforceProcessor.java b/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/processor/SalesforceProcessor.java
index d3e3533c13e..c1bc35716fa 100644
--- a/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/processor/SalesforceProcessor.java
+++ b/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/processor/SalesforceProcessor.java
@@ -57,8 +57,6 @@ public interface SalesforceProcessor extends Service {
}
}
}
-
return answer;
}
-
}
diff --git a/components/camel-salesforce/camel-salesforce-component/src/test/java/org/apache/camel/component/salesforce/RestApiIntegrationTest.java b/components/camel-salesforce/camel-salesforce-component/src/test/java/org/apache/camel/component/salesforce/RestApiIntegrationTest.java
index 1ef44f6d2f6..e8fa5e95704 100644
--- a/components/camel-salesforce/camel-salesforce-component/src/test/java/org/apache/camel/component/salesforce/RestApiIntegrationTest.java
+++ b/components/camel-salesforce/camel-salesforce-component/src/test/java/org/apache/camel/component/salesforce/RestApiIntegrationTest.java
@@ -16,6 +16,7 @@
*/
package org.apache.camel.component.salesforce;
+import java.io.IOException;
import java.io.InputStream;
import java.nio.charset.StandardCharsets;
import java.time.ZoneId;
@@ -74,6 +75,8 @@ import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Tag;
import org.junit.jupiter.api.Test;
+import static org.apache.camel.component.salesforce.SalesforceEndpointConfig.EVENT_NAME;
+import static org.apache.camel.component.salesforce.SalesforceEndpointConfig.EVENT_SCHEMA_ID;
import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertFalse;
import static org.junit.jupiter.api.Assertions.assertNotNull;
@@ -526,6 +529,35 @@ public class RestApiIntegrationTest extends AbstractSalesforceTestBase {
assertNotNull(versions);
}
+ @Test
+ public void testGetEventSchemaByEventName() {
+ final Object expandedResult
+ = template.requestBodyAndHeader("salesforce:getEventSchema", "", EVENT_NAME, "BatchApexErrorEvent");
+ assertNotNull(expandedResult);
+
+ final Object compactResult = template.requestBodyAndHeaders("salesforce:getEventSchema", "",
+ Map.of(EVENT_NAME, "BatchApexErrorEvent",
+ SalesforceEndpointConfig.EVENT_SCHEMA_FORMAT, "compact"));
+ assertNotNull(compactResult);
+ }
+
+ @Test
+ public void testGetEventSchemaBySchemaId() throws IOException {
+ final Object schemaResult = template.requestBodyAndHeaders("salesforce:getEventSchema", "",
+ Map.of(EVENT_NAME, "BatchApexErrorEvent",
+ SalesforceEndpointConfig.EVENT_SCHEMA_FORMAT, "compact"));
+ assertNotNull(schemaResult);
+
+ ObjectMapper mapper = new ObjectMapper();
+ @SuppressWarnings("unchecked")
+ final Map<String, Object> map = (Map<String, Object>) mapper.readValue((InputStream) schemaResult, Map.class);
+ final String schemaId = (String) map.get("uuid");
+
+ final Object idResult = template.requestBodyAndHeader("salesforce:getEventSchema", "", EVENT_SCHEMA_ID, schemaId);
+ System.out.println(idResult);
+ assertNotNull(idResult);
+ }
+
@Test
public void testQuery() throws Exception {
createLineItem();