diff --git a/spring-integration-core/src/main/java/org/springframework/integration/handler/MethodInvokingMessageProcessor.java b/spring-integration-core/src/main/java/org/springframework/integration/handler/MethodInvokingMessageProcessor.java index 00f8365a06..a202327e7e 100644 --- a/spring-integration-core/src/main/java/org/springframework/integration/handler/MethodInvokingMessageProcessor.java +++ b/spring-integration-core/src/main/java/org/springframework/integration/handler/MethodInvokingMessageProcessor.java @@ -434,15 +434,9 @@ public class MethodInvokingMessageProcessor extends AbstractMessageProcessor { } Assert.notNull(headerName, "Cannot determine header name. Possible reasons: -debug is " + "disabled or header name is not explicitly provided via @Header annotation."); - if (headerName.startsWith("$")) { - // rely on access to getSomeValue for $someValue - headerName = headerName.substring(1); - } String headerExpression = "headers." + headerName + relativeExpression; - if (headerAnnotation.required()) { - return headerExpression; - } - return "headers['" + headerName + "'] != null ? " + headerExpression + " : null"; + return (headerAnnotation.required()) ? headerExpression + : "headers['" + headerName + "'] != null ? " + headerExpression + " : null"; } private synchronized void setExclusiveTargetParameterType(Class targetParameterType) {