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));