iSharkFly-Docs/java-tutorials
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Updated indentation and refactored code

Browse Source 
Added a a new method receiveMessage() to receive custom converted messages
This commit is contained in:
Kiran 2016-10-09 13:55:01 -04:00 committed by GitHub
parent 94f258f90c
commit 53a353916b
1 changed files with 17 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
spring-jms/src/com/baeldung/spring/jms/SampleListener.java
View File

@ -1,18 +1,26 @@
package com.baeldung.spring.jms;
import java.util.Map;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;
import org.springframework.jms.core.JmsTemplate;
public class SampleListener implements MessageListener {
private String textMessage;
public JmsTemplate getJmsTemplate() {
return getJmsTemplate();
}
public void onMessage(Message message) {
if (message instanceof TextMessage) {
try {
textMessage = ((TextMessage) message).getText();
String msg = ((TextMessage) message).getText();
System.out.println("Message has been consumed : " + msg);
} catch (JMSException ex) {
throw new RuntimeException(ex);
}
@ -20,4 +28,10 @@ public class SampleListener implements MessageListener {
throw new IllegalArgumentException("Message Error");
}
}
}
public Employee receiveMessage() throws JMSException {
Map map = (Map) getJmsTemplate().receiveAndConvert();
Employee employee = new Employee((String) map.get("name"), (Integer) map.get("age"));
return employee;
}
}