You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@camel.apache.org by "Nicolas Filotto (Jira)" <ji...@apache.org> on 2023/06/27 15:41:00 UTC
[jira] [Updated] (CAMEL-19510) camel-spring-boot-examples - Fix the reactive-streams
[ https://issues.apache.org/jira/browse/CAMEL-19510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Nicolas Filotto updated CAMEL-19510:
------------------------------------
Affects Version/s: 4.0-M3
3.20.6
> camel-spring-boot-examples - Fix the reactive-streams
> -----------------------------------------------------
>
> Key: CAMEL-19510
> URL: https://issues.apache.org/jira/browse/CAMEL-19510
> Project: Camel
> Issue Type: Task
> Affects Versions: 3.20.6, 4.0-M3
> Reporter: Nicolas Filotto
> Assignee: Nicolas Filotto
> Priority: Minor
>
> While playing with the example {{reactive-streams}} of {{camel-spring-boot-examples}}, I realized that:
> With Camel 3.21 the rest endpoint defined in {{RestExample}} fails with the next error:
> {noformat}
> java.lang.ClassCastException: class java.lang.String cannot be cast to class java.lang.Long (java.lang.String and java.lang.Long are in module java.base of loader 'bootstrap')
> at org.apache.camel.example.reactive.streams.RestExample$RestExampleStreams.lambda$sum$0(RestExample.java:52) ~[classes/:na]
> at reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:100) ~[reactor-core-3.2.16.RELEASE.jar:3.2.16.RELEASE]
> at reactor.core.publisher.FluxZip$ZipCoordinator.drain(FluxZip.java:735) ~[reactor-core-3.2.16.RELEASE.jar:3.2.16.RELEASE]
> at reactor.core.publisher.FluxZip$ZipInner.onNext(FluxZip.java:894) ~[reactor-core-3.2.16.RELEASE.jar:3.2.16.RELEASE]
> at org.apache.camel.component.reactive.streams.util.MonoPublisher$1.request(MonoPublisher.java:54) ~[camel-reactive-streams-3.21.0-SNAPSHOT.jar:3.21.0-SNAPSHOT]
> at reactor.core.publisher.FluxZip$ZipInner.onSubscribe(FluxZip.java:881) ~[reactor-core-3.2.16.RELEASE.jar:3.2.16.RELEASE]
> at org.apache.camel.component.reactive.streams.util.MonoPublisher.subscribe(MonoPublisher.java:39) ~[camel-reactive-streams-3.21.0-SNAPSHOT.jar:3.21.0-SNAPSHOT]
> at reactor.core.publisher.FluxZip$ZipCoordinator.subscribe(FluxZip.java:579) ~[reactor-core-3.2.16.RELEASE.jar:3.2.16.RELEASE]
> at reactor.core.publisher.FluxZip.handleBoth(FluxZip.java:326) ~[reactor-core-3.2.16.RELEASE.jar:3.2.16.RELEASE]
> at reactor.core.publisher.FluxZip.handleArrayMode(FluxZip.java:267) ~[reactor-core-3.2.16.RELEASE.jar:3.2.16.RELEASE]
> at reactor.core.publisher.FluxZip.subscribe(FluxZip.java:136) ~[reactor-core-3.2.16.RELEASE.jar:3.2.16.RELEASE]
> at reactor.core.publisher.FluxMap.subscribe(FluxMap.java:62) ~[reactor-core-3.2.16.RELEASE.jar:3.2.16.RELEASE]
> at reactor.core.publisher.Flux.subscribe(Flux.java:7968) ~[reactor-core-3.2.16.RELEASE.jar:3.2.16.RELEASE]
> at org.apache.camel.component.reactive.streams.util.UnwrapStreamProcessor.process(UnwrapStreamProcessor.java:42) ~[camel-reactive-streams-3.21.0-SNAPSHOT.jar:3.21.0-SNAPSHOT]
> at org.apache.camel.processor.errorhandler.RedeliveryErrorHandler$SimpleTask.run(RedeliveryErrorHandler.java:477) ~[camel-core-processor-3.21.0-SNAPSHOT.jar:3.21.0-SNAPSHOT]
> at org.apache.camel.impl.engine.DefaultReactiveExecutor$Worker.schedule(DefaultReactiveExecutor.java:181) ~[camel-base-engine-3.21.0-SNAPSHOT.jar:3.21.0-SNAPSHOT]
> at org.apache.camel.impl.engine.DefaultReactiveExecutor.scheduleMain(DefaultReactiveExecutor.java:59) ~[camel-base-engine-3.21.0-SNAPSHOT.jar:3.21.0-SNAPSHOT]
> at org.apache.camel.processor.Pipeline.process(Pipeline.java:165) ~[camel-core-processor-3.21.0-SNAPSHOT.jar:3.21.0-SNAPSHOT]
> at org.apache.camel.impl.engine.CamelInternalProcessor.process(CamelInternalProcessor.java:392) ~[camel-base-engine-3.21.0-SNAPSHOT.jar:3.21.0-SNAPSHOT]
> at org.apache.camel.impl.engine.DefaultAsyncProcessorAwaitManager.process(DefaultAsyncProcessorAwaitManager.java:83) ~[camel-base-engine-3.21.0-SNAPSHOT.jar:3.21.0-SNAPSHOT]
> at org.apache.camel.support.AsyncProcessorSupport.process(AsyncProcessorSupport.java:41) ~[camel-support-3.21.0-SNAPSHOT.jar:3.21.0-SNAPSHOT]
> at org.apache.camel.http.common.CamelServlet.doExecute(CamelServlet.java:333) ~[camel-http-common-3.21.0-SNAPSHOT.jar:3.21.0-SNAPSHOT]
> at org.apache.camel.http.common.CamelServlet.doService(CamelServlet.java:228) ~[camel-http-common-3.21.0-SNAPSHOT.jar:3.21.0-SNAPSHOT]
> at org.apache.camel.http.common.CamelServlet.handleService(CamelServlet.java:146) ~[camel-http-common-3.21.0-SNAPSHOT.jar:3.21.0-SNAPSHOT]
> at org.apache.camel.http.common.CamelServlet.service(CamelServlet.java:95) ~[camel-http-common-3.21.0-SNAPSHOT.jar:3.21.0-SNAPSHOT]
> at javax.servlet.http.HttpServlet.service(HttpServlet.java:779) ~[tomcat-embed-core-9.0.70.jar:4.0.FR]
> {noformat}
> With Camel 4, it is even worse because no route starts:
> {code:java}
> 2023-06-27T15:53:02.430+02:00 INFO 40276 --- [ main] a.c.e.r.s.a.ReactiveStreamsSpringBootApp : No active profile set, falling back to 1 default profile: "default"
> 2023-06-27T15:53:04.194+02:00 INFO 40276 --- [ main] o.s.b.w.embedded.tomcat.TomcatWebServer : Tomcat initialized with port(s): 8080 (http)
> 2023-06-27T15:53:04.204+02:00 INFO 40276 --- [ main] o.apache.catalina.core.StandardService : Starting service [Tomcat]
> 2023-06-27T15:53:04.204+02:00 INFO 40276 --- [ main] o.apache.catalina.core.StandardEngine : Starting Servlet engine: [Apache Tomcat/10.1.10]
> 2023-06-27T15:53:04.318+02:00 INFO 40276 --- [ main] o.a.c.c.C.[Tomcat].[localhost].[/] : Initializing Spring embedded WebApplicationContext
> 2023-06-27T15:53:04.319+02:00 INFO 40276 --- [ main] w.s.c.ServletWebServerApplicationContext : Root WebApplicationContext: initialization completed in 1773 ms
> 2023-06-27T15:53:05.406+02:00 INFO 40276 --- [ main] o.s.b.a.e.web.EndpointLinksResolver : Exposing 1 endpoint(s) beneath base path '/actuator'
> 2023-06-27T15:53:05.528+02:00 INFO 40276 --- [ main] o.a.c.c.s.CamelHttpTransportServlet : Initialized CamelHttpTransportServlet[name=CamelServlet, contextPath=]
> 2023-06-27T15:53:05.530+02:00 INFO 40276 --- [ main] o.s.b.w.embedded.tomcat.TomcatWebServer : Tomcat started on port(s): 8080 (http) with context path ''
> 2023-06-27T15:53:05.616+02:00 INFO 40276 --- [ main] o.a.c.impl.engine.AbstractCamelContext : Apache Camel 4.0.0-SNAPSHOT (camel-1) is starting
> 2023-06-27T15:53:05.622+02:00 INFO 40276 --- [ main] o.a.c.impl.engine.AbstractCamelContext : Routes startup (started:0)
> 2023-06-27T15:53:05.623+02:00 INFO 40276 --- [ main] o.a.c.impl.engine.AbstractCamelContext : Apache Camel 4.0.0-SNAPSHOT (camel-1) started in 6ms (build:0ms init:0ms start:6ms)
> {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)