[jira] [Created] (CAMEL-12776) camel-salesforce: Platform event subscription fails pretty frequently

["sowjanya mudimala (JIRA)" <ji...@apache.org>]

sowjanya mudimala created CAMEL-12776:
-----------------------------------------

             Summary: camel-salesforce: Platform event subscription fails pretty frequently
                 Key: CAMEL-12776
                 URL: https://issues.apache.org/jira/browse/CAMEL-12776
             Project: Camel
          Issue Type: Bug
          Components: camel-salesforce
    Affects Versions: 2.23.0
         Environment: $ java --version
java 10.0.2 2018-07-17
Java(TM) SE Runtime Environment 18.3 (build 10.0.2+13)
Java HotSpot(TM) 64-Bit Server VM 18.3 (build 10.0.2+13, mixed mode)
            Reporter: sowjanya mudimala


I have a simple route to subscribe to Salesforce platform event and send to AWS-SQS queue. I am using mvn to execute the jar. sometimes code is working fine and prints the platform event data. but most of the times as soon as I run the jar, I see the attached "org.cometd.common.TransportException: null" error. connection doesn't recover by itself. I have to re-execute the jar. It fails pretty frequently that I am unable to use the feature. 
{code:java}
context.addRoutes(new RouteBuilder() {
@Override
public void configure() throws Exception {

from("sfdc:event/Netsuite_Customer_Event__e")
.process(new Processor() {

@Override
public void process(Exchange exchange) throws Exception {

PlatformEvent event = exchange.getIn().getBody(PlatformEvent.class);
System.out.println("****************Received Event : " + event.getEventData().toString());
//	org.cometd.bayeux.Message event = exchange.getIn().getBody(org.cometd.bayeux.Message.class);
//	System.out.println("Received Event: " + event.getJSON());

}

})
.to("aws-sqs:"
+ "FIFOQueue.fifo"
+ "?amazonSQSClient=#sqsClient"
+ "&extendMessageVisibility="
+ true
+ "&messageGroupIdStrategy=useConstant"
+ "&visibilityTimeout="
+ 900
+ "&attributeNames=ApproximateFirstReceiveTimestamp,ApproximateReceiveCount,SentTimestamp");

}
});
{code}
{noformat}
 
