Hello Mark,
Here you go:
2018-06-28 15:47:27,161 ERROR [Timer-Driven Process Thread-9]
o.apache.nifi.jms.processors.ConsumeJMS
ConsumeJMS[id=01641047-1441-10a4-ce22-23d392689dd9]
ConsumeJMS[id=01641047-1441-10a4-ce22-23d392689dd9] failed to process session
due to org.springframework.jms.UncategorizedJmsException: Uncategorized
exception occured during JMS processing; nested exception is
com.rabbitmq.jms.util.RMQJMSException:
com.rabbitmq.jms.client.message.RMQTextMessage; Processor Administratively
Yielded for 1 sec: org.springframework.jms.UncategorizedJmsException:
Uncategorized exception occured during JMS processing; nested exception is
com.rabbitmq.jms.util.RMQJMSException:
com.rabbitmq.jms.client.message.RMQTextMessage
org.springframework.jms.UncategorizedJmsException: Uncategorized exception
occured during JMS processing; nested exception is
com.rabbitmq.jms.util.RMQJMSException:
com.rabbitmq.jms.client.message.RMQTextMessage
at
org.springframework.jms.support.JmsUtils.convertJmsAccessException(JmsUtils.java:316)
at
org.springframework.jms.support.JmsAccessor.convertJmsAccessException(JmsAccessor.java:169)
at
org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:497)
at
org.apache.nifi.jms.processors.JMSConsumer.consume(JMSConsumer.java:85)
at
org.apache.nifi.jms.processors.ConsumeJMS.rendezvousWithJms(ConsumeJMS.java:181)
at
org.apache.nifi.jms.processors.ConsumeJMS.rendezvousWithJms(ConsumeJMS.java:59)
at
org.apache.nifi.jms.processors.AbstractJMSProcessor.onTrigger(AbstractJMSProcessor.java:157)
at
org.apache.nifi.jms.processors.ConsumeJMS.onTrigger(ConsumeJMS.java:59)
at
org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:27)
at
org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1147)
at
org.apache.nifi.controller.tasks.ConnectableTask.invoke(ConnectableTask.java:175)
at
org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$1.run(TimerDrivenSchedulingAgent.java:117)
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)
Caused by: com.rabbitmq.jms.util.RMQJMSException:
com.rabbitmq.jms.client.message.RMQTextMessage
at
com.rabbitmq.jms.client.RMQMessage.instantiateRmqMessage(RMQMessage.java:1070)
at
com.rabbitmq.jms.client.RMQMessage.fromMessage(RMQMessage.java:1030)
at
com.rabbitmq.jms.client.RMQMessage.convertJmsMessage(RMQMessage.java:871)
at
com.rabbitmq.jms.client.RMQMessage.convertMessage(RMQMessage.java:865)
at
com.rabbitmq.jms.client.RMQMessageConsumer.receive(RMQMessageConsumer.java:331)
at
com.rabbitmq.jms.client.RMQMessageConsumer.receive(RMQMessageConsumer.java:246)
at
org.apache.nifi.jms.processors.JMSConsumer$1.doInJms(JMSConsumer.java:95)
at
org.apache.nifi.jms.processors.JMSConsumer$1.doInJms(JMSConsumer.java:85)
at
org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:494)
... 16 common frames omitted
Caused by: java.lang.ClassNotFoundException:
com.rabbitmq.jms.client.message.RMQTextMessage
at java.net.URLClassLoader.findClass(URLClassLoader.java:381)
at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
at java.lang.Class.forName0(Native Method)
at java.lang.Class.forName(Class.java:348)
at
com.rabbitmq.jms.client.RMQMessage.instantiateRmqMessage(RMQMessage.java:1064)
... 24 common frames omitted
From: Mark Payne <[email protected]>
Sent: jeudi 28 juin 2018 16:40
To: [email protected]
Subject: Re: simple JMS pub-sub not working
Hi Kelsey,
Can you provide the entire stack trace? What you've given here is just a
"Caused by" portion of it.
Thanks
-Mark
On Jun 28, 2018, at 9:50 AM, Kelsey RIDER
<[email protected]<mailto:[email protected]>> wrote:
Hello again,
I’m trying to set up a very simple round-trip JMS test.
I have a RabbitMQ server set up and installed locally.
I set up a simple NiFi flow that generates a FlowFile and uses PublishJMS to
send it to the queue.
I then have a ConsumeJMS processor that tries to consume what I just published.
The problem is that the consumer always dies with the following exception:
Caused by: java.lang.ClassNotFoundException:
com.rabbitmq.jms.client.message.RMQTextMessage
at java.net.URLClassLoader.findClass(URLClassLoader.java:381)
at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
at java.lang.Class.forName0(Native Method)
at java.lang.Class.forName(Class.java:348)
at
com.rabbitmq.jms.client.RMQMessage.instantiateRmqMessage(RMQMessage.java:1064)
Both the publisher and the consumer use the same JMSConnectionFactoryProvider,
which is configured with the appropriate libraries and is successfully
communicating with RabbitMQ (I can see the published messages from the RabbitMQ
admin console).
Why doesn’t ConsumeJMS use the libraries configured on the JMS controller
service? How could I get this to work? I tried dropping the required JARs in
lib/ but this led to the JMS controller service not starting (don’t recall the
exception). Dropping them in lib/bootstrap/ didn’t have any effect.
Thanks,
Kelsey
Suite à l’évolution des dispositifs de réglementation du travail, si vous
recevez ce mail avant 7h00, en soirée, durant le week-end ou vos congés merci,
sauf cas d’urgence exceptionnelle, de ne pas le traiter ni d’y répondre
immédiatement.
