diff --git a/org.springframework.integration/src/main/java/org/springframework/integration/message/MethodParameterMessageMapper.java b/org.springframework.integration/src/main/java/org/springframework/integration/message/MethodParameterMessageMapper.java index 4229e0bcd6..1696dbc3df 100644 --- a/org.springframework.integration/src/main/java/org/springframework/integration/message/MethodParameterMessageMapper.java +++ b/org.springframework.integration/src/main/java/org/springframework/integration/message/MethodParameterMessageMapper.java @@ -16,11 +16,11 @@ package org.springframework.integration.message; +import java.lang.annotation.Annotation; import java.lang.reflect.Method; import java.util.HashMap; import java.util.HashSet; import java.util.Iterator; -import java.util.List; import java.util.Map; import java.util.Properties; import java.util.Set; @@ -34,9 +34,7 @@ import org.springframework.integration.annotation.Headers; import org.springframework.integration.core.Message; import org.springframework.integration.core.MessageHeaders; import org.springframework.util.Assert; -import org.springframework.util.CollectionUtils; import org.springframework.util.ObjectUtils; -import org.springframework.util.ReflectionUtils; import org.springframework.util.StringUtils; /** @@ -277,16 +275,7 @@ public class MethodParameterMessageMapper implements InboundMessageMapper annotations = CollectionUtils.arrayToList(annotationArray); + Annotation[] annotations = this.parameter.getParameterAnnotations(); for (Object o : annotations) { if (o instanceof Header) { this._headerAnnotation = (Header) o;