[GitHub] [camel-quarkus] mswiderski commented on issue #1851: The stream has no active subscriptions when using camel-quarkus-smallrye-reactive-messaging

[GitBox <gi...@apache.org>]

mswiderski commented on issue #1851:
URL: https://github.com/apache/camel-quarkus/issues/1851#issuecomment-699818243


   further investigation shows that following code is not really respected on startup 
   https://github.com/apache/camel-quarkus/blob/1.1.0/extensions/smallrye-reactive-messaging/deployment/src/main/java/org/apache/camel/quarkus/component/smallrye/reactive/messaging/deployment/SmallRyeReactiveMessagingProcessor.java#L73
   
   as the init method is still invoked and actually overrides the reactive instance which makes it to register to publishers but only one subscriber and that's why the exception is thrown as the publisher used is the one without any subscribers.
   
   the only workaround I found is to do a null check on reactive field in Smallrye Reactive Massaging Camel component which made it work.


----------------------------------------------------------------
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.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org