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.BeanClassLoaderAwareprotected 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