Skip to content

Commit

Permalink
Merge pull request #4008 from eclipse/fix-service_client_ack_mode
Browse files Browse the repository at this point in the history
:fix: Fix service client ack mode
  • Loading branch information
Coduz authored Apr 3, 2024
2 parents b6a93ca + 52d50b0 commit 21d4941
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);
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 21d4941

Please sign in to comment.