Package org.springframework.kafka.support.mapping

Class AbstractJavaTypeMapper

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

  • Field Details

    • DEFAULT_CLASSID_FIELD_NAME

      public static final String DEFAULT_CLASSID_FIELD_NAME
      Default header name for type information.
      See Also:

    • DEFAULT_CONTENT_CLASSID_FIELD_NAME

      public static final String DEFAULT_CONTENT_CLASSID_FIELD_NAME
      Default header name for container object contents type information.
      See Also:

    • DEFAULT_KEY_CLASSID_FIELD_NAME

      public static final String DEFAULT_KEY_CLASSID_FIELD_NAME
      Default header name for map key type information.
      See Also:

    • KEY_DEFAULT_CLASSID_FIELD_NAME

      public static final String KEY_DEFAULT_CLASSID_FIELD_NAME
      Default header name for key type information.
      See Also:

    • KEY_DEFAULT_CONTENT_CLASSID_FIELD_NAME

      public static final String KEY_DEFAULT_CONTENT_CLASSID_FIELD_NAME
      Default header name for key container object contents type information.
      See Also:

    • KEY_DEFAULT_KEY_CLASSID_FIELD_NAME

      public static final String KEY_DEFAULT_KEY_CLASSID_FIELD_NAME
      Default header name for key map key type information.
      See Also:

  • Constructor Details

    • AbstractJavaTypeMapper

      public AbstractJavaTypeMapper()

  • Method Details

    • getClassIdFieldName

      public String getClassIdFieldName()

    • setClassIdFieldName

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

    • getContentClassIdFieldName

      public String getContentClassIdFieldName()

    • setContentClassIdFieldName

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

    • getKeyClassIdFieldName

      public String getKeyClassIdFieldName()

    • setKeyClassIdFieldName

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

    • setIdClassMapping

      public void setIdClassMapping(Map<String,Class<?>> idClassMapping)

    • setBeanClassLoader

      public void setBeanClassLoader(ClassLoader classLoader)
      Specified by:
      setBeanClassLoader in interface BeanClassLoaderAware

    • getClassLoader

      protected ClassLoader getClassLoader()

    • addHeader

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

    • retrieveHeader

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

    • retrieveHeaderAsString

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

    • getIdClassMapping

      public Map<String,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