2018-09-04 15:49:07 DEBUG SubscriptionHelper:394 - [CHANNEL:META_SUBSCRIBE]: {failure={exception=org.cometd.common.TransportException: null, message={ext={replay={}}, channel=/meta/subscribe, id=6, subscription=/event/Netsuite_Customer_Event__e}}, channel=/meta/subscribe, id=6, subscription=/event/Netsuite_Customer_Event__e, successful=false} 2018-09-04 15:49:07 DEBUG SubscriptionHelper:394 - [CHANNEL:META_SUBSCRIBE]: {failure={exception=org.cometd.common.TransportException: null, message={ext={replay={}}, channel=/meta/subscribe, id=6, subscription=/event/Netsuite_Customer_Event__e}}, channel=/meta/subscribe, id=6, subscription=/event/Netsuite_Customer_Event__e, successful=false} 2018-09-04 15:49:07 DEBUG SubscriptionHelper:394 - [CHANNEL:META_SUBSCRIBE]: {failure={exception=org.cometd.common.TransportException: null, message={ext={replay={}}, channel=/meta/subscribe, id=6, subscription=/event/Netsuite_Customer_Event__e}}, channel=/meta/subscribe, id=6, subscription=/event/Netsuite_Customer_Event__e, successful=false} 2018-09-04 15:49:07 WARN SalesforceConsumer:213 - Error subscribing to event/Netsuite_Customer_Event__e: null. Caused by: [org.apache.camel.component.salesforce.api.SalesforceException - Error subscribing to event/Netsuite_Customer_Event__e: null] org.apache.camel.component.salesforce.api.SalesforceException: Error subscribing to event/Netsuite_Customer_Event__e: null at org.apache.camel.component.salesforce.internal.streaming.SubscriptionHelper$7.onMessage(SubscriptionHelper.java:406) at org.cometd.common.AbstractClientSession$AbstractSessionChannel.notifyOnMessage(AbstractClientSession.java:594) at org.cometd.common.AbstractClientSession$AbstractSessionChannel.notifyMessageListeners(AbstractClientSession.java:579) at org.cometd.common.AbstractClientSession.notifyListeners(AbstractClientSession.java:291) at org.cometd.common.AbstractClientSession.receive(AbstractClientSession.java:257) at org.cometd.client.BayeuxClient.failMessage(BayeuxClient.java:843) at org.cometd.client.BayeuxClient.messageFailure(BayeuxClient.java:839) at org.cometd.client.BayeuxClient.messagesFailure(BayeuxClient.java:670) at org.cometd.client.BayeuxClient$SessionState.send(BayeuxClient.java:1536) at org.cometd.client.BayeuxClient$SessionState.access$1400(BayeuxClient.java:1214) at org.cometd.client.BayeuxClient.sendMessages(BayeuxClient.java:475) at org.cometd.client.BayeuxClient.enqueueSend(BayeuxClient.java:975) at org.cometd.client.BayeuxClient.send(BayeuxClient.java:968) at org.cometd.common.AbstractClientSession$AbstractSessionChannel.sendSubscribe(AbstractClientSession.java:469) at org.cometd.common.AbstractClientSession$AbstractSessionChannel.subscribe(AbstractClientSession.java:456) at org.cometd.common.AbstractClientSession$AbstractSessionChannel.subscribe(AbstractClientSession.java:446) at org.apache.camel.component.salesforce.internal.streaming.SubscriptionHelper.subscribe(SubscriptionHelper.java:421) at org.apache.camel.component.salesforce.SalesforceConsumer.doStart(SalesforceConsumer.java:265) at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:72) at org.apache.camel.impl.DefaultCamelContext.startService(DefaultCamelContext.java:3708) at org.apache.camel.impl.DefaultCamelContext.doStartOrResumeRouteConsumers(DefaultCamelContext.java:4026) at org.apache.camel.impl.DefaultCamelContext.doStartRouteConsumers(DefaultCamelContext.java:3961) at org.apache.camel.impl.DefaultCamelContext.safelyStartRouteServices(DefaultCamelContext.java:3881) at org.apache.camel.impl.DefaultCamelContext.doStartOrResumeRoutes(DefaultCamelContext.java:3645) at org.apache.camel.impl.DefaultCamelContext.doStartCamel(DefaultCamelContext.java:3488) at org.apache.camel.impl.DefaultCamelContext$4.call(DefaultCamelContext.java:3247) at org.apache.camel.impl.DefaultCamelContext$4.call(DefaultCamelContext.java:3243) at org.apache.camel.impl.DefaultCamelContext.doWithDefinedClassLoader(DefaultCamelContext.java:3266) at org.apache.camel.impl.DefaultCamelContext.doStart(DefaultCamelContext.java:3243) at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:72) at org.apache.camel.impl.DefaultCamelContext.start(DefaultCamelContext.java:3159) at com.tableau.ea.App.main(App.java:112) at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.base/java.lang.reflect.Method.invoke(Method.java:564) at org.codehaus.mojo.exec.ExecJavaMojo$1.run(ExecJavaMojo.java:282) at java.base/java.lang.Thread.run(Thread.java:844) Caused by: org.cometd.common.TransportException: null ... 30 more 2018-09-04 15:49:07 WARN SalesforceConsumer:213 - Error subscribing to event/Netsuite_Customer_Event__e: null. Caused by: [org.apache.camel.component.salesforce.api.SalesforceException - Error subscribing to event/Netsuite_Customer_Event__e: null] org.apache.camel.component.salesforce.api.SalesforceException: Error subscribing to event/Netsuite_Customer_Event__e: null at org.apache.camel.component.salesforce.internal.streaming.SubscriptionHelper$7.onMessage(SubscriptionHelper.java:406) at org.cometd.common.AbstractClientSession$AbstractSessionChannel.notifyOnMessage(AbstractClientSession.java:594) at org.cometd.common.AbstractClientSession$AbstractSessionChannel.notifyMessageListeners(AbstractClientSession.java:579) at org.cometd.common.AbstractClientSession.notifyListeners(AbstractClientSession.java:291) at org.cometd.common.AbstractClientSession.receive(AbstractClientSession.java:257) at org.cometd.client.BayeuxClient.failMessage(BayeuxClient.java:843) at org.cometd.client.BayeuxClient.messageFailure(BayeuxClient.java:839) at org.cometd.client.BayeuxClient.messagesFailure(BayeuxClient.java:670) at org.cometd.client.BayeuxClient$SessionState.send(BayeuxClient.java:1536) at org.cometd.client.BayeuxClient$SessionState.access$1400(BayeuxClient.java:1214) at org.cometd.client.BayeuxClient.sendMessages(BayeuxClient.java:475) at org.cometd.client.BayeuxClient.enqueueSend(BayeuxClient.java:975) at org.cometd.client.BayeuxClient.send(BayeuxClient.java:968) at org.cometd.common.AbstractClientSession$AbstractSessionChannel.sendSubscribe(AbstractClientSession.java:469) at org.cometd.common.AbstractClientSession$AbstractSessionChannel.subscribe(AbstractClientSession.java:456) at org.cometd.common.AbstractClientSession$AbstractSessionChannel.subscribe(AbstractClientSession.java:446) at org.apache.camel.component.salesforce.internal.streaming.SubscriptionHelper.subscribe(SubscriptionHelper.java:421) at org.apache.camel.component.salesforce.SalesforceConsumer.doStart(SalesforceConsumer.java:265) at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:72) at org.apache.camel.impl.DefaultCamelContext.startService(DefaultCamelContext.java:3708) at org.apache.camel.impl.DefaultCamelContext.doStartOrResumeRouteConsumers(DefaultCamelContext.java:4026) at org.apache.camel.impl.DefaultCamelContext.doStartRouteConsumers(DefaultCamelContext.java:3961) at org.apache.camel.impl.DefaultCamelContext.safelyStartRouteServices(DefaultCamelContext.java:3881) at org.apache.camel.impl.DefaultCamelContext.doStartOrResumeRoutes(DefaultCamelContext.java:3645) at org.apache.camel.impl.DefaultCamelContext.doStartCamel(DefaultCamelContext.java:3488) at org.apache.camel.impl.DefaultCamelContext$4.call(DefaultCamelContext.java:3247) at org.apache.camel.impl.DefaultCamelContext$4.call(DefaultCamelContext.java:3243) at org.apache.camel.impl.DefaultCamelContext.doWithDefinedClassLoader(DefaultCamelContext.java:3266) at org.apache.camel.impl.DefaultCamelContext.doStart(DefaultCamelContext.java:3243) at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:72) at org.apache.camel.impl.DefaultCamelContext.start(DefaultCamelContext.java:3159) at com.tableau.ea.App.main(App.java:112) at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.base/java.lang.reflect.Method.invoke(Method.java:564) at org.codehaus.mojo.exec.ExecJavaMojo$1.run(ExecJavaMojo.java:282) at java.base/java.lang.Thread.run(Thread.java:844) Caused by: org.cometd.common.TransportException: null ... 30 more 2018-09-04 15:49:07 WARN SalesforceConsumer:213 - Error subscribing to event/Netsuite_Customer_Event__e: null. Caused by: [org.apache.camel.component.salesforce.api.SalesforceException - Error subscribing to event/Netsuite_Customer_Event__e: null] org.apache.camel.component.salesforce.api.SalesforceException: Error subscribing to event/Netsuite_Customer_Event__e: null at org.apache.camel.component.salesforce.internal.streaming.SubscriptionHelper$7.onMessage(SubscriptionHelper.java:406) at org.cometd.common.AbstractClientSession$AbstractSessionChannel.notifyOnMessage(AbstractClientSession.java:594) at org.cometd.common.AbstractClientSession$AbstractSessionChannel.notifyMessageListeners(AbstractClientSession.java:579) at org.cometd.common.AbstractClientSession.notifyListeners(AbstractClientSession.java:291) at org.cometd.common.AbstractClientSession.receive(AbstractClientSession.java:257) at org.cometd.client.BayeuxClient.failMessage(BayeuxClient.java:843) at org.cometd.client.BayeuxClient.messageFailure(BayeuxClient.java:839) at org.cometd.client.BayeuxClient.messagesFailure(BayeuxClient.java:670) at org.cometd.client.BayeuxClient$SessionState.send(BayeuxClient.java:1536) at org.cometd.client.BayeuxClient$SessionState.access$1400(BayeuxClient.java:1214) at org.cometd.client.BayeuxClient.sendMessages(BayeuxClient.java:475) at org.cometd.client.BayeuxClient.enqueueSend(BayeuxClient.java:975) at org.cometd.client.BayeuxClient.send(BayeuxClient.java:968) at org.cometd.common.AbstractClientSession$AbstractSessionChannel.sendSubscribe(AbstractClientSession.java:469) at org.cometd.common.AbstractClientSession$AbstractSessionChannel.subscribe(AbstractClientSession.java:456) at org.cometd.common.AbstractClientSession$AbstractSessionChannel.subscribe(AbstractClientSession.java:446) at org.apache.camel.component.salesforce.internal.streaming.SubscriptionHelper.subscribe(SubscriptionHelper.java:421) at org.apache.camel.component.salesforce.SalesforceConsumer.doStart(SalesforceConsumer.java:265) at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:72) at org.apache.camel.impl.DefaultCamelContext.startService(DefaultCamelContext.java:3708) at org.apache.camel.impl.DefaultCamelContext.doStartOrResumeRouteConsumers(DefaultCamelContext.java:4026) at org.apache.camel.impl.DefaultCamelContext.doStartRouteConsumers(DefaultCamelContext.java:3961) at org.apache.camel.impl.DefaultCamelContext.safelyStartRouteServices(DefaultCamelContext.java:3881) at org.apache.camel.impl.DefaultCamelContext.doStartOrResumeRoutes(DefaultCamelContext.java:3645) at org.apache.camel.impl.DefaultCamelContext.doStartCamel(DefaultCamelContext.java:3488) at org.apache.camel.impl.DefaultCamelContext$4.call(DefaultCamelContext.java:3247) at org.apache.camel.impl.DefaultCamelContext$4.call(DefaultCamelContext.java:3243) at org.apache.camel.impl.DefaultCamelContext.doWithDefinedClassLoader(DefaultCamelContext.java:3266) at org.apache.camel.impl.DefaultCamelContext.doStart(DefaultCamelContext.java:3243) at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:72) at org.apache.camel.impl.DefaultCamelContext.start(DefaultCamelContext.java:3159) at com.tableau.ea.App.main(App.java:112) at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.base/java.lang.reflect.Method.invoke(Method.java:564) at org.codehaus.mojo.exec.ExecJavaMojo$1.run(ExecJavaMojo.java:282) at java.base/java.lang.Thread.run(Thread.java:844) Caused by: org.cometd.common.TransportException: null ... 30 more 2018-09-04 15:49:07 DEBUG 786ebb6a:977 - Failed message {ext={replay={}}, channel=/meta/subscribe, id=6, subscription=/event/Netsuite_Customer_Event__e} 2018-09-04 15:49:07 INFO DefaultCamelContext:4033 - Route: route1 started and consuming from: sfdc://event/Netsuite_Customer_Event__e 2018-09-04 15:49:07 INFO DefaultCamelContext:4033 - Route: route1 started and consuming from: sfdc://event/Netsuite_Customer_Event__e 2018-09-04 15:49:07 INFO DefaultCamelContext:3185 - Total 1 routes, of which 1 are started 2018-09-04 15:49:07 INFO DefaultCamelContext:3185 - Total 1 routes, of which 1 are started 2018-09-04 15:49:07 INFO DefaultCamelContext:3196 - Apache Camel 2.23.0-SNAPSHOT (CamelContext: camel-1) started in 2.351 seconds 2018-09-04 15:49:07 INFO DefaultCamelContext:3196 - Apache Camel 2.23.0-SNAPSHOT (CamelContext: camel-1) started in 2.351 seconds 2018-09-04 15:50:06 DEBUG ReservedThreadExecutor:311 - ReservedThreadExecutor@6da1c1de{s=2/8,p=0}@168e6309 IDLE 2018-09-04 15:50:06 DEBUG ReservedThreadExecutor:190 - ReservedThreadExecutor@6da1c1de{s=2/8,p=0} tryExecute STOP! 2018-09-04 15:50:06 DEBUG ReservedThreadExecutor:259 - ReservedThreadExecutor@6da1c1de{s=1/8,p=0}@76cc1848 offer STOP! 2018-09-04 15:50:06 DEBUG ReservedThreadExecutor:317 - ReservedThreadExecutor@6da1c1de{s=1/8,p=0}@76cc1848 task=STOP! 2018-09-04 15:50:06 DEBUG ReservedThreadExecutor:375 - ReservedThreadExecutor@6da1c1de{s=1/8,p=0}@76cc1848 Exited 2018-09-04 15:50:06 DEBUG QueuedThreadPool:682 - ran ReservedThreadExecutor@6da1c1de{s=1/8,p=0}@76cc1848 2018-09-04 15:50:57 DEBUG 786ebb6a:393 - Waited 109840/109835ms for [CONNECTED], state is DISCONNECTED 2018-09-04 15:50:57 ERROR SubscriptionHelper:281 - Error restarting: Error during CONNECT: 403::Unknown client org.apache.camel.CamelException: Error during CONNECT: 403::Unknown client at org.apache.camel.component.salesforce.internal.streaming.SubscriptionHelper.doStart(SubscriptionHelper.java:221) at org.apache.camel.component.salesforce.internal.streaming.SubscriptionHelper$4.run(SubscriptionHelper.java:278) at org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:762) at org.eclipse.jetty.util.thread.QueuedThreadPool$2.run(QueuedThreadPool.java:680) at java.base/java.lang.Thread.run(Thread.java:844) 2018-09-04 15:50:57 ERROR SubscriptionHelper:281 - Error restarting: Error during CONNECT: 403::Unknown client org.apache.camel.CamelException: Error during CONNECT: 403::Unknown client at org.apache.camel.component.salesforce.internal.streaming.SubscriptionHelper.doStart(SubscriptionHelper.java:221) at org.apache.camel.component.salesforce.internal.streaming.SubscriptionHelper$4.run(SubscriptionHelper.java:278) at org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:762) at org.eclipse.jetty.util.thread.QueuedThreadPool$2.run(QueuedThreadPool.java:680) at java.base/java.lang.Thread.run(Thread.java:844) 2018-09-04 15:50:57 ERROR SubscriptionHelper:281 - Error restarting: Error during CONNECT: 403::Unknown client org.apache.camel.CamelException: Error during CONNECT: 403::Unknown client at org.apache.camel.component.salesforce.internal.streaming.SubscriptionHelper.doStart(SubscriptionHelper.java:221) at org.apache.camel.component.salesforce.internal.streaming.SubscriptionHelper$4.run(SubscriptionHelper.java:278) at org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:762) at org.eclipse.jetty.util.thread.QueuedThreadPool$2.run(QueuedThreadPool.java:680) at java.base/java.lang.Thread.run(Thread.java:844) 2018-09-04 15:50:57 ERROR SubscriptionHelper:290 - Failed to restart after pausing for 0 msecs 2018-09-04 15:50:57 ERROR SubscriptionHelper:290 - Failed to restart after pausing for 0 msecs 2018-09-04 15:50:57 ERROR SubscriptionHelper:290 - Failed to restart after pausing for 0 msecs 2018-09-04 15:50:57 DEBUG QueuedThreadPool:682 - ran org.apache.camel.component.salesforce.internal.streaming.SubscriptionHelper$4@539c6eec 2018-09-04 15:51:06 DEBUG ReservedThreadExecutor:311 - ReservedThreadExecutor@6da1c1de{s=1/8,p=0}@168e6309 IDLE 2018-09-04 15:51:06 DEBUG ReservedThreadExecutor:190 - ReservedThreadExecutor@6da1c1de{s=1/8,p=0} tryExecute STOP! 2018-09-04 15:51:06 DEBUG ReservedThreadExecutor:259 - ReservedThreadExecutor@6da1c1de{s=0/8,p=0}@168e6309 offer STOP! 2018-09-04 15:51:06 DEBUG ReservedThreadExecutor:317 - ReservedThreadExecutor@6da1c1de{s=0/8,p=0}@168e6309 task=STOP! 2018-09-04 15:51:06 DEBUG ReservedThreadExecutor:375 - ReservedThreadExecutor@6da1c1de{s=0/8,p=0}@168e6309 Exited 2018-09-04 15:51:06 DEBUG QueuedThreadPool:682 - ran ReservedThreadExecutor@6da1c1de{s=0/8,p=0}@168e6309
{noformat}
 



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)