From 99f33b5b4b895410a3ca20f4dd5769f08d65b9f8 Mon Sep 17 00:00:00 2001
From: Peter Hormanns <peter.hormanns@jalin.de>
Date: Wed, 13 Sep 2023 19:54:05 +0200
Subject: [PATCH] client_ack

---
 qserv/src/main/java/de/hsadmin/core/qserv/QueueServer.java | 1 +
 1 file changed, 1 insertion(+)

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 6431211..5974492 100644
--- a/qserv/src/main/java/de/hsadmin/core/qserv/QueueServer.java
+++ b/qserv/src/main/java/de/hsadmin/core/qserv/QueueServer.java
@@ -183,6 +183,7 @@ public class QueueServer implements MessageListener, ExceptionListener {
 			final ObjectMessage statusMessage = session.createObjectMessage(queueMessage);
 			logger.log(Level.INFO, "send(" + statusMessage + ")");
 			producer.send(statusMessage);
+			statusMessage.acknowledge();
 		} catch (Exception statusException) {
 			logger.log(Level.SEVERE, statusException.getMessage(), statusException);
 		} finally {