jms consumer leak when exceptions occur

apache / pekko-connectors

Apache Pekko Connectors is a Reactive Enterprise Integration library for Java and Scala, based on Reactive Streams and Apache Pekko.

https://pekko.apache.org/

Apache License 2.0

64 stars 32 forks source link

jms consumer leak when exceptions occur #484

Closed pjfanning closed 8 months ago

pjfanning commented 8 months ago

see https://github.com/akka/alpakka/issues/3038

from the description and checking the jms connector code, it's pretty clear that handleRetriableException is not closing the open sessions but just clearing the list of open sessions while leaving them open

pjfanning commented 8 months ago

https://github.com/apache/incubator-pekko-connectors/pull/485 merged - I'll keep an eye on the tests as they might be brittle