Hi Arun, There is no dedicated AMQP 1.0 processor in NiFi.
Instead, you can use the JMS processors and controller services with Qpid JMS driver [1]. The Qpid JMS client is AMQP 1.0 compatible so it should work with any AMQP 1.0 server like RMQ 4.0. For NiFi 1.x you will need to use the 1.x Qpid JMS (the latest is 1.12.1 currently). Qpid JMS 2.x (2.6.1) is compatible with NiFi 2.x. High level install / config steps: - download and untar the Qpid JMS binaries - create JMSConnectionFactoryProvider controller service - JMS Connection Factory Implementation Class: org.apache.qpid.jms.JmsConnectionFactory - JMS Client Libraries: points to the lib folder of the unpacked Qpid JMS binaries - JMS Broker URI: e.g. amqp://myhost:5672 Hope this helps! Regards, Peter Turcsanyi [1] https://qpid.apache.org/components/jms/index.html On Tue, Oct 29, 2024 at 4:11 PM Varadarajan, Arun < arun.varadara...@paramount.com> wrote: > Hi Team, > > Right now NIFI's AMQP supports protocol AMQP 0.9.1 only. Our producers are > planning to upgrade to RMQ 4.0. Could someone please let us know , if the > existing consumeAMQP [with 0.9.1 protocol] will support RMQ 4.0 as well and > is there any limitation we have with 0.9.1 version? > > We have referred few docs , which states AMQP 1.0 is the core for RMQ 4.0 > . So want to hear from you people. > > Regards, > Arun V >
