Uploaded image for project: 'Red Hat Fuse'
  1. Red Hat Fuse
  2. ENTESB-10928

Camel-paho in Spring Boot 2 against AMQ 7.3 throws Connection lost (32109) - java.io.EOFException

    XMLWordPrintable

Details

    • Bug
    • Resolution: Won't Do
    • Blocker
    • None
    • fuse-7.4-GA
    • Camel
    • % %
    • Hide

      1. Run preconfigured AMQ-7.3 by following docker command.:

      docker run -it -p 8162:8161 -p 61617:61616 -e AMQ_USER=admin -e AMQ_PASSWORD=admin123. -e AMQ_ROLE=admin -e AMQ_NAME=broker -e AMQ_TRANSPORTS='openwire,amqp,stomp,mqtt,hornetq' -e AMQ_REQUIRE_LOGIN=true registry.access.redhat.com/amq-broker-7/amq-broker-72-openshift:1.3-4
      

      2. Unzip attached reproducer
      3. mvn clean install
      4. Run the application with mvn spring-boot:run and see the error

      Show
      1. Run preconfigured AMQ-7.3 by following docker command.: docker run -it -p 8162:8161 -p 61617:61616 -e AMQ_USER=admin -e AMQ_PASSWORD=admin123. -e AMQ_ROLE=admin -e AMQ_NAME=broker -e AMQ_TRANSPORTS= 'openwire,amqp,stomp,mqtt,hornetq' -e AMQ_REQUIRE_LOGIN= true registry.access.redhat.com/amq-broker-7/amq-broker-72-openshift:1.3-4 2. Unzip attached reproducer 3. mvn clean install 4. Run the application with mvn spring-boot:run and see the error
    • Fuse 7.5 Sprint 53 - Blockers

    Description

      Camel-paho doesn't work against AMQ 7.3 in Spring Boot 2. The same scenario works with Spring Boot 1. That means it might be a regression.

        .   ____          _            __ _ _
       /\\ / ___'_ __ _ _(_)_ __  __ _ \ \ \ \
      ( ( )\___ | '_ | '_| | '_ \/ _` | \ \ \ \
       \\/  ___)| |_)| | | | | || (_| |  ) ) ) )
        '  |____| .__|_| |_|_| |_\__, | / / / /
       =========|_|==============|___/=/_/_/_/
       :: Spring Boot ::        (v2.1.3.RELEASE)
      
      16:20:25.474 [main] INFO  i.f.q.camel.amq.Application - Starting Application on vkasala-OSX with PID 72463 (/Users/vkasala/Work/Repositories/spring-boot-camel-amq/target/classes started by vkasala in /Users/vkasala/Work/Repositories/spring-boot-camel-amq)
      16:20:25.476 [main] INFO  i.f.q.camel.amq.Application - No active profile set, falling back to default profiles: default
      16:20:27.381 [main] INFO  o.s.c.s.PostProcessorRegistrationDelegate$BeanPostProcessorChecker - Bean 'org.apache.camel.spring.boot.CamelAutoConfiguration' of type [org.apache.camel.spring.boot.CamelAutoConfiguration$$EnhancerBySpringCGLIB$$84d2b06] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
      16:20:27.554 [main] INFO  org.xnio - XNIO version 3.3.8.Final
      16:20:27.565 [main] INFO  org.xnio.nio - XNIO NIO Implementation Version 3.3.8.Final
      16:20:27.636 [main] WARN  io.undertow.websockets.jsr - UT026009: XNIO worker was not set on WebSocketDeploymentInfo, the default worker will be used
      16:20:27.636 [main] WARN  io.undertow.websockets.jsr - UT026010: Buffer pool was not set on WebSocketDeploymentInfo, the default pool will be used
      16:20:27.657 [main] INFO  io.undertow.servlet - Initializing Spring embedded WebApplicationContext
      16:20:27.657 [main] INFO  o.s.web.context.ContextLoader - Root WebApplicationContext: initialization completed in 2140 ms
      16:20:27.969 [main] INFO  o.a.c.i.c.DefaultTypeConverter - Type converters loaded (core: 195, classpath: 1)
      16:20:28.357 [main] INFO  o.s.s.c.ThreadPoolTaskExecutor - Initializing ExecutorService 'applicationTaskExecutor'
      16:20:28.983 [main] INFO  o.s.b.a.e.web.EndpointLinksResolver - Exposing 2 endpoint(s) beneath base path '/actuator'
      16:20:29.109 [main] INFO  o.a.c.spring.boot.RoutesCollector - Loading additional Camel XML routes from: classpath:camel/*.xml
      16:20:29.110 [main] INFO  o.a.c.spring.boot.RoutesCollector - Loading additional Camel XML rests from: classpath:camel-rest/*.xml
      16:20:29.123 [main] INFO  o.a.camel.spring.SpringCamelContext - Apache Camel 2.23.2.fuse-740004-redhat-00001 (CamelContext: CamelAMQ) is starting
      16:20:29.124 [main] INFO  o.a.c.m.ManagedManagementStrategy - JMX is enabled
      16:20:29.301 [main] INFO  o.a.camel.spring.SpringCamelContext - StreamCaching is not in use. If using streams then its recommended to enable stream caching. See more details at http://camel.apache.org/stream-caching.html
      16:20:29.391 [main] INFO  o.a.camel.spring.SpringCamelContext - Apache Camel 2.23.2.fuse-740004-redhat-00001 (CamelContext: CamelAMQ) is shutting down
      16:20:29.400 [main] INFO  o.a.camel.spring.SpringCamelContext - Apache Camel 2.23.2.fuse-740004-redhat-00001 (CamelContext: CamelAMQ) uptime 0.276 seconds
      16:20:29.400 [main] INFO  o.a.camel.spring.SpringCamelContext - Apache Camel 2.23.2.fuse-740004-redhat-00001 (CamelContext: CamelAMQ) is shutdown in 0.009 seconds
      16:20:29.417 [main] INFO  o.s.b.a.l.ConditionEvaluationReportLoggingListener - 
      
      Error starting ApplicationContext. To display the conditions report re-run your application with 'debug' enabled.
      16:20:29.420 [main] ERROR o.s.boot.SpringApplication - Application run failed
      org.apache.camel.RuntimeCamelException: org.apache.camel.FailedToCreateRouteException: Failed to create route producer: Route(producer)[[From[timer:order?period=3000]] -> [Transfor... because of Connection lost
              at org.apache.camel.util.ObjectHelper.wrapRuntimeCamelException(ObjectHelper.java:1826)
              at org.apache.camel.spring.SpringCamelContext.start(SpringCamelContext.java:136)
              at org.apache.camel.spring.CamelContextFactoryBean.start(CamelContextFactoryBean.java:370)
              at org.apache.camel.spring.CamelContextFactoryBean.onApplicationEvent(CamelContextFactoryBean.java:417)
              at org.apache.camel.spring.CamelContextFactoryBean.onApplicationEvent(CamelContextFactoryBean.java:95)
              at org.springframework.context.event.SimpleApplicationEventMulticaster.doInvokeListener(SimpleApplicationEventMulticaster.java:172)
              at org.springframework.context.event.SimpleApplicationEventMulticaster.invokeListener(SimpleApplicationEventMulticaster.java:165)
              at org.springframework.context.event.SimpleApplicationEventMulticaster.multicastEvent(SimpleApplicationEventMulticaster.java:139)
              at org.springframework.context.support.AbstractApplicationContext.publishEvent(AbstractApplicationContext.java:402)
              at org.springframework.context.support.AbstractApplicationContext.publishEvent(AbstractApplicationContext.java:359)
              at org.springframework.context.support.AbstractApplicationContext.finishRefresh(AbstractApplicationContext.java:896)
              at org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.finishRefresh(ServletWebServerApplicationContext.java:163)
              at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:552)
              at org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.refresh(ServletWebServerApplicationContext.java:142)
              at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:775)
              at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:397)
              at org.springframework.boot.SpringApplication.run(SpringApplication.java:316)
              at org.springframework.boot.SpringApplication.run(SpringApplication.java:1260)
              at org.springframework.boot.SpringApplication.run(SpringApplication.java:1248)
              at io.fabric8.quickstarts.camel.amq.Application.main(Application.java:31)
              at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
              at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
              at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
              at java.lang.reflect.Method.invoke(Method.java:498)
              at org.springframework.boot.maven.AbstractRunMojo$LaunchRunner.run(AbstractRunMojo.java:558)
              at java.lang.Thread.run(Thread.java:748)
      Caused by: org.apache.camel.FailedToCreateRouteException: Failed to create route producer: Route(producer)[[From[timer:order?period=3000]] -> [Transfor... because of Connection lost
              at org.apache.camel.impl.RouteService.warmUp(RouteService.java:147)
              at org.apache.camel.impl.DefaultCamelContext.doWarmUpRoutes(DefaultCamelContext.java:3953)
              at org.apache.camel.impl.DefaultCamelContext.safelyStartRouteServices(DefaultCamelContext.java:3860)
              at org.apache.camel.impl.DefaultCamelContext.doStartOrResumeRoutes(DefaultCamelContext.java:3646)
              at org.apache.camel.impl.DefaultCamelContext.doStartCamel(DefaultCamelContext.java:3489)
              at org.apache.camel.impl.DefaultCamelContext$4.call(DefaultCamelContext.java:3248)
              at org.apache.camel.impl.DefaultCamelContext$4.call(DefaultCamelContext.java:3244)
              at org.apache.camel.impl.DefaultCamelContext.doWithDefinedClassLoader(DefaultCamelContext.java:3267)
              at org.apache.camel.impl.DefaultCamelContext.doStart(DefaultCamelContext.java:3244)
              at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:72)
              at org.apache.camel.impl.DefaultCamelContext.start(DefaultCamelContext.java:3160)
              at org.apache.camel.spring.SpringCamelContext.start(SpringCamelContext.java:133)
              ... 24 common frames omitted
      Caused by: org.eclipse.paho.client.mqttv3.MqttException: Connection lost
              at org.eclipse.paho.client.mqttv3.internal.CommsReceiver.run(CommsReceiver.java:181)
              at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
              at java.util.concurrent.FutureTask.run(FutureTask.java:266)
              at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
              at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
              at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
              at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
              ... 1 common frames omitted
      Caused by: java.io.EOFException: null
              at java.io.DataInputStream.readByte(DataInputStream.java:267)
              at org.eclipse.paho.client.mqttv3.internal.wire.MqttInputStream.readMqttWireMessage(MqttInputStream.java:92)
              at org.eclipse.paho.client.mqttv3.internal.CommsReceiver.run(CommsReceiver.java:133)
              ... 7 common frames omitted
      16:20:29.427 [main] INFO  o.s.s.c.ThreadPoolTaskExecutor - Shutting down ExecutorService 'applicationTaskExecutor'
      [WARNING] 
      java.lang.reflect.InvocationTargetException
              at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
              at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
              at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
              at java.lang.reflect.Method.invoke(Method.java:498)
              at org.springframework.boot.maven.AbstractRunMojo$LaunchRunner.run(AbstractRunMojo.java:558)
              at java.lang.Thread.run(Thread.java:748)
      Caused by: org.apache.camel.RuntimeCamelException: org.apache.camel.FailedToCreateRouteException: Failed to create route producer: Route(producer)[[From[timer:order?period=3000]] -> [Transfor... because of Connection lost
              at org.apache.camel.util.ObjectHelper.wrapRuntimeCamelException(ObjectHelper.java:1826)
              at org.apache.camel.spring.SpringCamelContext.start(SpringCamelContext.java:136)
              at org.apache.camel.spring.CamelContextFactoryBean.start(CamelContextFactoryBean.java:370)
              at org.apache.camel.spring.CamelContextFactoryBean.onApplicationEvent(CamelContextFactoryBean.java:417)
              at org.apache.camel.spring.CamelContextFactoryBean.onApplicationEvent(CamelContextFactoryBean.java:95)
              at org.springframework.context.event.SimpleApplicationEventMulticaster.doInvokeListener(SimpleApplicationEventMulticaster.java:172)
              at org.springframework.context.event.SimpleApplicationEventMulticaster.invokeListener(SimpleApplicationEventMulticaster.java:165)
              at org.springframework.context.event.SimpleApplicationEventMulticaster.multicastEvent(SimpleApplicationEventMulticaster.java:139)
              at org.springframework.context.support.AbstractApplicationContext.publishEvent(AbstractApplicationContext.java:402)
              at org.springframework.context.support.AbstractApplicationContext.publishEvent(AbstractApplicationContext.java:359)
              at org.springframework.context.support.AbstractApplicationContext.finishRefresh(AbstractApplicationContext.java:896)
              at org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.finishRefresh(ServletWebServerApplicationContext.java:163)
              at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:552)
              at org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.refresh(ServletWebServerApplicationContext.java:142)
              at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:775)
              at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:397)
              at org.springframework.boot.SpringApplication.run(SpringApplication.java:316)
              at org.springframework.boot.SpringApplication.run(SpringApplication.java:1260)
              at org.springframework.boot.SpringApplication.run(SpringApplication.java:1248)
              at io.fabric8.quickstarts.camel.amq.Application.main(Application.java:31)
              ... 6 more
      Caused by: org.apache.camel.FailedToCreateRouteException: Failed to create route producer: Route(producer)[[From[timer:order?period=3000]] -> [Transfor... because of Connection lost
              at org.apache.camel.impl.RouteService.warmUp(RouteService.java:147)
              at org.apache.camel.impl.DefaultCamelContext.doWarmUpRoutes(DefaultCamelContext.java:3953)
              at org.apache.camel.impl.DefaultCamelContext.safelyStartRouteServices(DefaultCamelContext.java:3860)
              at org.apache.camel.impl.DefaultCamelContext.doStartOrResumeRoutes(DefaultCamelContext.java:3646)
              at org.apache.camel.impl.DefaultCamelContext.doStartCamel(DefaultCamelContext.java:3489)
              at org.apache.camel.impl.DefaultCamelContext$4.call(DefaultCamelContext.java:3248)
              at org.apache.camel.impl.DefaultCamelContext$4.call(DefaultCamelContext.java:3244)
              at org.apache.camel.impl.DefaultCamelContext.doWithDefinedClassLoader(DefaultCamelContext.java:3267)
              at org.apache.camel.impl.DefaultCamelContext.doStart(DefaultCamelContext.java:3244)
              at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:72)
              at org.apache.camel.impl.DefaultCamelContext.start(DefaultCamelContext.java:3160)
              at org.apache.camel.spring.SpringCamelContext.start(SpringCamelContext.java:133)
              ... 24 more
      Caused by: Connection lost (32109) - java.io.EOFException
              at org.eclipse.paho.client.mqttv3.internal.CommsReceiver.run(CommsReceiver.java:181)
              at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
              at java.util.concurrent.FutureTask.run(FutureTask.java:266)
              at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
              at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
              at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
              at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
              ... 1 more
      Caused by: java.io.EOFException
              at java.io.DataInputStream.readByte(DataInputStream.java:267)
              at org.eclipse.paho.client.mqttv3.internal.wire.MqttInputStream.readMqttWireMessage(MqttInputStream.java:92)
              at org.eclipse.paho.client.mqttv3.internal.CommsReceiver.run(CommsReceiver.java:133)
              ... 7 more
      
      ^C%                                                                                                                                                                         ~/W/R/spring-boot-camel-amq ❯❯❯ 
      

      Attachments

        Activity

          People

            rnetuka@redhat.com Radovan Netuka
            vkasala@redhat.com Viliam Kasala
            Votes:
            0 Vote for this issue
            Watchers:
            7 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: