public abstract class AbstractJavaTypeMapper
extends java.lang.Object
implements org.springframework.beans.factory.BeanClassLoaderAware
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 and Description |
---|
AbstractJavaTypeMapper() |
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) |
public static final java.lang.String DEFAULT_CLASSID_FIELD_NAME
public static final java.lang.String DEFAULT_CONTENT_CLASSID_FIELD_NAME
public static final java.lang.String DEFAULT_KEY_CLASSID_FIELD_NAME
public java.lang.String getClassIdFieldName()
public java.lang.String getContentClassIdFieldName()
public java.lang.String getKeyClassIdFieldName()
public void setIdClassMapping(java.util.Map<java.lang.String,java.lang.Class<?>> idClassMapping)
public void setBeanClassLoader(java.lang.ClassLoader classLoader)
setBeanClassLoader
in interface org.springframework.beans.factory.BeanClassLoaderAware
protected java.lang.ClassLoader getClassLoader()
protected void addHeader(org.apache.kafka.common.header.Headers headers, java.lang.String headerName, java.lang.Class<?> clazz)
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)
public java.util.Map<java.lang.String,java.lang.Class<?>> getIdClassMapping()