Skip to content

Instantly share code, notes, and snippets.

@ruwanka
Last active January 10, 2024 06:29
Show Gist options
  • Save ruwanka/03e51dd5b86bff0849338e5692026186 to your computer and use it in GitHub Desktop.
Save ruwanka/03e51dd5b86bff0849338e5692026186 to your computer and use it in GitHub Desktop.
Jms message converter for converting text message to pojo
package com.aptkode;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.jms.support.converter.MessageConversionException;
import org.springframework.jms.support.converter.MessageConverter;
import org.springframework.stereotype.Component;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.Session;
import javax.jms.TextMessage;
@Component
public class StudentMessageConverter implements MessageConverter {
private static final Logger logger = LoggerFactory.getLogger(StudentMessageConverter.class);
private static final ObjectMapper mapper = new ObjectMapper();
@Override
public Message toMessage(Object object, Session session) throws JMSException, MessageConversionException {
return null;
}
@Override
public Object fromMessage(Message message) throws JMSException, MessageConversionException {
TextMessage textMessage = (TextMessage) message;
String payload = textMessage.getText();
Student student = null;
try {
student = mapper.readValue(payload, Student.class);
} catch (Exception e) {
logger.error("error converting to student", e);
}
return student;
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment