[jira] [Resolved] (CAMEL-11615) WorkerPool is null in DefaultCamelReactiveStreamsService

["Claus Ibsen (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/CAMEL-11615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Claus Ibsen resolved CAMEL-11615.
---------------------------------
    Resolution: Fixed
      Assignee: Claus Ibsen

Yeah the component has been improved from 2.20 onwards so it works better there. 

The best solution is to create the thread pool in the constructor which is now what we do.

> WorkerPool is null in DefaultCamelReactiveStreamsService
> --------------------------------------------------------
>
>                 Key: CAMEL-11615
>                 URL: https://issues.apache.org/jira/browse/CAMEL-11615
>             Project: Camel
>          Issue Type: Bug
>          Components: camel-reactive-streams
>    Affects Versions: 2.19.1
>         Environment: OS: OSX 10.11.6
> JDK: Oracle 1.8.0_141
> MVN: 3.5.0
>            Reporter: Qaiser Abbasi
>            Assignee: Claus Ibsen
>             Fix For: 2.20.0, 2.19.3
>
>
> In https://github.com/qabbasi/reactive-camel-demo I'm using the camel-reactive-streams-starter project to create a application based on RxJava2. Currently I'm getting a NPE during runtime.
> I also tried to test the sample route inside https://github.com/apache/camel/tree/master/examples/camel-example-reactive-streams, but unfortunately this also results in the same exception:
> java.lang.NullPointerException: null
>         at org.apache.camel.component.reactive.streams.engine.CamelSubscription.checkAndFlush(CamelSubscription.java:123) ~[camel-reactive-streams-2.19.1.jar:2.19.1]
>         at org.apache.camel.component.reactive.streams.engine.CamelSubscription.publish(CamelSubscription.java:247) ~[camel-reactive-streams-2.19.1.jar:2.19.1]
>         at org.apache.camel.component.reactive.streams.engine.CamelPublisher.publish(CamelPublisher.java:100) ~[camel-reactive-streams-2.19.1.jar:2.19.1]
>         at org.apache.camel.component.reactive.streams.engine.DefaultCamelReactiveStreamsService.sendCamelExchange(DefaultCamelReactiveStreamsService.java:123) ~[camel-reactive-streams-2.19.1.jar:2.19.1]
>         at org.apache.camel.component.reactive.streams.ReactiveStreamsProducer.process(ReactiveStreamsProducer.java:44) ~[camel-reactive-streams-2.19.1.jar:2.19.1]
>         at org.apache.camel.processor.SendProcessor.process(SendProcessor.java:145) ~[camel-core-2.19.1.jar:2.19.1]
>         at org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:77) ~[camel-core-2.19.1.jar:2.19.1]
>         at org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:541) ~[camel-core-2.19.1.jar:2.19.1]
>         at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:198) [camel-core-2.19.1.jar:2.19.1]
>         at org.apache.camel.processor.Pipeline.process(Pipeline.java:120) ~[camel-core-2.19.1.jar:2.19.1]
>         at org.apache.camel.processor.Pipeline.process(Pipeline.java:83) ~[camel-core-2.19.1.jar:2.19.1]
>         at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:198) [camel-core-2.19.1.jar:2.19.1]
>         at org.apache.camel.component.timer.TimerConsumer.sendTimerExchange(TimerConsumer.java:197) [camel-core-2.19.1.jar:2.19.1]
>         at org.apache.camel.component.timer.TimerConsumer$1.run(TimerConsumer.java:79) [camel-core-2.19.1.jar:2.19.1]
>         at java.util.TimerThread.mainLoop(Timer.java:555) [na:1.8.0_141]
>         at java.util.TimerThread.run(Timer.java:505) [na:1.8.0_141]



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)