Hello, I have extended the RMQSource class and overrode setupQueue method to declare a queue and bind it to an exchange.
Now, when I stop the flink job the queue is not deleted. I tried to override cancel() and close() to delete the queue but I found they are not called on stopping the job. Is there a way to delete that queue? Thanks in advance!
