cftp and activeMQ in same route

[Anonymous]

Hi everyone,

I'm trying to retrieve a file through a cFTP component, work on it and send the result in a topic. That's the final goal.

But i'm struggling to get the file and have an ActiveMQ at the same time and i don't understand why.

Actually, i'm trying with just this :

It works just fine! I get the content of the file in the body. But when i just activate my cMQConnectionFactory, it goes wrong!

I'm sure my connection is good (i have routes using it)

Here is the message:

Exception in thread "main" java.lang.NoSuchMethodError: org.apache.camel.component.file.GenericFileConsumer.
<init>(Lorg/apache/camel/component/file/GenericFileEndpoint;Lorg/apache/camel/Processor;Lorg/apache/camel/component/file/GenericFileOperations;Lorg/apache/camel/component/file/GenericFileProcessStrategy;)V
at org.apache.camel.component.file.remote.RemoteFileConsumer.<init>(RemoteFileConsumer.java:39)
at org.apache.camel.component.file.remote.FtpConsumer.<init>(FtpConsumer.java:51)
at org.apache.camel.component.file.remote.FtpEndpoint.buildConsumer(FtpEndpoint.java:99)
at org.apache.camel.component.file.remote.RemoteFileEndpoint.createConsumer(RemoteFileEndpoint.java:103)
at org.apache.camel.component.file.remote.FtpEndpoint.createConsumer(FtpEndpoint.java:93)
at org.apache.camel.component.file.remote.FtpEndpoint.createConsumer(FtpEndpoint.java:44)
at org.apache.camel.impl.EventDrivenConsumerRoute.addServices(EventDrivenConsumerRoute.java:69)
at org.apache.camel.impl.DefaultRoute.onStartingServices(DefaultRoute.java:103)
at org.apache.camel.impl.RouteService.doWarmUp(RouteService.java:172)
at org.apache.camel.impl.RouteService.warmUp(RouteService.java:145)
at org.apache.camel.impl.DefaultCamelContext.doWarmUpRoutes(DefaultCamelContext.java:3760)
at org.apache.camel.impl.DefaultCamelContext.safelyStartRouteServices(DefaultCamelContext.java:3667)
at org.apache.camel.impl.DefaultCamelContext.doStartOrResumeRoutes(DefaultCamelContext.java:3453)
at org.apache.camel.impl.DefaultCamelContext.doStartCamel(DefaultCamelContext.java:3307)
at org.apache.camel.impl.DefaultCamelContext.access$000(DefaultCamelContext.java:202)
at org.apache.camel.impl.DefaultCamelContext$2.call(DefaultCamelContext.java:3091)
at org.apache.camel.impl.DefaultCamelContext$2.call(DefaultCamelContext.java:3087)
at org.apache.camel.impl.DefaultCamelContext.doWithDefinedClassLoader(DefaultCamelContext.java:3110)
at org.apache.camel.impl.DefaultCamelContext.doStart(DefaultCamelContext.java:3087)
at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61)
at org.apache.camel.impl.DefaultCamelContext.start(DefaultCamelContext.java:3024)
at org.apache.camel.main.Main.doStart(Main.java:139)
at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61)
at org.apache.camel.main.MainSupport.run(MainSupport.java:168)
at data.int_dta_rte_magentotomq_001_0_2.INT_DTA_RTE_MagentoToMQ_001.run(INT_DTA_RTE_MagentoToMQ_001.java:272)
at data.int_dta_rte_magentotomq_001_0_2.INT_DTA_RTE_MagentoToMQ_001.runJobInTOS(INT_DTA_RTE_MagentoToMQ_001.java:846)
at data.int_dta_rte_magentotomq_001_0_2.INT_DTA_RTE_MagentoToMQ_001.main(INT_DTA_RTE_MagentoToMQ_001.java:816)

I tried to reach the lines in the error message, it's only saying "main.run()",  "try { run(); }" and

"int exitCode = new INT_DTA_RTE_MagentoToMQ_001().runJobInTOS(args);"

I don't understand why activating a connection can provoke this error. I've tried using it with a cJMS component to be sure the connection is used, it changes nothing.

Thanks by advance for the help.

Regards,

Romain

[Anonymous · Accepted solution]

Hi all,

I've solved this issue

The configuration of the cMQConnectionFactory needs to be done manually with specific dependencies :