From 52d50b038bc8cf198d253c3d117381e50505931e Mon Sep 17 00:00:00 2001 From: riccardomodanese Date: Wed, 3 Apr 2024 14:20:53 +0200 Subject: [PATCH] :fix: set the correct message acknowledge mode for the service client session Signed-off-by: riccardomodanese --- .../org/eclipse/kapua/client/security/amqpclient/Client.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/client/security/src/main/java/org/eclipse/kapua/client/security/amqpclient/Client.java b/client/security/src/main/java/org/eclipse/kapua/client/security/amqpclient/Client.java index 17b00f9c559..cb5c5da1517 100644 --- a/client/security/src/main/java/org/eclipse/kapua/client/security/amqpclient/Client.java +++ b/client/security/src/main/java/org/eclipse/kapua/client/security/amqpclient/Client.java @@ -48,7 +48,7 @@ public Client(String username, String password, String host, int port, String cl connection.setExceptionListener(new JMSExceptionListner(connectionStatus, clientId)); connection.setClientID(clientId); connection.start(); - session = connection.createSession(false, Session.CLIENT_ACKNOWLEDGE); + session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); logger.info("AMQP client binding request sender to: {}", requestAddress); logger.info("AMQP client binding message listener to: {}", replyAddress); consumer = session.createConsumer(session.createQueue(replyAddress));