Talend ESB: cMessagingEndpoint - could not connect to salesforce platform event

Six Stars

Talend ESB: cMessagingEndpoint - could not connect to salesforce platform event

Hi,

We need to load data into Salesforce Table on a real time basis. So trying to develop a Talend ESB Job . We could not find the correct URI syntax to connect to Salesforce Table in cmessagingendpoint component.

salesforce:topic?options

I tried options like "salesforce:sobject= SFDCTablename?username=SFDCuser&password=SFDCpassword&loginURL= SalesforceEndpointURL"

If Somebody had faced this problem, what is the solution?

Sixteen Stars

Re: Talend ESB: cMessagingEndpoint - could not connect to salesforce Table

Have you looked here: http://camel.apache.org/salesforce.html ?

 

Also, can you let us know what error you are getting?

Six Stars

Re: Talend ESB: cMessagingEndpoint - could not connect to salesforce platform event

Hi rhall,

 

Yes I looked at that link. We need to give the URI. But I am unable to find the correct syntax for the URI in that component

 

I tried to give the URI syntax like this but with no luck  -----> "salesforce:sobject= SFDCTablename?username=SFDCuser&password=SFDCpassword&loginURL= SalesforceEndpointURL"

 

Here are the logs

 

Failed to create route write_data_salesforce at: >>>
because of Failed to resolve endpoint:
due to: Cannot auto create component: salesforce
at org.apache.camel.model.RouteDefinition.addRoutes(RouteDefinition.java:1072)
at org.apache.camel.model.RouteDefinition.addRoutes(RouteDefinition.java:196)
at org.apache.camel.impl.DefaultCamelContext.startRoute(DefaultCamelContext.java:944)
at org.apache.camel.impl.DefaultCamelContext.startRouteDefinitions(DefaultCamelContext.java:3260)
at org.apache.camel.impl.DefaultCamelContext.doStartCamel(DefaultCamelContext.java:2983)
at org.apache.camel.impl.DefaultCamelContext.access$000(DefaultCamelContext.java:175)
at org.apache.camel.impl.DefaultCamelContext$2.call(DefaultCamelContext.java:2814)
at org.apache.camel.impl.DefaultCamelContext$2.call(DefaultCamelContext.java:2810)
at org.apache.camel.impl.DefaultCamelContext.doWithDefinedClassLoader(DefaultCamelContext.java:2833)
at org.apache.camel.impl.DefaultCamelContext.doStart(DefaultCamelContext.java:2810)
at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61)
at org.apache.camel.impl.DefaultCamelContext.start(DefaultCamelContext.java:2779)
at org.apache.camel.main.Main.doStart(Main.java:126)
at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61)
at org.apache.camel.main.MainSupport.run(MainSupport.java:124)
at talend_etl_project.write_data_salesforce_0_1.write_data_salesforce.run(write_data_salesforce.java:155)
at talend_etl_project.write_data_salesforce_0_1.write_data_salesforce.runJobInTOS(write_data_salesforce.java:217)
at talend_etl_project.write_data_salesforce_0_1.write_data_salesforce.main(write_data_salesforce.java:187)
Caused by: org.apache.camel.ResolveEndpointFailedException: Failed to resolve endpoint: salesforce://upsertSObject?loginUrl=https%3A%2F%2Fabc--dev.cs67.my.salesforce.com%2Fservices%2FSoap%2Fu%2F39.0&password=abc123%40&sObjectIdName=Reservation_Event__e&userName=datascience_api%40abc.com.dev due to: Cannot auto create component: salesforce
at org.apache.camel.impl.DefaultCamelContext.getEndpoint(DefaultCamelContext.java:587)
at org.apache.camel.util.CamelContextHelper.getMandatoryEndpoint(CamelContextHelper.java:79)
at org.apache.camel.model.RouteDefinition.resolveEndpoint(RouteDefinition.java:211)
at org.apache.camel.impl.DefaultRouteContext.resolveEndpoint(DefaultRouteContext.java:107)
at org.apache.camel.impl.DefaultRouteContext.resolveEndpoint(DefaultRouteContext.java:113)
at org.apache.camel.model.SendDefinition.resolveEndpoint(SendDefinition.java:62)
at org.apache.camel.model.SendDefinition.createProcessor(SendDefinition.java:56)
at org.apache.camel.model.ProcessorDefinition.makeProcessorImpl(ProcessorDefinition.java:535)
at org.apache.camel.model.ProcessorDefinition.makeProcessor(ProcessorDefinition.java:496)
at org.apache.camel.model.ProcessorDefinition.addRoutes(ProcessorDefinition.java:220)
at org.apache.camel.model.RouteDefinition.addRoutes(RouteDefinition.java:1069)
... 17 more
Caused by: org.apache.camel.RuntimeCamelException: Cannot auto create component: salesforce
at org.apache.camel.impl.DefaultCamelContext.getComponent(DefaultCamelContext.java:409)
at org.apache.camel.impl.DefaultCamelContext.getComponent(DefaultCamelContext.java:385)
at org.apache.camel.impl.DefaultCamelContext.getEndpoint(DefaultCamelContext.java:557)
... 27 more
Caused by: java.lang.IllegalArgumentException: loginConfig must be specified
at org.apache.camel.util.ObjectHelper.notNull(ObjectHelper.java:316)
at org.apache.camel.component.salesforce.SalesforceComponent.doStart(SalesforceComponent.java:193)
at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61)
at org.apache.camel.impl.DefaultCamelContext.startService(DefaultCamelContext.java:3234)
at org.apache.camel.impl.DefaultCamelContext.getComponent(DefaultCamelContext.java:404)
... 29 more
Job write_data_salesforce ended at 14:56 22/06/2018. [exit code=1]

 

 

