[BUG] potential ConcurrentModificationException when removeQueue

Open HScarb opened this issue 1 year ago • 0 comments

Describe the bug https://github.com/streamnative/aop/blob/06bf6573172c2c41fb0483215ce65ccea5b281a7/amqp-impl/src/main/java/io/streamnative/pulsar/handlers/amqp/impl/PersistentExchange.java#L287-L303

in removeQueue method, we remove value from a map when iterating it, which cause potential ConcurrentModificationException.

To Reproduce bind queue with Direct exchange, then remove the queue

Expected behavior queue removed successfully

Screenshots none

Additional context none

Apr 15 '24 13:04 HScarb