diff --git a/spring-integration-core/src/main/java/org/springframework/integration/json/JsonInboundMessageMapper.java b/spring-integration-core/src/main/java/org/springframework/integration/json/JsonInboundMessageMapper.java index 30aa010da1..eeef944078 100644 --- a/spring-integration-core/src/main/java/org/springframework/integration/json/JsonInboundMessageMapper.java +++ b/spring-integration-core/src/main/java/org/springframework/integration/json/JsonInboundMessageMapper.java @@ -19,7 +19,6 @@ package org.springframework.integration.json; import java.util.HashMap; import java.util.LinkedHashMap; import java.util.Map; -import java.util.UUID; import org.codehaus.jackson.JsonFactory; import org.codehaus.jackson.JsonParser; @@ -29,6 +28,7 @@ import org.codehaus.jackson.map.ObjectMapper; import org.codehaus.jackson.map.type.TypeFactory; import org.codehaus.jackson.type.JavaType; import org.codehaus.jackson.type.TypeReference; + import org.springframework.integration.Message; import org.springframework.integration.MessageHeaders; import org.springframework.integration.mapping.InboundMessageMapper; @@ -39,6 +39,7 @@ import org.springframework.util.Assert; * {@link InboundMessageMapper} implementation that maps incoming JSON messages to a {@link Message} with the specified payload type. * * @author Jeremy Grelle + * @author Oleg Zhurakousky * @since 2.0 */ public class JsonInboundMessageMapper implements InboundMessageMapper { @@ -49,12 +50,9 @@ public class JsonInboundMessageMapper implements InboundMessageMapper { private static final Map> DEFAULT_HEADER_TYPES = new HashMap>(); static { - DEFAULT_HEADER_TYPES.put(MessageHeaders.ID, UUID.class); - DEFAULT_HEADER_TYPES.put(MessageHeaders.TIMESTAMP, Long.class); DEFAULT_HEADER_TYPES.put(MessageHeaders.EXPIRATION_DATE, Long.class); } - private final JavaType payloadType; private final Map> headerTypes = DEFAULT_HEADER_TYPES;