Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Renamed TransformerEndpoint to MessageTransformingConsumer.

Browse Source
This commit is contained in:
Mark Fisher
2008-10-13 14:45:05 +00:00
parent fc2a30d8fd
commit 78ae171dd7
4 changed files with 16 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
org.springframework.integration/src/main/java/org/springframework/integration/config/annotation/TransformerAnnotationPostProcessor.java
View File

@@ -22,7 +22,7 @@ import org.springframework.beans.factory.ListableBeanFactory;
import org.springframework.integration.annotation.Transformer;
import org.springframework.integration.message.MessageConsumer;
import org.springframework.integration.transformer.MethodInvokingTransformer;
import org.springframework.integration.transformer.TransformerEndpoint;
import org.springframework.integration.transformer.MessageTransformingConsumer;
/**
* Post-processor for Methods annotated with {@link Transformer @Transformer}.
@@ -39,7 +39,7 @@ public class TransformerAnnotationPostProcessor extends AbstractMethodAnnotation
@Override
protected MessageConsumer createConsumer(Object bean, Method method, Transformer annotation) {
MethodInvokingTransformer transformer = new MethodInvokingTransformer(bean, method);
return new TransformerEndpoint(transformer);
return new MessageTransformingConsumer(transformer);
}
}

4
org.springframework.integration/src/main/java/org/springframework/integration/config/xml/AbstractTransformerParser.java
View File

@@ -22,7 +22,7 @@ import org.springframework.beans.factory.support.BeanDefinitionBuilder;
import org.springframework.beans.factory.support.BeanDefinitionReaderUtils;
import org.springframework.beans.factory.xml.ParserContext;
import org.springframework.integration.transformer.Transformer;
import org.springframework.integration.transformer.TransformerEndpoint;
import org.springframework.integration.transformer.MessageTransformingConsumer;
/**
* @author Mark Fisher
@@ -31,7 +31,7 @@ public abstract class AbstractTransformerParser extends AbstractConsumerEndpoint
@Override
protected BeanDefinitionBuilder parseConsumer(Element element, ParserContext parserContext) {
BeanDefinitionBuilder builder = BeanDefinitionBuilder.genericBeanDefinition(TransformerEndpoint.class);
BeanDefinitionBuilder builder = BeanDefinitionBuilder.genericBeanDefinition(MessageTransformingConsumer.class);
BeanDefinitionBuilder transformerBuilder =
BeanDefinitionBuilder.genericBeanDefinition(this.getTransformerClass());
this.parseTransformer(element, parserContext, transformerBuilder);

4
org.springframework.integration/src/main/java/org/springframework/integration/config/xml/TransformerParser.java
View File

@@ -21,7 +21,7 @@ import org.w3c.dom.Element;
import org.springframework.beans.factory.support.BeanDefinitionBuilder;
import org.springframework.beans.factory.xml.ParserContext;
import org.springframework.integration.transformer.MethodInvokingTransformer;
import org.springframework.integration.transformer.TransformerEndpoint;
import org.springframework.integration.transformer.MessageTransformingConsumer;
/**
* Parser for the <transformer/> element.
@@ -32,7 +32,7 @@ public class TransformerParser extends AbstractConsumerEndpointParser {
@Override
protected BeanDefinitionBuilder parseConsumer(Element element, ParserContext parserContext) {
BeanDefinitionBuilder builder = BeanDefinitionBuilder.genericBeanDefinition(TransformerEndpoint.class);
BeanDefinitionBuilder builder = BeanDefinitionBuilder.genericBeanDefinition(MessageTransformingConsumer.class);
builder.addConstructorArgReference(this.parseAdapter(element, parserContext, MethodInvokingTransformer.class));
return builder;
}

12
org.springframework.integration/src/main/java/org/springframework/integration/transformer/TransformerEndpoint.java → org.springframework.integration/src/main/java/org/springframework/integration/transformer/MessageTransformingConsumer.java
View File

@@ -21,14 +21,22 @@ import org.springframework.integration.message.Message;
import org.springframework.util.Assert;
/**
* A reply-producing {@link org.springframework.integration.message.MessageConsumer}
* that delegates to a {@link Transformer} instance to modify the received
* {@link Message} and send the result to its output channel.
*
* @author Mark Fisher
*/
public class TransformerEndpoint extends AbstractReplyProducingMessageConsumer {
public class MessageTransformingConsumer extends AbstractReplyProducingMessageConsumer {
private final Transformer transformer;
public TransformerEndpoint(Transformer transformer) {
/**
* Create a {@link MessageTransformingConsumer} instance that delegates to
* the provided {@link Transformer}.
*/
public MessageTransformingConsumer(Transformer transformer) {
Assert.notNull(transformer, "transformer must not be null");
this.transformer = transformer;
}