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

Claus Ibsen commented on CAMEL-14224:
-------------------------------------

And what happens when you use =1

> Camel-Websocket: The sendToAll method in the Producer is really slow
> --------------------------------------------------------------------
>
>                 Key: CAMEL-14224
>                 URL: https://issues.apache.org/jira/browse/CAMEL-14224
>             Project: Camel
>          Issue Type: Bug
>          Components: camel-websocket
>    Affects Versions: 2.24.2
>         Environment: 
>            Reporter: michael elbaz
>            Priority: Major
>
> I don't know what the idea behind but in this class 
> ([Producer|https://github.com/apache/camel/blob/master/components/camel-websocket/src/main/java/org/apache/camel/component/websocket/WebsocketProducer.java])
>  sendToAll method the Thread.sleep in the while loop make all the process 
> crazy slow just try to run this code
> {code:java}
>     @Override
>     public void configure() throws Exception {
>         String uri = 
> "websocket://127.0.0.1:8443/test?sendToAll=true&sendTimeout=0";
>         from(uri).to(uri);
>     }
> {code}
> and send multiple message to the server and you will see how slow is it for 
> my point there is two defect:
> # Give the availability to send to all *expect* the sender
> # Fix the while loop
> During my test to have decent performance i set this parameter `sendTimeout` 
> to 0 but i got this exception then: 
> {code:java}
> org.apache.camel.component.websocket.WebsocketSendException: Failed to 
> deliver message within 0 millis to one or more recipients.. 
> Exchange[ID-DESKTOP-S8PM2C4-1574865248397-0-3]
>       at 
> org.apache.camel.component.websocket.WebsocketProducer.sendToAll(WebsocketProducer.java:149)
>  ~[camel-websocket-2.24.2.jar:2.24.2]
>       at 
> org.apache.camel.component.websocket.WebsocketProducer.process(WebsocketProducer.java:52)
>  ~[camel-websocket-2.24.2.jar:2.24.2]
>       at 
> org.apache.camel.util.AsyncProcessorConverterHelper$ProcessorToAsyncProcessorBridge.process(AsyncProcessorConverterHelper.java:61)
>  ~[camel-core-2.24.2.jar:2.24.2]
>       at 
> org.apache.camel.processor.SendProcessor.process(SendProcessor.java:148) 
> [camel-core-2.24.2.jar:2.24.2]
>       at 
> org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:548)
>  [camel-core-2.24.2.jar:2.24.2]
>       at 
> org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:201)
>  [camel-core-2.24.2.jar:2.24.2]
>       at 
> org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:201)
>  [camel-core-2.24.2.jar:2.24.2]
>       at 
> org.apache.camel.component.direct.DirectProducer.process(DirectProducer.java:76)
>  [camel-core-2.24.2.jar:2.24.2]
>       at 
> org.apache.camel.processor.SendProcessor.process(SendProcessor.java:148) 
> [camel-core-2.24.2.jar:2.24.2]
>       at 
> org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:548)
>  [camel-core-2.24.2.jar:2.24.2]
>       at 
> org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:201)
>  [camel-core-2.24.2.jar:2.24.2]
>       at 
> org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:201)
>  [camel-core-2.24.2.jar:2.24.2]
>       at 
> org.apache.camel.component.websocket.WebsocketConsumer.sendMessage(WebsocketConsumer.java:75)
>  [camel-websocket-2.24.2.jar:2.24.2]
>       at 
> org.apache.camel.component.websocket.WebsocketConsumer.sendMessage(WebsocketConsumer.java:59)
>  [camel-websocket-2.24.2.jar:2.24.2]
>       at 
> org.apache.camel.component.websocket.DefaultWebsocket.onMessage(DefaultWebsocket.java:66)
>  [camel-websocket-2.24.2.jar:2.24.2]
>       at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) 
> ~[na:1.8.0_201]
>       at 
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) 
> ~[na:1.8.0_201]
>       at 
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
>  ~[na:1.8.0_201]
>       at java.lang.reflect.Method.invoke(Method.java:498) ~[na:1.8.0_201]
>       at 
> org.eclipse.jetty.websocket.common.events.annotated.CallableMethod.call(CallableMethod.java:70)
>  [websocket-common-9.4.22.v20191022.jar:9.4.22.v20191022]
>       at 
> org.eclipse.jetty.websocket.common.events.annotated.OptionalSessionCallableMethod.call(OptionalSessionCallableMethod.java:72)
>  [websocket-common-9.4.22.v20191022.jar:9.4.22.v20191022]
>       at 
> org.eclipse.jetty.websocket.common.events.JettyAnnotatedEventDriver.onTextMessage(JettyAnnotatedEventDriver.java:251)
>  [websocket-common-9.4.22.v20191022.jar:9.4.22.v20191022]
>       at 
> org.eclipse.jetty.websocket.common.message.SimpleTextMessage.messageComplete(SimpleTextMessage.java:69)
>  [websocket-common-9.4.22.v20191022.jar:9.4.22.v20191022]
>       at 
> org.eclipse.jetty.websocket.common.events.AbstractEventDriver.appendMessage(AbstractEventDriver.java:65)
>  [websocket-common-9.4.22.v20191022.jar:9.4.22.v20191022]
>       at 
> org.eclipse.jetty.websocket.common.events.JettyAnnotatedEventDriver.onTextFrame(JettyAnnotatedEventDriver.java:243)
>  [websocket-common-9.4.22.v20191022.jar:9.4.22.v20191022]
>       at 
> org.eclipse.jetty.websocket.common.events.AbstractEventDriver.incomingFrame(AbstractEventDriver.java:150)
>  [websocket-common-9.4.22.v20191022.jar:9.4.22.v20191022]
>       at 
> org.eclipse.jetty.websocket.common.WebSocketSession.incomingFrame(WebSocketSession.java:322)
>  [websocket-common-9.4.22.v20191022.jar:9.4.22.v20191022]
>       at 
> org.eclipse.jetty.websocket.common.extensions.AbstractExtension.nextIncomingFrame(AbstractExtension.java:147)
>  [websocket-common-9.4.22.v20191022.jar:9.4.22.v20191022]
>       at 
> org.eclipse.jetty.websocket.common.extensions.compress.PerMessageDeflateExtension.nextIncomingFrame(PerMessageDeflateExtension.java:112)
>  [websocket-common-9.4.22.v20191022.jar:9.4.22.v20191022]
>       at 
> org.eclipse.jetty.websocket.common.extensions.compress.CompressExtension.forwardIncoming(CompressExtension.java:168)
>  [websocket-common-9.4.22.v20191022.jar:9.4.22.v20191022]
>       at 
> org.eclipse.jetty.websocket.common.extensions.compress.PerMessageDeflateExtension.incomingFrame(PerMessageDeflateExtension.java:92)
>  [websocket-common-9.4.22.v20191022.jar:9.4.22.v20191022]
>       at 
> org.eclipse.jetty.websocket.common.extensions.ExtensionStack.incomingFrame(ExtensionStack.java:202)
>  [websocket-common-9.4.22.v20191022.jar:9.4.22.v20191022]
>       at 
> org.eclipse.jetty.websocket.common.Parser.notifyFrame(Parser.java:225) 
> [websocket-common-9.4.22.v20191022.jar:9.4.22.v20191022]
>       at 
> org.eclipse.jetty.websocket.common.Parser.parseSingleFrame(Parser.java:259) 
> [websocket-common-9.4.22.v20191022.jar:9.4.22.v20191022]
>       at 
> org.eclipse.jetty.websocket.common.io.AbstractWebSocketConnection.onFillable(AbstractWebSocketConnection.java:460)
>  [websocket-common-9.4.22.v20191022.jar:9.4.22.v20191022]
>       at 
> org.eclipse.jetty.websocket.common.io.AbstractWebSocketConnection.onFillable(AbstractWebSocketConnection.java:441)
>  [websocket-common-9.4.22.v20191022.jar:9.4.22.v20191022]
>       at 
> org.eclipse.jetty.io.AbstractConnection$ReadCallback.succeeded(AbstractConnection.java:311)
>  [jetty-io-9.4.22.v20191022.jar:9.4.22.v20191022]
>       at org.eclipse.jetty.io.FillInterest.fillable(FillInterest.java:103) 
> [jetty-io-9.4.22.v20191022.jar:9.4.22.v20191022]
>       at org.eclipse.jetty.io.ChannelEndPoint$2.run(ChannelEndPoint.java:117) 
> [jetty-io-9.4.22.v20191022.jar:9.4.22.v20191022]
>       at 
> org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.runTask(EatWhatYouKill.java:336)
>  [jetty-util-9.4.22.v20191022.jar:9.4.22.v20191022]
>       at 
> org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.doProduce(EatWhatYouKill.java:313)
>  [jetty-util-9.4.22.v20191022.jar:9.4.22.v20191022]
>       at 
> org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.tryProduce(EatWhatYouKill.java:171)
>  [jetty-util-9.4.22.v20191022.jar:9.4.22.v20191022]
>       at 
> org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.run(EatWhatYouKill.java:129)
>  [jetty-util-9.4.22.v20191022.jar:9.4.22.v20191022]
>       at 
> org.eclipse.jetty.util.thread.ReservedThreadExecutor$ReservedThread.run(ReservedThreadExecutor.java:388)
>  [jetty-util-9.4.22.v20191022.jar:9.4.22.v20191022]
>       at 
> org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:806)
>  [jetty-util-9.4.22.v20191022.jar:9.4.22.v20191022]
>       at 
> org.eclipse.jetty.util.thread.QueuedThreadPool$Runner.run(QueuedThreadPool.java:938)
>  [jetty-util-9.4.22.v20191022.jar:9.4.22.v20191022]
>       at java.lang.Thread.run(Thread.java:748) [na:1.8.0_201]
> {code}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to