Details
-
Bug
-
Resolution: Done
-
Major
-
fuse-7.8-GA, fuse-7.9-GA
-
None
-
False
-
False
-
%
-
+
-
Automated
-
Description
input Streeam not closed when jmsMessageType=Stream.
there is an upstream issue open for the same:
https://issues.apache.org/jira/browse/CAMEL-17565
https://github.com/apache/camel/commit/95cd5c2854a50b78fe2448f541e03320d7e95971
below the file leak :
3 descriptors are open
#1 test-stream\in\test126.xml by thread:Camel (camel-1) thread #1 - file://test-stream/in on Fri Jan 28 08:18:48 PST 2022
at java.io.FileInputStream.<init>(FileInputStream.java:139)
at org.apache.camel.converter.IOConverter.toInputStream(IOConverter.java:81)
at org.apache.camel.converter.IOConverter.toInputStream(IOConverter.java:95)
at org.apache.camel.component.file.GenericFileConverter.genericFileToInputStream(GenericFileConverter.java:118)
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.apache.camel.util.ObjectHelper.invokeMethod(ObjectHelper.java:1401)
at org.apache.camel.impl.converter.StaticMethodTypeConverter.convertTo(StaticMethodTypeConverter.java:59)
at org.apache.camel.impl.converter.BaseTypeConverterRegistry.doConvertTo(BaseTypeConverterRegistry.java:325)
at org.apache.camel.impl.converter.BaseTypeConverterRegistry.mandatoryConvertTo(BaseTypeConverterRegistry.java:188)
at org.apache.camel.component.jms.JmsBinding.createJmsMessageForType(JmsBinding.java:692)
at org.apache.camel.component.jms.JmsBinding.createJmsMessage(JmsBinding.java:562)
at org.apache.camel.component.jms.JmsBinding.createJmsMessage(JmsBinding.java:515)
at org.apache.camel.component.jms.JmsBinding.makeJmsMessage(JmsBinding.java:346)
at org.apache.camel.component.jms.JmsProducer$2.createMessage(JmsProducer.java:327)
at org.apache.camel.component.jms.JmsConfiguration$CamelJmsTemplate.doSendToDestination(JmsConfiguration.java:577)
at org.apache.camel.component.jms.JmsConfiguration$CamelJmsTemplate.access$100(JmsConfiguration.java:520)
at org.apache.camel.component.jms.JmsConfiguration$CamelJmsTemplate$1.doInJms(JmsConfiguration.java:534)
at org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:504)
at org.apache.camel.component.jms.JmsConfiguration$CamelJmsTemplate.send(JmsConfiguration.java:531)
at org.apache.camel.component.jms.JmsProducer.doSend(JmsProducer.java:440)
at org.apache.camel.component.jms.JmsProducer.processInOnly(JmsProducer.java:394)
at org.apache.camel.component.jms.JmsProducer.process(JmsProducer.java:157)
at org.apache.camel.processor.SendProcessor.process(SendProcessor.java:148)
at org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:548)
at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:201)
at org.apache.camel.processor.Pipeline.process(Pipeline.java:138)
at org.apache.camel.processor.Pipeline.process(Pipeline.java:101)
at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:201)
at org.apache.camel.component.file.GenericFileConsumer.processExchange(GenericFileConsumer.java:454)
at org.apache.camel.component.file.GenericFileConsumer.processBatch(GenericFileConsumer.java:223)
at org.apache.camel.component.file.GenericFileConsumer.poll(GenericFileConsumer.java:187)
at org.apache.camel.impl.ScheduledPollConsumer.doRun(ScheduledPollConsumer.java:174)
at org.apache.camel.impl.ScheduledPollConsumer.run(ScheduledPollConsumer.java:101)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
#2 test-stream\in\test126.xml by thread:Camel (camel-1) thread #1 - file://test-stream/in on Fri Jan 28 08:18:53 PST 2022
at java.io.FileInputStream.<init>(FileInputStream.java:139)