Class SimpleFromAvroTransformer
java.lang.Object
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.transformer.AbstractTransformer
org.springframework.integration.transformer.SimpleFromAvroTransformer
- All Implemented Interfaces:
org.springframework.beans.factory.Aware,org.springframework.beans.factory.BeanClassLoaderAware,org.springframework.beans.factory.BeanFactoryAware,org.springframework.beans.factory.BeanNameAware,org.springframework.beans.factory.InitializingBean,org.springframework.context.ApplicationContextAware,ExpressionCapable,NamedComponent,GenericTransformer<org.springframework.messaging.Message<?>,org.springframework.messaging.Message<?>>,Transformer
public class SimpleFromAvroTransformer extends AbstractTransformer implements org.springframework.beans.factory.BeanClassLoaderAware
An Apache Avro transformer to create generated
SpecificRecord objects
from byte[].- Since:
- 5.2
-
Field Summary
Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport
EXPRESSION_PARSER, logger -
Constructor Summary
Constructors Constructor Description SimpleFromAvroTransformer(java.lang.Class<? extends org.apache.avro.specific.SpecificRecord> defaultType)Construct an instance with the supplied default type to create. -
Method Summary
Modifier and Type Method Description protected java.lang.ObjectdoTransform(org.springframework.messaging.Message<?> message)Subclasses must implement this method to provide the transformation logic.protected voidonInit()Subclasses may implement this for initialization logic.voidsetBeanClassLoader(java.lang.ClassLoader classLoader)voidsetTypeExpression(org.springframework.expression.Expression expression)Set the expression to evaluate against the message to determine the type.voidsetTypeExpressionString(java.lang.String expression)Set the expression to evaluate against the message to determine the type id.SimpleFromAvroTransformertypeExpression(java.lang.String expression)Set the expression to evaluate against the message to determine the type id.SimpleFromAvroTransformertypeExpression(org.springframework.expression.Expression expression)Set the expression to evaluate against the message to determine the type.Methods inherited from class org.springframework.integration.transformer.AbstractTransformer
transformMethods inherited from class org.springframework.integration.context.IntegrationObjectSupport
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
-
Constructor Details
-
SimpleFromAvroTransformer
public SimpleFromAvroTransformer(java.lang.Class<? extends org.apache.avro.specific.SpecificRecord> defaultType)Construct an instance with the supplied default type to create.- Parameters:
defaultType- the type.
-
-
Method Details
-
setBeanClassLoader
public void setBeanClassLoader(java.lang.ClassLoader classLoader)- Specified by:
setBeanClassLoaderin interfaceorg.springframework.beans.factory.BeanClassLoaderAware
-
typeExpression
public SimpleFromAvroTransformer typeExpression(org.springframework.expression.Expression expression)Set the expression to evaluate against the message to determine the type. Defaultheaders['avro_type'].- Parameters:
expression- the expression.- Returns:
- the transformer
-
typeExpression
Set the expression to evaluate against the message to determine the type id. Defaultheaders['avro_type'].- Parameters:
expression- the expression.- Returns:
- the transformer
-
setTypeExpression
public void setTypeExpression(org.springframework.expression.Expression expression)Set the expression to evaluate against the message to determine the type. Defaultheaders['avro_type'].- Parameters:
expression- the expression.
-
setTypeExpressionString
public void setTypeExpressionString(java.lang.String expression)Set the expression to evaluate against the message to determine the type id. Defaultheaders['avro_type'].- Parameters:
expression- the expression.
-
onInit
protected void onInit()Description copied from class:IntegrationObjectSupportSubclasses may implement this for initialization logic.- Overrides:
onInitin classIntegrationObjectSupport
-
doTransform
protected java.lang.Object doTransform(org.springframework.messaging.Message<?> message)Description copied from class:AbstractTransformerSubclasses must implement this method to provide the transformation logic. If the return value is itself a Message, it will be used as the result. Otherwise, any non-null return value will be used as the payload of the result Message.- Specified by:
doTransformin classAbstractTransformer- Parameters:
message- The message.- Returns:
- The result of the transformation.
-