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

["Andrea Cosentino (JIRA)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/CAMEL-12776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16603903#comment-16603903 ] 

Andrea Cosentino commented on CAMEL-12776:
------------------------------------------

Please use users mailing list first

> 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: Linux
>            Reporter: sowjanya mudimala
>            Priority: Major
>         Attachments: camel-salesforce-debug-logs.txt
>
>
> 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}
>  



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