Aurélien Pupier created CAMEL-23484:
---------------------------------------
Summary: Unstable Paho test EOFException
Key: CAMEL-23484
URL: https://issues.apache.org/jira/browse/CAMEL-23484
Project: Camel
Issue Type: Test
Components: camel-paho
Affects Versions: 4.20.0
Reporter: Aurélien Pupier
5 tests are failign often on Ci with similar error:
{noformat}
org.apache.camel.RuntimeCamelException: Connection lost (32109) -
java.io.EOFException
at
org.apache.camel.RuntimeCamelException.wrapRuntimeException(RuntimeCamelException.java:68)
at
org.apache.camel.support.service.BaseService.doFail(BaseService.java:431)
at
org.apache.camel.support.service.BaseService.fail(BaseService.java:360)
at
org.apache.camel.support.service.BaseService.start(BaseService.java:136)
at
org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:127)
at
org.apache.camel.impl.engine.AbstractCamelContext.startService(AbstractCamelContext.java:3584)
at
org.apache.camel.impl.engine.InternalRouteStartupManager.doStartOrResumeRouteConsumers(InternalRouteStartupManager.java:425)
at
org.apache.camel.impl.engine.InternalRouteStartupManager.doStartRouteConsumers(InternalRouteStartupManager.java:341)
at
org.apache.camel.impl.engine.InternalRouteStartupManager.safelyStartRouteServices(InternalRouteStartupManager.java:217)
at
org.apache.camel.impl.engine.InternalRouteStartupManager.lambda$doStartOrResumeRoutes$1(InternalRouteStartupManager.java:129)
at
org.apache.camel.impl.engine.AbstractCamelContext.lambda$startingRoutes$2(AbstractCamelContext.java:1159)
at
org.apache.camel.util.concurrent.ContextValueFactory.where(ContextValueFactory.java:65)
at
org.apache.camel.util.concurrent.ContextValue.where(ContextValue.java:174)
at
org.apache.camel.impl.engine.AbstractCamelContext.startingRoutes(AbstractCamelContext.java:1157)
at
org.apache.camel.impl.engine.InternalRouteStartupManager.doStartOrResumeRoutes(InternalRouteStartupManager.java:117)
at
org.apache.camel.impl.engine.AbstractCamelContext.doStartCamel(AbstractCamelContext.java:3190)
at
org.apache.camel.impl.engine.AbstractCamelContext.doStartContext(AbstractCamelContext.java:2796)
at
org.apache.camel.impl.engine.AbstractCamelContext.doStart(AbstractCamelContext.java:2751)
at
org.apache.camel.support.service.BaseService.start(BaseService.java:123)
at
org.apache.camel.impl.engine.AbstractCamelContext.start(AbstractCamelContext.java:2331)
at
org.apache.camel.impl.DefaultCamelContext.start(DefaultCamelContext.java:214)
at
org.apache.camel.test.infra.core.DefaultContextLifeCycleManager.beforeEach(DefaultContextLifeCycleManager.java:80)
at
org.apache.camel.test.infra.core.DefaultCamelContextExtension.beforeEach(DefaultCamelContextExtension.java:102)
at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)
at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)
Caused by: Connection lost (32109) - java.io.EOFException
at
org.eclipse.paho.client.mqttv3.internal.CommsReceiver.run(CommsReceiver.java:197)
at java.base/java.lang.Thread.run(Thread.java:1583)
Caused by: java.io.EOFException
at
java.base/java.io.DataInputStream.readUnsignedByte(DataInputStream.java:297)
at java.base/java.io.DataInputStream.readByte(DataInputStream.java:275)
at
org.eclipse.paho.client.mqttv3.internal.wire.MqttInputStream.readMqttWireMessage(MqttInputStream.java:92)
at
org.eclipse.paho.client.mqttv3.internal.CommsReceiver.run(CommsReceiver.java:137)
... 1 more
{noformat}
{noformat}
org.apache.camel.CamelExecutionException: Exception occurred during execution
on the exchange: Exchange[31024215DAB9A81-0000000000000001]
at
org.apache.camel.CamelExecutionException.wrapCamelExecutionException(CamelExecutionException.java:45)
at
org.apache.camel.support.ExchangeHelper.extractResultBody(ExchangeHelper.java:704)
at
org.apache.camel.impl.engine.DefaultProducerTemplate.extractResultBody(DefaultProducerTemplate.java:594)
at
org.apache.camel.impl.engine.DefaultProducerTemplate.extractResultBody(DefaultProducerTemplate.java:590)
at
org.apache.camel.impl.engine.DefaultProducerTemplate.sendBodyAndHeader(DefaultProducerTemplate.java:220)
at
org.apache.camel.impl.engine.DefaultProducerTemplate.sendBodyAndHeader(DefaultProducerTemplate.java:212)
at
org.apache.camel.component.paho.PahoToDSendDynamicTest.testToDSlashed(PahoToDSendDynamicTest.java:58)
Caused by: Connection lost (32109) - java.io.EOFException
at
org.eclipse.paho.client.mqttv3.internal.CommsReceiver.run(CommsReceiver.java:197)
at java.base/java.lang.Thread.run(Thread.java:1583)
Caused by: java.io.EOFException
at
java.base/java.io.DataInputStream.readUnsignedByte(DataInputStream.java:297)
at java.base/java.io.DataInputStream.readByte(DataInputStream.java:275)
at
org.eclipse.paho.client.mqttv3.internal.wire.MqttInputStream.readMqttWireMessage(MqttInputStream.java:92)
at
org.eclipse.paho.client.mqttv3.internal.CommsReceiver.run(CommsReceiver.java:137)
... 1 more
{noformat}
{noformat}
org.apache.camel.RuntimeCamelException: Connection lost (32109) -
java.io.EOFException
at
org.apache.camel.RuntimeCamelException.wrapRuntimeException(RuntimeCamelException.java:68)
at
org.apache.camel.support.service.BaseService.doFail(BaseService.java:431)
at
org.apache.camel.support.service.BaseService.fail(BaseService.java:360)
at
org.apache.camel.support.service.BaseService.start(BaseService.java:136)
at
org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:127)
at
org.apache.camel.impl.engine.AbstractCamelContext.startService(AbstractCamelContext.java:3584)
at
org.apache.camel.impl.engine.InternalRouteStartupManager.doStartOrResumeRouteConsumers(InternalRouteStartupManager.java:425)
at
org.apache.camel.impl.engine.InternalRouteStartupManager.doStartRouteConsumers(InternalRouteStartupManager.java:341)
at
org.apache.camel.impl.engine.InternalRouteStartupManager.safelyStartRouteServices(InternalRouteStartupManager.java:217)
at
org.apache.camel.impl.engine.InternalRouteStartupManager.lambda$doStartOrResumeRoutes$1(InternalRouteStartupManager.java:129)
at
org.apache.camel.impl.engine.AbstractCamelContext.lambda$startingRoutes$2(AbstractCamelContext.java:1159)
at
org.apache.camel.util.concurrent.ContextValueFactory.where(ContextValueFactory.java:65)
at
org.apache.camel.util.concurrent.ContextValue.where(ContextValue.java:174)
at
org.apache.camel.impl.engine.AbstractCamelContext.startingRoutes(AbstractCamelContext.java:1157)
at
org.apache.camel.impl.engine.InternalRouteStartupManager.doStartOrResumeRoutes(InternalRouteStartupManager.java:117)
at
org.apache.camel.impl.engine.AbstractCamelContext.doStartCamel(AbstractCamelContext.java:3190)
at
org.apache.camel.impl.engine.AbstractCamelContext.doStartContext(AbstractCamelContext.java:2796)
at
org.apache.camel.impl.engine.AbstractCamelContext.doStart(AbstractCamelContext.java:2751)
at
org.apache.camel.support.service.BaseService.start(BaseService.java:123)
at
org.apache.camel.impl.engine.AbstractCamelContext.start(AbstractCamelContext.java:2331)
at
org.apache.camel.impl.DefaultCamelContext.start(DefaultCamelContext.java:214)
at
org.apache.camel.test.infra.core.DefaultContextLifeCycleManager.beforeEach(DefaultContextLifeCycleManager.java:80)
at
org.apache.camel.test.infra.core.DefaultCamelContextExtension.beforeEach(DefaultCamelContextExtension.java:102)
at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)
at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)
Caused by: Connection lost (32109) - java.io.EOFException
at
org.eclipse.paho.client.mqttv3.internal.CommsReceiver.run(CommsReceiver.java:197)
at java.base/java.lang.Thread.run(Thread.java:1583)
Caused by: java.io.EOFException
at
java.base/java.io.DataInputStream.readUnsignedByte(DataInputStream.java:297)
at java.base/java.io.DataInputStream.readByte(DataInputStream.java:275)
at
org.eclipse.paho.client.mqttv3.internal.wire.MqttInputStream.readMqttWireMessage(MqttInputStream.java:92)
at
org.eclipse.paho.client.mqttv3.internal.CommsReceiver.run(CommsReceiver.java:137)
... 1 more
{noformat}
PahoManualAcksTest.testManualAcks
PahoOverrideTopicTest.shouldOverride
PahoToDSendDynamicTest.testToD
PahoToDSendDynamicTest.testToDSlashed
PahoToDTest.testToD
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