Six Stars

Re: Talend ESB: cMessagingEndpoint - could not connect to salesforce platform event

Yes, I looked at that link. The syntax is not clear. I have tried the URI syntax as below

"salesforce:sobject= SFDCTablename?username=SFDCuser&password=SFDCpassword&loginURL= SalesforceEndpointURL"

Here are the logs

Starting job read_data_Salesforce at 14:56 22/06/2018.

SLF4J: Class path contains multiple SLF4J bindings.
SLF4J: Found binding in [jar:file:/D:/Talend-6.4/workspace/.Java/lib/Salesforce-all-5.14.5.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in [jar:file:/D:/Talend-6.4/workspace/.Java/lib/slf4j-log4j12-1.7.5.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
SLF4J: Actual binding is of type [org.slf4j.impl.Log4jLoggerFactory]
[statistics] connecting to socket on port 3595
[statistics] connected
Failed to create route read_data_Salesforce_cJMS_2 at: >>> To[salesforce:upsertSObject?sObjectIdName=Reservation_Event__e&userName=datascience_api@abc.com.dev&password=abc@&loginUrl=https://abc--dev.cs67.my.salesforce.com/services/Soap/u/39.0] <<< in route: Route(read_data_Salesforce_cJMS_2)[[From[cMQConnectionFactory1... because of Failed to resolve endpoint: salesforce://upsertSObject?loginUrl=https%3A%2F%2Fabc--dev.cs67.my.salesforce.com%2Fservices%2FSoap%2Fu%2F39.0&password=abc%40&sObjectIdName=Reservation_Event__e&userName=datascience_api%40abc.com.dev due to: Cannot auto create component: salesforce
org.apache.camel.FailedToCreateRouteException: Failed to create route read_data_Salesforce_cJMS_2 at: >>> To[salesforce:upsertSObject?sObjectIdName=Reservation_Event__e&userName=datascience_api@abc.com.dev&password=abc@&loginUrl=https://abc--dev.cs67.my.salesforce.com/services/Soap/u/39.0] <<< in route: Route(read_data_Salesforce_cJMS_2)[[From[cMQConnectionFactory1... because of Failed to resolve endpoint: salesforce://upsertSObject?loginUrl=https%3A%2F%2Fabc--dev.cs67.my.salesforce.com%2Fservices%2FSoap%2Fu%2F39.0&password=abc%40&sObjectIdName=Reservation_Event__e&userName=datascience_api%40abc.com.dev due to: Cannot auto create component: salesforce
at org.apache.camel.model.RouteDefinition.addRoutes(RouteDefinition.java:1072)
at org.apache.camel.model.RouteDefinition.addRoutes(RouteDefinition.java:196)
at org.apache.camel.impl.DefaultCamelContext.startRoute(DefaultCamelContext.java:944)
at org.apache.camel.impl.DefaultCamelContext.startRouteDefinitions(DefaultCamelContext.java:3260)
at org.apache.camel.impl.DefaultCamelContext.doStartCamel(DefaultCamelContext.java:2983)
at org.apache.camel.impl.DefaultCamelContext.access$000(DefaultCamelContext.java:175)
at org.apache.camel.impl.DefaultCamelContext$2.call(DefaultCamelContext.java:2814)
at org.apache.camel.impl.DefaultCamelContext$2.call(DefaultCamelContext.java:2810)
at org.apache.camel.impl.DefaultCamelContext.doWithDefinedClassLoader(DefaultCamelContext.java:2833)
at org.apache.camel.impl.DefaultCamelContext.doStart(DefaultCamelContext.java:2810)
at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61)
at org.apache.camel.impl.DefaultCamelContext.start(DefaultCamelContext.java:2779)
at org.apache.camel.main.Main.doStart(Main.java:126)
at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61)
at org.apache.camel.main.MainSupport.run(MainSupport.java:124)
at talend_etl_project.read_data_Salesforce_0_1.read_data_Salesforce.run(read_data_Salesforce.java:155)
at talend_etl_project.read_data_Salesforce_0_1.read_data_Salesforce.runJobInTOS(read_data_Salesforce.java:217)
at talend_etl_project.read_data_Salesforce_0_1.read_data_Salesforce.main(read_data_Salesforce.java:187)
Caused by: org.apache.camel.ResolveEndpointFailedException: Failed to resolve endpoint: salesforce://upsertSObject?loginUrl=https%3A%2F%2Fabc--dev.cs67.my.salesforce.com%2Fservices%2FSoap%2Fu%2F39.0&password=abc%40&sObjectIdName=Reservation_Event__e&userName=datascience_api%40abc.com.dev due to: Cannot auto create component: salesforce
at org.apache.camel.impl.DefaultCamelContext.getEndpoint(DefaultCamelContext.java:587)
at org.apache.camel.util.CamelContextHelper.getMandatoryEndpoint(CamelContextHelper.java:79)
at org.apache.camel.model.RouteDefinition.resolveEndpoint(RouteDefinition.java:211)
at org.apache.camel.impl.DefaultRouteContext.resolveEndpoint(DefaultRouteContext.java:107)
at org.apache.camel.impl.DefaultRouteContext.resolveEndpoint(DefaultRouteContext.java:113)
at org.apache.camel.model.SendDefinition.resolveEndpoint(SendDefinition.java:62)
at org.apache.camel.model.SendDefinition.createProcessor(SendDefinition.java:56)
at org.apache.camel.model.ProcessorDefinition.makeProcessorImpl(ProcessorDefinition.java:535)
at org.apache.camel.model.ProcessorDefinition.makeProcessor(ProcessorDefinition.java:496)
at org.apache.camel.model.ProcessorDefinition.addRoutes(ProcessorDefinition.java:220)
at org.apache.camel.model.RouteDefinition.addRoutes(RouteDefinition.java:1069)
... 17 more
Caused by: org.apache.camel.RuntimeCamelException: Cannot auto create component: salesforce
at org.apache.camel.impl.DefaultCamelContext.getComponent(DefaultCamelContext.java:409)
at org.apache.camel.impl.DefaultCamelContext.getComponent(DefaultCamelContext.java:385)
at org.apache.camel.impl.DefaultCamelContext.getEndpoint(DefaultCamelContext.java:557)
... 27 more
Caused by: java.lang.IllegalArgumentException: loginConfig must be specified
at org.apache.camel.util.ObjectHelper.notNull(ObjectHelper.java:316)
at org.apache.camel.component.salesforce.SalesforceComponent.doStart(SalesforceComponent.java:193)
at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61)
at org.apache.camel.impl.DefaultCamelContext.startService(DefaultCamelContext.java:3234)
at org.apache.camel.impl.DefaultCamelContext.getComponent(DefaultCamelContext.java:404)
... 29 more
Job read_data_Salesforce ended at 14:56 22/06/2018. [exit code=1]

 

Tutorial

Introduction to Talend Open Studio for Data Integration.

Definitive Guide to Data Integration

Practical steps to developing your data integration strategy.

Definitive Guide to Data Quality

Create systems and workflow to manage clean data ingestion and data transformation.