Fixed JMS connection leak when uncaught exceptions happen
This closes
@@ -155,9 +155,12 @@ abstract class AbstractJMSProcessor<T extends JMSWorker> extends AbstractProcess
worker = buildTargetResource(context);
}
+ try {
rendezvousWithJms(context, session, worker);
+ } finally {
workerPool.offer(worker);
}
+ }
@OnScheduled
public void setupWorkerPool(final ProcessContext context) {
