I have a queue in RabbitMQ that I try to ConsumeAMQP from, configured like this:
Queue detection-responses Auto-Acknowledge Messages false Batch Size 1 Prefetch Count 0 Header Output Format Comma-Separated String Header Separator , Remove Curly Braces False BrokersNo value setHost Name 18.235.119.166 Port 5672 Virtual Host / User Name Admin Password Sensitive value setAMQP Version 0.9.1 SSL Context Service No value set Use Client Certificate Authentication false My messages are not successfully consumed into my nifi flow. This is what I find in my log: 17:23:39 UTC INFO 1134134d-1ec5-158c-c3db-526be43cd3fa ConsumeAMQP[id=1134134d-1ec5-158c-c3db-526be43cd3fa] Successfully connected AMQPConsumer to amqp://Admin@18.235.119.166:5672/ and 'detection-responses' queue 17:23:39 UTC DEBUG 1134134d-1ec5-158c-c3db-526be43cd3fa ConsumeAMQP[id=1134134d-1ec5-158c-c3db-526be43cd3fa] Closing AMQP channel for amqp://Admin@18.235.119.166:5672/ 17:23:39 UTC INFO 1134134d-1ec5-158c-c3db-526be43cd3fa ConsumeAMQP[id=1134134d-1ec5-158c-c3db-526be43cd3fa] Consumer is closed, discarding message (delivery tag: 1). Auto-refresh Is this because the channel is closing prematurely? Is there a queue property I must set to keep it open? Thank you for any help.
