From 96611786871881b3c0e160e6d9003db9c46c9ff4 Mon Sep 17 00:00:00 2001 From: Peter Hormanns Date: Wed, 13 Sep 2023 20:42:36 +0200 Subject: [PATCH] auto_ack --- qserv/src/main/java/de/hsadmin/core/qserv/QueueServer.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/qserv/src/main/java/de/hsadmin/core/qserv/QueueServer.java b/qserv/src/main/java/de/hsadmin/core/qserv/QueueServer.java index 1d7f771..834abab 100644 --- a/qserv/src/main/java/de/hsadmin/core/qserv/QueueServer.java +++ b/qserv/src/main/java/de/hsadmin/core/qserv/QueueServer.java @@ -187,7 +187,7 @@ public class QueueServer implements MessageListener, ExceptionListener { } finally { if (producer != null) try { producer.close(); } catch (Exception e) { } if (session != null) try { session.close(); } catch (Exception e) { } -// if (queueConnection != null) try { queueConnection.close(); } catch (Exception e) { } + if (queueConnection != null) try { queueConnection.close(); } catch (Exception e) { } } }