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 {