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

input Streeam not closed when jmsMessageType=Stream

    XMLWordPrintable

Details

    • Bug
    • Resolution: Done
    • Major
    • fuse-7.11-GA
    • fuse-7.8-GA, fuse-7.9-GA
    • Fuse Standalone
    • None

    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)

      Attachments

        Activity

          People

            jondruse@redhat.com Jiri Ondrusek
            rhn-support-mgolfari Matteo Golfarini (Inactive)
            Federico Mariani Federico Mariani
            Votes:
            0 Vote for this issue
            Watchers:
            5 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: