org.springframework.kafka.support.converter

Class AbstractJavaTypeMapper

java.lang.Object

org.springframework.kafka.support.converter.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

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	DEFAULT_CLASSID_FIELD_NAME Default header name for type information.
static java.lang.String	DEFAULT_CONTENT_CLASSID_FIELD_NAME Default header name for container object contents type information.
static java.lang.String	DEFAULT_KEY_CLASSID_FIELD_NAME Default header name for map key type information.

Constructor Summary

Constructors

Constructor and Description
AbstractJavaTypeMapper()

Method Summary

Modifier and Type	Method and Description
protected void	addHeader(org.apache.kafka.common.header.Headers headers, java.lang.String headerName, java.lang.Class<?> clazz)
java.lang.String	getClassIdFieldName()
protected java.lang.ClassLoader	getClassLoader()
java.lang.String	getContentClassIdFieldName()
java.util.Map<java.lang.String,java.lang.Class<?>>	getIdClassMapping()
java.lang.String	getKeyClassIdFieldName()
protected java.lang.String	retrieveHeader(org.apache.kafka.common.header.Headers headers, java.lang.String headerName)
protected java.lang.String	retrieveHeaderAsString(org.apache.kafka.common.header.Headers headers, java.lang.String headerName)
void	setBeanClassLoader(java.lang.ClassLoader classLoader)
void	setIdClassMapping(java.util.Map<java.lang.String,java.lang.Class<?>> idClassMapping)

Methods inherited from class java.lang.Object

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

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

Constructor Detail

AbstractJavaTypeMapper

public AbstractJavaTypeMapper()

Method Detail

getClassIdFieldName

public java.lang.String getClassIdFieldName()

getContentClassIdFieldName

public java.lang.String getContentClassIdFieldName()

getKeyClassIdFieldName

public java.lang.String getKeyClassIdFieldName()

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()