hostsharing/hs.hsadmin
8
1
Fork 0
Code Pull Requests Activity

client_ack

Browse Source
This commit is contained in:
Peter Hormanns 2023-09-13 19:54:05 +02:00
parent c530a65461
commit 99f33b5b4b
1 changed files with 1 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
qserv/src/main/java/de/hsadmin/core/qserv/QueueServer.java
View File

@ -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 {