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. |
transform
afterPropertiesSet, 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, toString
public 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()
IntegrationObjectSupport
onInit
in class IntegrationObjectSupport
protected Object doTransform(Message<?> message)
AbstractTransformer
doTransform
in class AbstractTransformer
message
- The message.