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]