1 parent e35be6d commit adb3bdaCopy full SHA for adb3bda
1 file changed
jms/src/main/java/com/fd/tryout/jms/listener/MyMessageListener.java
@@ -1,20 +1,22 @@
1
package com.fd.tryout.jms.listener;
2
3
+import lombok.extern.slf4j.Slf4j;
4
import org.springframework.jms.annotation.JmsListener;
5
import org.springframework.stereotype.Component;
6
7
import javax.jms.JMSException;
8
import javax.jms.Message;
9
import javax.jms.TextMessage;
10
11
+@Slf4j
12
@Component
13
public class MyMessageListener {
14
15
@JmsListener(destination = "${input.queue}")
16
public void onMessageReceived(final Message message) throws JMSException {
17
if (message instanceof TextMessage) {
18
String text = ((TextMessage) message).getText();
- System.out.println(text);
19
+ log.debug("Message received" + text);
20
}
21
22
0 commit comments