Package com.alibaba.cloud.stream.binder.rocketmq.convert

Class RocketMQMessageConverter

java.lang.Object
org.springframework.messaging.converter.AbstractMessageConverter
com.alibaba.cloud.stream.binder.rocketmq.convert.RocketMQMessageConverter
All Implemented Interfaces:
org.springframework.messaging.converter.MessageConverter, org.springframework.messaging.converter.SmartMessageConverter
public class RocketMQMessageConverter extends org.springframework.messaging.converter.AbstractMessageConverter
The default message converter of rocketMq,its bean name is DEFAULT_NAME .
Author:
zkzlx

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    static final String
    DEFAULT_NAME
    if you want to customize a bean, please use the BeanName.

    Fields inherited from class org.springframework.messaging.converter.AbstractMessageConverter

    logger

  • Constructor Summary

    Constructors
    Constructor
    Description
    RocketMQMessageConverter()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    protected Object
    convertFromInternal(org.springframework.messaging.Message<?> message, Class<?> targetClass, Object conversionHint)
    Convert the message payload from serialized form to an Object by RocketMQMessageConverter.
    org.springframework.messaging.converter.CompositeMessageConverter
    getMessageConverter()
     
    void
    setMessageConverter(org.springframework.messaging.converter.CompositeMessageConverter messageConverter)
     
    protected boolean
    supports(Class<?> clazz)
    support all classes.

    Methods inherited from class org.springframework.messaging.converter.AbstractMessageConverter

    addSupportedMimeTypes, canConvertFrom, canConvertTo, convertToInternal, fromMessage, fromMessage, getContentTypeResolver, getDefaultContentType, getMimeType, getSerializedPayloadClass, getSupportedMimeTypes, isStrictContentTypeMatch, setContentTypeResolver, setSerializedPayloadClass, setStrictContentTypeMatch, supportsMimeType, toMessage, toMessage

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Field Details

    • DEFAULT_NAME

      public static final String DEFAULT_NAME
      if you want to customize a bean, please use the BeanName.
      See Also:

  • Constructor Details

    • RocketMQMessageConverter

      public RocketMQMessageConverter()

  • Method Details

    • getMessageConverter

      public org.springframework.messaging.converter.CompositeMessageConverter getMessageConverter()

    • setMessageConverter

      public void setMessageConverter(org.springframework.messaging.converter.CompositeMessageConverter messageConverter)

    • supports

      protected boolean supports(Class<?> clazz)
      support all classes.
      Specified by:
      supports in class org.springframework.messaging.converter.AbstractMessageConverter
      Parameters:
      clazz - classes.
      Returns:
      awayls true.

    • convertFromInternal

      protected Object convertFromInternal(org.springframework.messaging.Message<?> message, Class<?> targetClass, Object conversionHint)
      Convert the message payload from serialized form to an Object by RocketMQMessageConverter.
      Overrides:
      convertFromInternal in class org.springframework.messaging.converter.AbstractMessageConverter
      Parameters:
      message - the input message
      targetClass - the target class for the conversion
      conversionHint - an extra object passed to the MessageConverter, e.g. the associated MethodParameter (may be null}
      Returns:
      the result of the conversion, or null if the converter cannot perform the conversion
      Since:
      4.2