Hi,
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. Pls suggest if this is
a valid issue/ something specific to my environment.
Envirnoment: MAC , Java 10
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");
}
});
Thanks,
Sowjanya
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
