public class SimpleFromAvroTransformer extends AbstractTransformer implements org.springframework.beans.factory.BeanClassLoaderAware
SpecificRecord objects
from byte[].EXPRESSION_PARSER, logger| Constructor and Description |
|---|
SimpleFromAvroTransformer(java.lang.Class<? extends org.apache.avro.specific.SpecificRecord> defaultType)
Construct an instance with the supplied default type to create.
|
| Modifier and Type | Method and Description |
|---|---|
protected java.lang.Object |
doTransform(org.springframework.messaging.Message<?> message)
Subclasses must implement this method to provide the transformation
logic.
|
protected void |
onInit()
Subclasses may implement this for initialization logic.
|
void |
setBeanClassLoader(java.lang.ClassLoader classLoader) |
void |
setTypeExpression(org.springframework.expression.Expression expression)
Set the expression to evaluate against the message to determine the type.
|
void |
setTypeExpressionString(java.lang.String expression)
Set the expression to evaluate against the message to determine the type id.
|
SimpleFromAvroTransformer |
typeExpression(org.springframework.expression.Expression expression)
Set the expression to evaluate against the message to determine the type.
|
SimpleFromAvroTransformer |
typeExpression(java.lang.String expression)
Set the expression to evaluate against the message to determine the type id.
|
transformafterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getComponentType, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toStringpublic SimpleFromAvroTransformer(java.lang.Class<? extends org.apache.avro.specific.SpecificRecord> defaultType)
defaultType - the type.public void setBeanClassLoader(java.lang.ClassLoader classLoader)
setBeanClassLoader in interface org.springframework.beans.factory.BeanClassLoaderAwarepublic SimpleFromAvroTransformer typeExpression(org.springframework.expression.Expression expression)
headers['avro_type'].expression - the expression.public SimpleFromAvroTransformer typeExpression(java.lang.String expression)
headers['avro_type'].expression - the expression.public void setTypeExpression(org.springframework.expression.Expression expression)
headers['avro_type'].expression - the expression.public void setTypeExpressionString(java.lang.String expression)
headers['avro_type'].expression - the expression.protected void onInit()
IntegrationObjectSupportonInit in class IntegrationObjectSupportprotected java.lang.Object doTransform(org.springframework.messaging.Message<?> message)
AbstractTransformerdoTransform in class AbstractTransformermessage - The message.