Skip to content

Commit

Permalink
:fix: set the correct message acknowledge mode for the service client…
Browse files Browse the repository at this point in the history
… session

Signed-off-by: riccardomodanese <riccardo.modanese@eurotech.com>
  • Loading branch information
riccardomodanese committed Apr 3, 2024
1 parent 63bd6a1 commit 52d50b0
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -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);

Check warning on line 51 in client/security/src/main/java/org/eclipse/kapua/client/security/amqpclient/Client.java

View check run for this annotation

Codecov / codecov/patch

client/security/src/main/java/org/eclipse/kapua/client/security/amqpclient/Client.java#L51

Added line #L51 was not covered by tests
logger.info("AMQP client binding request sender to: {}", requestAddress);
logger.info("AMQP client binding message listener to: {}", replyAddress);
consumer = session.createConsumer(session.createQueue(replyAddress));
Expand Down

0 comments on commit 52d50b0

Please sign in to comment.