[NIFI-8198] ConsumeAMQP should detect if Queue is deleted on server

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.14.0, 1.13.1
• Component/s: Extensions
• Assignee: Peter Turcsanyi
• Reporter: Peter Turcsanyi
• Created: 04/Feb/21 21:26
• Updated: 25/Feb/21 05:57
• Resolved: 24/Feb/21 08:05

Description

If ConsumeAMQP is running and connected to a queue and then the queue gets deleted on the server, the processor does not detect it but keeps running without any error. It needs to be restarted in order to notice the missing queue or to continue consuming the messages if the queue has been recreated in the meantime.

The AMQP server can notify the client via basic.cancel message which should be handled in ConsumeAMQP.

Issue Links

• links to: GitHub Pull Request #4805