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.
|
static java.lang.String |
KEY_DEFAULT_CLASSID_FIELD_NAME
Default header name for key type information.
|
static java.lang.String |
KEY_DEFAULT_CONTENT_CLASSID_FIELD_NAME
Default header name for key container object contents type information.
|
static java.lang.String |
KEY_DEFAULT_KEY_CLASSID_FIELD_NAME
Default header name for key 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 |
setClassIdFieldName(java.lang.String classIdFieldName)
Configure header name for type information.
|
void |
setContentClassIdFieldName(java.lang.String contentClassIdFieldName)
Configure header name for container object contents type information.
|
void |
setIdClassMapping(java.util.Map<java.lang.String,java.lang.Class<?>> idClassMapping) |
void |
setKeyClassIdFieldName(java.lang.String keyClassIdFieldName)
Configure header name for map key type information.
|
void |
setUseForKey(boolean isKey)
Configure the TypeMapper to use default key type class.
|
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 static final java.lang.String KEY_DEFAULT_CLASSID_FIELD_NAME
public static final java.lang.String KEY_DEFAULT_CONTENT_CLASSID_FIELD_NAME
public static final java.lang.String KEY_DEFAULT_KEY_CLASSID_FIELD_NAME
public java.lang.String getClassIdFieldName()
public void setClassIdFieldName(java.lang.String classIdFieldName)
classIdFieldName
- the header name.public java.lang.String getContentClassIdFieldName()
public void setContentClassIdFieldName(java.lang.String contentClassIdFieldName)
contentClassIdFieldName
- the header name.public java.lang.String getKeyClassIdFieldName()
public void setKeyClassIdFieldName(java.lang.String keyClassIdFieldName)
keyClassIdFieldName
- the header name.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()
public void setUseForKey(boolean isKey)
isKey
- Use key type headers if true