Jasonlhy commented on PR #14778:
URL: https://github.com/apache/camel/pull/14778#issuecomment-2226829418
I am evaluating camel for Salesforce Platform event, I have also noticed the
issue. I tested it on my machine and this pull request seems fixed the issue,
this is the log I got
```
at
org.apache.camel.component.salesforce.internal.streaming.SubscriptionHelper.lambda$createConnectionListener$2(SubscriptionHelper.java:162)
at
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
at
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
at java.base/java.lang.Thread.run(Thread.java:840)
[ead #29 - SalesforceHttpClient] SubscriptionHelper WARN
Connect failure: {failure={exception=java.net.UnknownHostException:
<mycompanY>.sandbox.my.salesforce.com: nodename nor servname provided, or not
known, message={clientId=arjyrbbfdpyy7ry124ktuvyos91u, advice={timeout=0},
channel=/meta/connect, id=18, connectionType=long-polling},
connectionType=long-polling}, channel=/meta/connect, id=18, successful=false}
Exception in thread "Camel (camel-1) thread #29 - SalesforceHttpClient"
java.lang.IllegalStateException: Invalid state UNCONNECTED
at org.cometd.client.BayeuxClient.handshake(BayeuxClient.java:310)
at
org.cometd.bayeux.client.ClientSession.handshake(ClientSession.java:68)
at
org.cometd.bayeux.client.ClientSession.handshake(ClientSession.java:59)
at
org.apache.camel.component.salesforce.internal.streaming.SubscriptionHelper.lambda$createConnectionListener$2(SubscriptionHelper.java:162)
at
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
at
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
at java.base/java.lang.Thread.run(Thread.java:840)
[ead #31 - SalesforceHttpClient] SubscriptionHelper WARN
Connect failure: {failure={exception=java.net.UnknownHostException:
<mycompanY>.sandbox.my.salesforce.com: nodename nor servname provided, or not
known, message={clientId=arjyrbbfdpyy7ry124ktuvyos91u, advice={timeout=0},
channel=/meta/connect, id=19, connectionType=long-polling},
connectionType=long-polling}, channel=/meta/connect, id=19, successful=false}
Exception in thread "Camel (camel-1) thread #31 - SalesforceHttpClient"
java.lang.IllegalStateException: Invalid state UNCONNECTED
at org.cometd.client.BayeuxClient.handshake(BayeuxClient.java:310)
at
org.cometd.bayeux.client.ClientSession.handshake(ClientSession.java:68)
at
org.cometd.bayeux.client.ClientSession.handshake(ClientSession.java:59)
at
org.apache.camel.component.salesforce.internal.streaming.SubscriptionHelper.lambda$createConnectionListener$2(SubscriptionHelper.java:162)
at
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
at
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
at java.base/java.lang.Thread.run(Thread.java:840)
[ead #33 - SalesforceHttpClient] SubscriptionHelper WARN
Connect failure: {failure={exception=java.net.UnknownHostException:
<mycompanY>.sandbox.my.salesforce.com: nodename nor servname provided, or not
known, message={clientId=arjyrbbfdpyy7ry124ktuvyos91u, advice={timeout=0},
channel=/meta/connect, id=20, connectionType=long-polling},
connectionType=long-polling}, channel=/meta/connect, id=20, successful=false}
Exception in thread "Camel (camel-1) thread #33 - SalesforceHttpClient"
java.lang.IllegalStateException: Invalid state UNCONNECTED
at org.cometd.client.BayeuxClient.handshake(BayeuxClient.java:310)
at
org.cometd.bayeux.client.ClientSession.handshake(ClientSession.java:68)
at
org.cometd.bayeux.client.ClientSession.handshake(ClientSession.java:59)
at
org.apache.camel.component.salesforce.internal.streaming.SubscriptionHelper.lambda$createConnectionListener$2(SubscriptionHelper.java:162)
at
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
at
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
at java.base/java.lang.Thread.run(Thread.java:840)
[ead #35 - SalesforceHttpClient] SubscriptionHelper WARN
Connect failure: {advice={reconnect=handshake, interval=0},
channel=/meta/connect, id=21, error=403::Unknown client, successful=false}
[ead #36 - SalesforceHttpClient] SubscriptionHelper INFO
Handshake successful. Channels to subscribe: [/event/PointHistoryEvent__e,
/event/AccountEvent__e]
[ead #37 - SalesforceHttpClient] SubscriptionHelper INFO
Subscribing to channels: [/event/PointHistoryEvent__e, /event/AccountEvent__e]
[ead #37 - SalesforceHttpClient] SubscriptionHelper INFO
Subscribing to channel /event/PointHistoryEvent__e...
[ead #37 - SalesforceHttpClient] SubscriptionHelper INFO
Subscribing to channel /event/AccountEvent__e...
[lesforceHttpClient@6ad5923a-29] ResponseListeners INFO
Exception while notifying listener
org.cometd.client.http.jetty.JettyHttpClientTransport$ResponseListener@4e9c40a3
java.util.ConcurrentModificationException: null
at
java.base/java.util.ArrayList$Itr.checkForComodification(ArrayList.java:1013)
~[?:?]
at java.base/java.util.ArrayList$Itr.next(ArrayList.java:967) ~[?:?]
at
java.base/java.util.Collections$UnmodifiableCollection$1.next(Collections.java:1054)
~[?:?]
at
org.apache.camel.component.salesforce.internal.streaming.SubscriptionHelper$1.storeCookies(SubscriptionHelper.java:392)
~[camel-salesforce-4.7.0-SNAPSHOT.jar:4.7.0-SNAPSHOT]
at
org.cometd.client.http.jetty.JettyHttpClientTransport.access$000(JettyHttpClientTransport.java:52)
~[cometd-java-client-http-jetty-8.0.2.jar:8.0.2]
at
org.cometd.client.http.jetty.JettyHttpClientTransport$ResponseListener.onHeader(JettyHttpClientTransport.java:239)
~[cometd-java-client-http-jetty-8.0.2.jar:8.0.2]
at
org.eclipse.jetty.client.transport.ResponseListeners.notifyHeader(ResponseListeners.java:130)
~[jetty-client-12.0.10.jar:12.0.10]
at
org.eclipse.jetty.client.transport.ResponseListeners.notifyHeader(ResponseListeners.java:122)
~[jetty-client-12.0.10.jar:12.0.10]
at
org.eclipse.jetty.client.transport.HttpReceiver.lambda$responseHeader$1(HttpReceiver.java:203)
~[jetty-client-12.0.10.jar:12.0.10]
at
org.eclipse.jetty.util.thread.SerializedInvoker$Link.run(SerializedInvoker.java:191)
[jetty-util-12.0.10.jar:12.0.10]
at
org.eclipse.jetty.util.thread.SerializedInvoker.run(SerializedInvoker.java:117)
[jetty-util-12.0.10.jar:12.0.10]
at
org.eclipse.jetty.client.transport.HttpReceiver.responseHeader(HttpReceiver.java:191)
[jetty-client-12.0.10.jar:12.0.10]
at
org.eclipse.jetty.client.transport.internal.HttpReceiverOverHTTP.parsedHeader(HttpReceiverOverHTTP.java:419)
[jetty-client-12.0.10.jar:12.0.10]
at org.eclipse.jetty.http.HttpParser.parsedHeader(HttpParser.java:1203)
[jetty-http-12.0.10.jar:12.0.10]
at org.eclipse.jetty.http.HttpParser.parseFields(HttpParser.java:1362)
[jetty-http-12.0.10.jar:12.0.10]
at org.eclipse.jetty.http.HttpParser.parseNext(HttpParser.java:1641)
[jetty-http-12.0.10.jar:12.0.10]
at
org.eclipse.jetty.client.transport.internal.HttpReceiverOverHTTP.parse(HttpReceiverOverHTTP.java:312)
[jetty-client-12.0.10.jar:12.0.10]
at
org.eclipse.jetty.client.transport.internal.HttpReceiverOverHTTP.parseAndFill(HttpReceiverOverHTTP.java:250)
[jetty-client-12.0.10.jar:12.0.10]
at
org.eclipse.jetty.client.transport.internal.HttpReceiverOverHTTP.receive(HttpReceiverOverHTTP.java:76)
[jetty-client-12.0.10.jar:12.0.10]
at
org.eclipse.jetty.client.transport.internal.HttpChannelOverHTTP.receive(HttpChannelOverHTTP.java:97)
[jetty-client-12.0.10.jar:12.0.10]
at
org.eclipse.jetty.client.transport.internal.HttpConnectionOverHTTP.onFillable(HttpConnectionOverHTTP.java:207)
[jetty-client-12.0.10.jar:12.0.10]
at
org.eclipse.jetty.io.AbstractConnection$ReadCallback.succeeded(AbstractConnection.java:322)
[jetty-io-12.0.10.jar:12.0.10]
at org.eclipse.jetty.io.FillInterest.fillable(FillInterest.java:99)
[jetty-io-12.0.10.jar:12.0.10]
at
org.eclipse.jetty.io.ssl.SslConnection$SslEndPoint.onFillable(SslConnection.java:574)
[jetty-io-12.0.10.jar:12.0.10]
at
org.eclipse.jetty.io.ssl.SslConnection.onFillable(SslConnection.java:390)
[jetty-io-12.0.10.jar:12.0.10]
at
org.eclipse.jetty.io.ssl.SslConnection$2.succeeded(SslConnection.java:150)
[jetty-io-12.0.10.jar:12.0.10]
at org.eclipse.jetty.io.FillInterest.fillable(FillInterest.java:99)
[jetty-io-12.0.10.jar:12.0.10]
at
org.eclipse.jetty.io.SelectableChannelEndPoint$1.run(SelectableChannelEndPoint.java:53)
[jetty-io-12.0.10.jar:12.0.10]
at
org.eclipse.jetty.util.thread.strategy.AdaptiveExecutionStrategy.runTask(AdaptiveExecutionStrategy.java:478)
[jetty-util-12.0.10.jar:12.0.10]
at
org.eclipse.jetty.util.thread.strategy.AdaptiveExecutionStrategy.consumeTask(AdaptiveExecutionStrategy.java:441)
[jetty-util-12.0.10.jar:12.0.10]
at
org.eclipse.jetty.util.thread.strategy.AdaptiveExecutionStrategy.tryProduce(AdaptiveExecutionStrategy.java:293)
[jetty-util-12.0.10.jar:12.0.10]
at
org.eclipse.jetty.util.thread.strategy.AdaptiveExecutionStrategy.run(AdaptiveExecutionStrategy.java:201)
[jetty-util-12.0.10.jar:12.0.10]
at
org.eclipse.jetty.util.thread.ReservedThreadExecutor$ReservedThread.run(ReservedThreadExecutor.java:311)
[jetty-util-12.0.10.jar:12.0.10]
at
org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:979)
[jetty-util-12.0.10.jar:12.0.10]
at
org.eclipse.jetty.util.thread.QueuedThreadPool$Runner.doRunJob(QueuedThreadPool.java:1209)
[jetty-util-12.0.10.jar:12.0.10]
at
org.eclipse.jetty.util.thread.QueuedThreadPool$Runner.run(QueuedThreadPool.java:1164)
[jetty-util-12.0.10.jar:12.0.10]
at java.base/java.lang.Thread.run(Thread.java:840) [?:?]
[ead #38 - SalesforceHttpClient] SubscriptionHelper INFO
Subscribed to channel /event/PointHistoryEvent__e
[ead #39 - SalesforceHttpClient] SubscriptionHelper INFO
Subscribed to channel /event/AccountEvent__e
[lesforceHttpClient@6ad5923a-32] route2 INFO
Received Platform Event: PlatformEvent: createdById: 0050p000004qnldAAA,
createdId: 2024-07-13T08:53:00.408Z, data:
{Data__c=ChineseLastName__c:mulesofttest -> Test camel,
ID__c=001H100001PGZAGIA5}
json:
{"created":1720860780.408000000,"createdById":"0050p000004qnldAAA","eventData":{"Data__c":"ChineseLastName__c:mulesofttest
-> Test camel","ID__c":"001H100001PGZAGIA5"}}
[lesforceHttpClient@6ad5923a-32] ReactorConnectionCache INFO
{"az.sdk.message":"The connection is closed, requesting a new
connection.","entityPath":"N/A","connectionId":"MF_b31637_1720860344474"}
[lesforceHttpClient@6ad5923a-32] ReactorConnectionCache INFO
{"az.sdk.message":"Waiting to connect and become
active.","entityPath":"N/A","connectionId":"MF_959b2e_1720860804288"}
[lesforceHttpClient@6ad5923a-32] ReactorConnection INFO
{"az.sdk.message":"Creating and starting
connection.","connectionId":"MF_959b2e_1720860804288","hostName":"jsonservicebus.servicebus.windows.net","port":5671}
[lesforceHttpClient@6ad5923a-32] ReactorExecutor INFO
{"az.sdk.message":"Starting reactor.","connectionId":"MF_959b2e_1720860804288"}
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
