Hi Cameleers,
this has been targeted for releases 3.7.1 and 3.8.0, if you can, it
would be of great help to test this before we release.
zoran
On Wed, Dec 16, 2020 at 3:44 PM Zoran Regvart <zo...@regvart.com> wrote:
>
> Hi Cameleers,
> I've created a PR[1], which I think fixes the problem, I encourage
> folk to provide feedback and test on your end if possible.
>
> I've tested with the `SubscriptionHelperIntegrationTest`. And manually by:
>
> 1/ Starting a streaming app with the route:
>
> from("salesforce:Account?sObjectName=Account&rawPayload=true&sObjectQuery=SELECT
> Id, Name FROM Account")¬
> .log(LoggingLevel.INFO, "salesforce", "${body}")
>
> 2/ creating an Account record, and noticing the output in the
> log/console from the `log` component
>
> 3/ rejecting traffic to Salesforce using iptables:
> $ iptables -A OUTPUT -d 85.222.0.0/16 -j REJECT
>
> 4/ disrupting the established connection using ss:
> $ ss -K dst 85.222.154.145 # or whatever IP was in the output of lsof
> -p $PID -a -i 6 -n
>
> 5/ noticing the messages in the log with back-off like:
>
> Connect failure: {failure={exception=java.io.EOFException:
> HttpConnectionOverHTTP@45d7880c::DecryptedEndPoint@621bd87d{l=/192.168.1.76:43432,r=eu18.salesforce.com/85.222.155.145:443...
> Restarting on unexpected disconnect from Salesforce...
> Handshake failure: {failure={exception=java.net.ConnectException:
> Connection refused, message={...
> Handshake failure: {failure={exception=java.net.ConnectException:
> Connection refused, message={...
>
> 5/ allowing traffic to Salesforce (removing the rule):
> $ iptables -D OUTPUT 4 # happens to be 4th rule that I've added in 3/,
> check with iptables -L OUTPUT --line-numbers
>
> 6/ seeing consumer reconnecting:
>
> Set Replay extension to replay from `-1` for channel `/topic/Account`
> Subscribing to channel /topic/Account...
> Successfully restarted!
> Subscribed to channel /topic/Account
>
> 7/ creating a new Account record, and seeing the message logged from
> the `log` component.
>
> zoran
>
> [1] https://github.com/apache/camel/pull/4778
>
> --
> Zoran Regvart
--
Zoran Regvart
