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.
