Search results
Spring JMS Listener Manual/Client Acknowledge Mode
application.yml
spring:
jms:
listener:
session:
acknowledge-mode: client
...
UserSubscriber.java
import jakarta.jms.JMSException;
import jakarta.jms.Message;
// ...
@Component
@RequiredArgsConstructor
@Slf4j
public class UserSubscriber {
public final UserService userService;
@JmsListener(destination = "${users-queue.name}")
public void onNewUserMessage(Message message) {
try {
// Do something with message
// Convert message from JSON or XML to POJO
// Process POJO
message.acknowledge();
} catch (JMSException ex) {
// ...
}
}
}