git.gumartinm.name Git - JavaForFun/blob

   1 package de.example.spring.kafka;
   2
   3 import org.springframework.messaging.Message;
   4 import org.springframework.messaging.converter.AbstractMessageConverter;
   5 import org.springframework.util.MimeType;
   6
   7 public class MyCustomMessageConverter extends AbstractMessageConverter {
   8
   9   public MyCustomMessageConverter() {
  10     super(new MimeType("application", "example"));
  11   }
  12
  13   @Override
  14   protected boolean supports(Class<?> clazz) {
  15     return (String.class == clazz);
  16   }
  17
  18   @Override
  19   protected Object convertFromInternal(Message<?> message, Class<?> targetClass, Object conversionHint) {
  20     Object payload = message.getPayload();
  21
  22     logger.info("convertFromInternal, payload: " + payload);
  23
  24         return (payload instanceof String ? payload : new String((byte[]) payload));
  25   }
  26 }