public class SimpleToAvroTransformer extends AbstractTransformer
SpecificRecord objects.EXPRESSION_PARSER, logger| Constructor and Description |
|---|
SimpleToAvroTransformer() |
| Modifier and Type | Method and Description |
|---|---|
protected Object |
doTransform(Message<?> message)
Subclasses must implement this method to provide the transformation
logic.
|
protected void |
onInit()
Subclasses may implement this for initialization logic.
|
void |
setTypeExpression(Expression expression)
Set the expression to evaluate against the message to determine the value
for the
AvroHeaders.TYPE header. |
void |
setTypeExpressionString(String expression)
Set the expression to evaluate against the message to determine the value
for the
AvroHeaders.TYPE header. |
SimpleToAvroTransformer |
typeExpression(Expression expression)
Set the expression to evaluate against the message to determine the value
for the
AvroHeaders.TYPE header. |
SimpleToAvroTransformer |
typeExpression(String expression)
Set the expression to evaluate against the message to determine the value
for the
AvroHeaders.TYPE header. |
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 SimpleToAvroTransformer typeExpression(Expression expression)
AvroHeaders.TYPE header.expression - the expression.public SimpleToAvroTransformer typeExpression(String expression)
AvroHeaders.TYPE header.expression - the expression.public void setTypeExpression(Expression expression)
AvroHeaders.TYPE header.expression - the expression.public void setTypeExpressionString(String expression)
AvroHeaders.TYPE header.expression - the expression.protected void onInit()
IntegrationObjectSupportonInit in class IntegrationObjectSupportprotected Object doTransform(Message<?> message)
AbstractTransformerdoTransform in class AbstractTransformermessage - The message.