Talend and RabbitMQ

Highlighted
Six Stars

Talend and RabbitMQ

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


Accepted Solutions
Ten Stars

Re: Talend and RabbitMQ

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.

All Replies
Ten Stars

Re: Talend and RabbitMQ

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

Re: Talend and RabbitMQ

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

Ten Stars

Re: Talend and RabbitMQ

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

Re: Talend and RabbitMQ

errors.PNG

 

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

 

15TH OCTOBER, COUNTY HALL, LONDON

Join us at the Community Lounge.

Register Now

2019 GARNER MAGIC QUADRANT FOR DATA INTEGRATION TOOL

Talend named a Leader.

Get your copy

OPEN STUDIO FOR DATA INTEGRATION

Kickstart your first data integration and ETL projects.

Download now

What’s New for Talend Summer ’19

Watch the recorded webinar!

Watch Now

Put Massive Amounts of Data to Work

Learn how to make your data more available, reduce costs and cut your build time

Watch Now

How OTTO Utilizes Big Data to Deliver Personalized Experiences

Read about OTTO's experiences with Big Data and Personalized Experiences

Blog

Talend Integration with Databricks

Take a look at this video about Talend Integration with Databricks

Watch Now