@Bean
public MessageConverter converter() {
    MappingJackson2MessageConverter converter = new MappingJackson2MessageConverter() {



        @Override
        public Message toMessage(Object object, Session session) throws JMSException, MessageConversionException {
            TextMessage message = (TextMessage) super.toMessage(object, session);
            System.out.println("outgoing JSON: " + message.getText());
            return message;
        }

        @Override
        public Object fromMessage(Message message) throws JMSException,MessageConversionException {

            if (message instanceof TextMessage) {
             try{
                 System.out.println("incoming JSON: " +((TextMessage) message).getText());
             }
             catch (JMSException e) {

                 throw new MessageConversionException("Failed to convert JSON message content", e);
             }
            }
            else {
                throw new IllegalArgumentException("This receiver only processes text messages!");

             }
            return super.fromMessage(message);

        }
   };
    converter.setTargetType(MessageType.TEXT);
    converter.setTypeIdPropertyName("_type");
    return converter;
}

@JmsListener(destination = "${input.queue}")
public static void listener(MyMessage myMessage) throws JMSException {
System.out.println("msg: " + myMessage);