Good morning and thank you Oleg. No, no other stack traces or errors are indicated. I've got my Publish AMQP configuration set to DEBUG for Bulletin Level.
I do get an error at the UI when I try to Start the Publish AMQP step after I have Stopped it. It tells me "PublishAMQP[id=47f88.....744] cannot be started because it is not stopped. Current state is STOPPING". I suspect this is a reflection of the WARN log message. In your experience must I take some action at the RabbitMQ Management Console to change my Exchange and Queue from Idle to Active? I believe that would happen automatically when AMQP messages starting hitting the exchange, but I thought it best to ask. I see nothing on the management console that alludes to enabling the exchange or the queue. Jim On Thu, Dec 8, 2016 at 7:24 AM, Oleg Zhurakousky < [email protected]> wrote: > James > > Aside from “closing” failure message, do you see any other errors or stack > traces in the logs? > Meanwhile I’ll try to dig more with what I have? > > Oleg > > On Dec 8, 2016, at 7:13 AM, James McMahon <[email protected]> wrote: > > Hello I am trying to use a Publish AMQP step in my NiFi workflow. I > generate a flow file with random text content using Generate Flow File, and > then send to a rabbitMQ Exchange named nifiAbcX using Publish AMQP. My > exchange is bound to queue AbcQ by key **.Abc.**, and my virtual host is > nifiVhost. I have established my exchange as a Topic type. > > > My NiFi instance and my RabbitMQ instance are co-located for development > test purposes on the same server. > > > It appears that my Publish AMQP does indeed generate output which it sends > down the "success" output flow path, but at the RabbitMQ Management Console > I find that my Exchange and my Queue are Idle and show no messages. My nifi > log shows this Warning message: Failure while closing target resource > AMQPublisher:amqp://[email protected]:5673/nifiVhost, EXCHANGE:nifiAbcX, > ROUTING_KEY:xyz.Abc.prod What is this telling me? Why am I seeing no > messages posted to my rabbitMQ queue through the exchange? Thank you in > advance. > > >
