[camel-quarkus] branch main updated: Fix Salesforce endpoint URIs for CDC eventing

[ja...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

jamesnetherton pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git


The following commit(s) were added to refs/heads/main by this push:
     new 64d31353a4 Fix Salesforce endpoint URIs for CDC eventing
64d31353a4 is described below

commit 64d31353a402dad4c9df8ace5a97ec83c1dccb90
Author: James Netherton <ja...@gmail.com>
AuthorDate: Mon Oct 10 07:32:08 2022 +0100

    Fix Salesforce endpoint URIs for CDC eventing
    
    Fixes #4161
---
 .../camel/quarkus/component/salesforce/SalesforceResource.java      | 2 +-
 .../apache/camel/quarkus/component/salesforce/SalesforceRoutes.java | 6 +++---
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/integration-tests/salesforce/src/main/java/org/apache/camel/quarkus/component/salesforce/SalesforceResource.java b/integration-tests/salesforce/src/main/java/org/apache/camel/quarkus/component/salesforce/SalesforceResource.java
index e6b7383358..309d735852 100644
--- a/integration-tests/salesforce/src/main/java/org/apache/camel/quarkus/component/salesforce/SalesforceResource.java
+++ b/integration-tests/salesforce/src/main/java/org/apache/camel/quarkus/component/salesforce/SalesforceResource.java
@@ -290,7 +290,7 @@ public class SalesforceResource {
     @GET
     @Produces(MediaType.APPLICATION_JSON)
     public String getPlatformEvent() {
-        return consumerTemplate.receiveBody("salesforce:event/TestEvent__e?rawPayload=true", 10000, String.class);
+        return consumerTemplate.receiveBody("salesforce:subscribe:event/TestEvent__e?rawPayload=true", 10000, String.class);
     }
 
     private JsonObject accountToJsonObject(Account account) {
diff --git a/integration-tests/salesforce/src/main/java/org/apache/camel/quarkus/component/salesforce/SalesforceRoutes.java b/integration-tests/salesforce/src/main/java/org/apache/camel/quarkus/component/salesforce/SalesforceRoutes.java
index 5c12346250..d952e85347 100644
--- a/integration-tests/salesforce/src/main/java/org/apache/camel/quarkus/component/salesforce/SalesforceRoutes.java
+++ b/integration-tests/salesforce/src/main/java/org/apache/camel/quarkus/component/salesforce/SalesforceRoutes.java
@@ -73,17 +73,17 @@ public class SalesforceRoutes extends RouteBuilder {
         if (!wireMockUrl.isPresent()) {
 
             // Change Data Capture
-            from("salesforce:/data/AccountChangeEvent?replayId=-1").routeId("cdc").autoStartup(false)
+            from("salesforce:subscribe:/data/AccountChangeEvent?replayId=-1").routeId("cdc").autoStartup(false)
                     .to("seda:events");
 
             // Streaming API : topic consumer - getting Account object
-            from("salesforce:CamelTestTopic?notifyForFields=ALL&"
+            from("salesforce:subscribe:CamelTestTopic?notifyForFields=ALL&"
                     + "notifyForOperationCreate=true&notifyForOperationDelete=true&notifyForOperationUpdate=true&"
                     + "sObjectClass=" + Account.class.getName() + "&updateTopic=true&sObjectQuery=SELECT Id, Name FROM Account")
                             .to("seda:CamelTestTopic");
 
             // Streaming API : topic consumer with RAW Payload - getting json as String
-            from("salesforce:CamelTestTopic?rawPayload=true&notifyForFields=ALL&"
+            from("salesforce:subscribe:CamelTestTopic?rawPayload=true&notifyForFields=ALL&"
                     + "notifyForOperationCreate=true&notifyForOperationDelete=true&notifyForOperationUpdate=true&"
                     + "updateTopic=true&sObjectQuery=SELECT Id, Name FROM Account")
                             .to("seda:RawPayloadCamelTestTopic");