diff --git a/spring-eai-core/src/main/java/org/springframework/integration/endpoint/MessageHandlerAdapter.java b/spring-eai-core/src/main/java/org/springframework/integration/endpoint/MessageHandlerAdapter.java index f5c28fd211..692f3a8a64 100644 --- a/spring-eai-core/src/main/java/org/springframework/integration/endpoint/MessageHandlerAdapter.java +++ b/spring-eai-core/src/main/java/org/springframework/integration/endpoint/MessageHandlerAdapter.java @@ -20,6 +20,7 @@ import org.springframework.beans.factory.InitializingBean; import org.springframework.integration.handler.MessageHandler; import org.springframework.integration.message.Message; import org.springframework.integration.message.MessageMapper; +import org.springframework.integration.message.SimplePayloadMessageMapper; import org.springframework.util.Assert; /** @@ -36,7 +37,7 @@ public class MessageHandlerAdapter implements MessageHandler, InitializingBea private String method; - private MessageMapper mapper; + private MessageMapper mapper = new SimplePayloadMessageMapper(); private SimpleMethodInvoker invoker;