Talend and RabbitMQ

[Anonymous]

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

[Jesperrekuh · Accepted solution]

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.

[Anonymous]

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

[Jesperrekuh]

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.

[Anonymous]

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

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.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