topic Re: Talend and RabbitMQ in Talend Studio

Talend and RabbitMQ

Anonymous — Sat, 16 Nov 2024 08:12:41 GMT

Hi,

I have created a job to publish data into rabbitmq. Below is the error I am getting after running the job. Could you please help me to fix this issue.

Checking ports...

Sending job 'ex' to server (10.1.5.76:8001)...

File transfer completed.

Deploying job 'ex' on server (10.1.5.76:8000)...

Running job 'ex'...
Starting job ex at 21:45 26/05/2018.

IOException parsing XML document from class path resource [META-INF/spring/ex.xml]; nested exception is java.io.FileNotFoundException: class path resource [META-INF/spring/ex.xml] cannot be opened because it does not exist
org.springframework.beans.factory.BeanDefinitionStoreException: IOException parsing XML document from class path resource [META-INF/spring/ex.xml]; nested exception is java.io.FileNotFoundException: class path resource [META-INF/spring/ex.xml] cannot be opened because it does not exist
at org.springframework.beans.factory.xml.XmlBeanDefinitionReader.loadBeanDefinitions(XmlBeanDefinitionReader.java:342)
at org.springframework.beans.factory.xml.XmlBeanDefinitionReader.loadBeanDefinitions(XmlBeanDefinitionReader.java:303)
at org.springframework.beans.factory.support.AbstractBeanDefinitionReader.loadBeanDefinitions(AbstractBeanDefinitionReader.java:174)
at org.springframework.beans.factory.support.AbstractBeanDefinitionReader.loadBeanDefinitions(AbstractBeanDefinitionReader.java:209)
at org.springframework.beans.factory.support.AbstractBeanDefinitionReader.loadBeanDefinitions(AbstractBeanDefinitionReader.java:180)
at org.springframework.beans.factory.support.AbstractBeanDefinitionReader.loadBeanDefinitions(AbstractBeanDefinitionReader.java:243)
at org.springframework.context.support.AbstractXmlApplicationContext.loadBeanDefinitions(AbstractXmlApplicationContext.java:127)
at org.springframework.context.support.AbstractXmlApplicationContext.loadBeanDefinitions(AbstractXmlApplicationContext.java:93)
at org.springframework.context.support.AbstractRefreshableApplicationContext.refreshBeanFactory(AbstractRefreshableApplicationContext.java:130)
at org.springframework.context.support.AbstractApplicationContext.obtainFreshBeanFactory(AbstractApplicationContext.java:539)
at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:451)
at org.springframework.context.support.ClassPathXmlApplicationContext.<init>(ClassPathXmlApplicationContext.java:139)
at org.springframework.context.support.ClassPathXmlApplicationContext.<init>(ClassPathXmlApplicationContext.java:83)
at cdp.ex_0_1.ex$1.createContext(ex.java:81)
at org.apache.camel.main.Main.getCamelContextMap(Main.java:149)
at org.apache.camel.main.MainSupport.postProcessContext(MainSupport.java:433)
at org.apache.camel.main.Main.doStart(Main.java:125)
at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61)
at org.apache.camel.main.MainSupport.run(MainSupport.java:138)
at cdp.ex_0_1.ex.run(ex.java:130)
at cdp.ex_0_1.ex.runJobInTOS(ex.java:197)
at cdp.ex_0_1.ex.main(ex.java:166)
Caused by: java.io.FileNotFoundException: class path resource [META-INF/spring/ex.xml] cannot be opened because it does not exist
at org.springframework.core.io.ClassPathResource.getInputStream(ClassPathResource.java:171)
at org.springframework.beans.factory.xml.XmlBeanDefinitionReader.loadBeanDefinitions(XmlBeanDefinitionReader.java:329)
... 21 more
Job ex ended at 21:45 26/05/2018. [exit code=1]

Thanks,
srenaray

Re: Talend and RabbitMQ

Jesperrekuh — Mon, 28 May 2018 12:20:14 GMT

Make sure your java environment vars are setup properly,
CLASSPATH
JAVA_HOME
JAVA_PATH
Google it please... to see how to set it up correctly and which ones...
Also possible to set it on runtime: java.exe classpath or something.

