Package org.springframework.kafka.support.converter

Class AbstractJavaTypeMapper

  • All Implemented Interfaces:
    org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanClassLoaderAware
    Direct Known Subclasses:
    DefaultJackson2JavaTypeMapper
    public abstract class AbstractJavaTypeMapper
extends java.lang.Object
implements org.springframework.beans.factory.BeanClassLoaderAware
    Abstract type mapper.
    Since:
    2.1
    Author:
    Mark Pollack, Sam Nelson, Andreas Asplund, Gary Russell, Elliot Kennedy

    • Field Detail

      • DEFAULT_CLASSID_FIELD_NAME

        public static final java.lang.String DEFAULT_CLASSID_FIELD_NAME
        Default header name for type information.
        See Also:
        Constant Field Values

      • DEFAULT_CONTENT_CLASSID_FIELD_NAME

        public static final java.lang.String DEFAULT_CONTENT_CLASSID_FIELD_NAME
        Default header name for container object contents type information.
        See Also:
        Constant Field Values

      • DEFAULT_KEY_CLASSID_FIELD_NAME

        public static final java.lang.String DEFAULT_KEY_CLASSID_FIELD_NAME
        Default header name for map key type information.
        See Also:
        Constant Field Values

      • KEY_DEFAULT_CLASSID_FIELD_NAME

        public static final java.lang.String KEY_DEFAULT_CLASSID_FIELD_NAME
        Default header name for key type information.
        See Also:
        Constant Field Values

      • KEY_DEFAULT_CONTENT_CLASSID_FIELD_NAME

        public static final java.lang.String KEY_DEFAULT_CONTENT_CLASSID_FIELD_NAME
        Default header name for key container object contents type information.
        See Also:
        Constant Field Values

      • KEY_DEFAULT_KEY_CLASSID_FIELD_NAME

        public static final java.lang.String KEY_DEFAULT_KEY_CLASSID_FIELD_NAME
        Default header name for key map key type information.
        See Also:
        Constant Field Values

    • Constructor Detail

      • AbstractJavaTypeMapper

        public AbstractJavaTypeMapper()

    • Method Detail

      • getClassIdFieldName

        public java.lang.String getClassIdFieldName()

      • setClassIdFieldName

        public void setClassIdFieldName​(java.lang.String classIdFieldName)
        Configure header name for type information.
        Parameters:
        classIdFieldName - the header name.
        Since:
        2.1.3

      • getContentClassIdFieldName

        public java.lang.String getContentClassIdFieldName()

      • setContentClassIdFieldName

        public void setContentClassIdFieldName​(java.lang.String contentClassIdFieldName)
        Configure header name for container object contents type information.
        Parameters:
        contentClassIdFieldName - the header name.
        Since:
        2.1.3

      • getKeyClassIdFieldName

        public java.lang.String getKeyClassIdFieldName()

      • setKeyClassIdFieldName

        public void setKeyClassIdFieldName​(java.lang.String keyClassIdFieldName)
        Configure header name for map key type information.
        Parameters:
        keyClassIdFieldName - the header name.
        Since:
        2.1.3

      • setIdClassMapping

        public void setIdClassMapping​(java.util.Map<java.lang.String,​java.lang.Class<?>> idClassMapping)

      • setBeanClassLoader

        public void setBeanClassLoader​(java.lang.ClassLoader classLoader)
        Specified by:
        setBeanClassLoader in interface org.springframework.beans.factory.BeanClassLoaderAware

      • getClassLoader

        protected java.lang.ClassLoader getClassLoader()

      • addHeader

        protected void addHeader​(org.apache.kafka.common.header.Headers headers,
                         java.lang.String headerName,
                         java.lang.Class<?> clazz)

      • retrieveHeader

        protected java.lang.String retrieveHeader​(org.apache.kafka.common.header.Headers headers,
                                          java.lang.String headerName)

      • retrieveHeaderAsString

        protected java.lang.String retrieveHeaderAsString​(org.apache.kafka.common.header.Headers headers,
                                                  java.lang.String headerName)

      • getIdClassMapping

        public java.util.Map<java.lang.String,​java.lang.Class<?>> getIdClassMapping()

      • setUseForKey

        public void setUseForKey​(boolean isKey)
        Configure the TypeMapper to use default key type class.
        Parameters:
        isKey - Use key type headers if true
        Since:
        2.1.3