INT-1627 renamed 'ExpressionPayloadMessageProcessor' to 'ExpressionCommandMessageProcessor'
This commit is contained in:
@@ -15,7 +15,7 @@ package org.springframework.integration.config;
|
||||
|
||||
import org.springframework.expression.BeanResolver;
|
||||
import org.springframework.integration.core.MessageHandler;
|
||||
import org.springframework.integration.handler.ExpressionPayloadMessageProcessor;
|
||||
import org.springframework.integration.handler.ExpressionCommandMessageProcessor;
|
||||
import org.springframework.integration.handler.ServiceActivatingHandler;
|
||||
|
||||
/**
|
||||
@@ -30,10 +30,10 @@ public class ExpressionControlBusFactoryBean extends AbstractSimpleMessageHandle
|
||||
|
||||
private volatile BeanResolver beanResolver;
|
||||
|
||||
private final ExpressionPayloadMessageProcessor processor;
|
||||
private final ExpressionCommandMessageProcessor processor;
|
||||
|
||||
|
||||
public ExpressionControlBusFactoryBean(ExpressionPayloadMessageProcessor processor) {
|
||||
public ExpressionControlBusFactoryBean(ExpressionCommandMessageProcessor processor) {
|
||||
this.processor = processor;
|
||||
}
|
||||
|
||||
|
||||
@@ -31,7 +31,7 @@ public class ControlBusParser extends AbstractConsumerEndpointParser {
|
||||
BeanDefinitionBuilder builder = BeanDefinitionBuilder.genericBeanDefinition(
|
||||
"org.springframework.integration.config.ExpressionControlBusFactoryBean");
|
||||
builder.addConstructorArgValue(new RootBeanDefinition(
|
||||
"org.springframework.integration.handler.ExpressionPayloadMessageProcessor"));
|
||||
"org.springframework.integration.handler.ExpressionCommandMessageProcessor"));
|
||||
IntegrationNamespaceUtils.setReferenceIfAttributeDefined(builder, element, "bean-resolver");
|
||||
IntegrationNamespaceUtils.setValueIfAttributeDefined(builder, element, "send-timeout");
|
||||
IntegrationNamespaceUtils.setValueIfAttributeDefined(builder, element, "order");
|
||||
|
||||
@@ -24,10 +24,10 @@ import org.springframework.integration.Message;
|
||||
* @author Mark Fisher
|
||||
* @since 2.0
|
||||
*/
|
||||
public class ExpressionPayloadMessageProcessor extends AbstractMessageProcessor<Object> {
|
||||
public class ExpressionCommandMessageProcessor extends AbstractMessageProcessor<Object> {
|
||||
|
||||
/**
|
||||
* Evaluates the Message payload expression.
|
||||
* Evaluates the Message payload expression as a command.
|
||||
* @throws IllegalArgumentException if the payload is not an Exception or String
|
||||
*/
|
||||
public Object processMessage(Message<?> message) {
|
||||
Reference in New Issue
Block a user