Re: Talend and RabbitMQ

Anonymous — Tue, 29 May 2018 09:19:46 GMT

Hi,

My Talend is poined to Remote Server. Could you please help me how can i set the Java_home and the server is already being used by other projects.

Thanks,
Sreeman

Re: Talend and RabbitMQ

Jesperrekuh — Tue, 29 May 2018 21:33:49 GMT

RabbitMQ:
First check if your RabbitMQ config is properly setup and is able to find the needed jars, so test RabbitMQ from your talend server prompt to see if it works? (Im not a RabbitMQ expert)
https://www.rabbitmq.com/management-cli.html

Next, Talend job, run/schedule on server:
So your job runs on remote server, contact admin / talend admin to properly config the Java environment to run the remote job(s) with specific components which need to be configured on the server or from within your talend job.

ClassPath:
Search on the forum to set classpath from within Talend as java parameter,
Although Im not aware of changes within the talend environment on how to load external lib/jars and your specific config/setup. Maybe the server runs with multiple java versions (in example mine runs 3java versions depending on tool/platform/sysuser)

Make sure RabbitMQ works while using prompt by system(talendadmin) / same user your job runs.

Re: Talend and RabbitMQ

Anonymous — Mon, 20 May 2019 11:41:18 GMT

Hello everyone,

I use component trabbitMQSubscriber but i have this error when i run the job.

émarrage du job Publish a 12:35 20/05/2019.

[statistics] connecting to socket on port 3354

[statistics] connected

Exception in component tRabbitMQSubscriber_1 (Publish)

java.io.IOException

at com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:129)

at com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:125)

at com.rabbitmq.client.impl.ChannelN.basicConsume(ChannelN.java:1384)

at com.rabbitmq.client.impl.recovery.AutorecoveringChannel.basicConsume(AutorecoveringChannel.java:532)

at com.rabbitmq.client.impl.recovery.AutorecoveringChannel.basicConsume(AutorecoveringChannel.java:486)

at com.rabbitmq.client.impl.recovery.AutorecoveringChannel.basicConsume(AutorecoveringChannel.java:464)

at rabbit.publish_0_1.Publish.tRabbitMQSubscriber_1Process(Publish.java:478)

at rabbit.publish_0_1.Publish.runJobInTOS(Publish.java:918)

at rabbit.publish_0_1.Publish.main(Publish.java:769)

Caused by: com.rabbitmq.client.ShutdownSignalException: channel error; protocol method: #method<channel.close>(reply-code=404, reply-text=NOT_FOUND - no queue 'simple.queue' in vhost '/', class-id=60, method-id=20)

at com.rabbitmq.utility.ValueOrException.getValue(ValueOrException.java:66)

at com.rabbitmq.utility.BlockingValueOrException.uninterruptibleGetValue(BlockingValueOrException.java:36)

at com.rabbitmq.client.impl.AMQChannel$BlockingRpcContinuation.getReply(AMQChannel.java:502)

at com.rabbitmq.client.impl.ChannelN.basicConsume(ChannelN.java:1378)

... 6 more

at com.rabbitmq.client.impl.ChannelN.asyncShutdown(ChannelN.java:522)

at com.rabbitmq.client.impl.ChannelN.processAsync(ChannelN.java:346)

at com.rabbitmq.client.impl.AMQChannel.handleCompleteInboundCommand(AMQChannel.java:182)

at com.rabbitmq.client.impl.AMQChannel.handleFrame(AMQChannel.java:114)

at com.rabbitmq.client.impl.AMQConnection.readFrame(AMQConnection.java:672)

at com.rabbitmq.client.impl.AMQConnection.access$300(AMQConnection.java:48)

at com.rabbitmq.client.impl.AMQConnection$MainLoop.run(AMQConnection.java:599)

at java.lang.Thread.run(Unknown Source)

[statistics] disconnected

Job Publish terminé à 12:35 20/05/2019. [Code sortie=1]

Thank's for your feedback

errors.PNG