camel-salesforce: подписка на события платформы довольно часто дает сбой (2.23.0-SNAPSHOT) - PullRequest
Новая
       10

camel-salesforce: подписка на события платформы довольно часто дает сбой (2.23.0-SNAPSHOT)

0 голосов
/ 11 сентября 2018

У меня есть простой маршрут, чтобы подписаться на событие платформы Salesforce и отправить в очередь AWS-SQS. Этот маршрут иногда работает, но в большинстве случаев не работает с исключениями другого типа («org.cometd.common.TransportException: null» / «java.lang.IllegalThreadStateException»).
Похоже, что соединение salesforce прерывается случайным образом и не может повторно подключиться. Это не очень красиво часто, что я не могу использовать эту функцию. Просьба предложить, если это действительная проблема / что-то специфическое для моей среды.

Окружающая среда: MAC, Java 10 Версия Camel-Salesforce 2.23.0-SNAPSHOT. 

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"); 

} 
});

Ниже приведен журнал для org.cometd.common.TransportException Журнал: https://drive.google.com/file/d/13Kcu1dZHRXn_H2ghMNcdldDVQFBpSDgh/view?usp=sharing

Ниже приведен журнал для исключения java.lang.IllegalThreadStateException. Журнал: [https://drive.google.com/file/d/1jXBQ0xCTfhqQHbMPD4CHhd3RTipW4Mhv/view?usp=sharing][1]

Спасибо, Совжаня

...