ptgoetz / storm-jms

Storm JMS Integration
Apache License 2.0
78 stars 66 forks source link

open connections #21

Closed albertocsm closed 9 years ago

albertocsm commented 9 years ago

I'm having an issue with open connections. Using AMQ 5.11 and Storm 9.5. I see a never ending number of open connections (sudo ss -s). The thing keeps growing until AMQ or Storm exhaust the machine resources. The session mode is AUTO_ACKNOWLEDGE and I´m producing +- 5k messages per minute. I have 3 topologies and equal number of spout instances (distributed = true). I only have a producer instance at all times. I've checked JMX info from AMQ and the reported number of consumers is 3, as expected. I do have more sessionIds them I would expect (+-20).

After reading the code thoroughly, it doesn't seem related to the spout at all, but I'm struggling with this one... Anybody experienced something like this with @ptgoetz storm-jms? Thanks

albertocsm commented 9 years ago

Issue seems related to using JMS Message Selectors. At least with AMQ Related to #19.