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) { } } }