File tree Expand file tree Collapse file tree 1 file changed +3
-2
lines changed
spring-kafka/src/main/java/org/springframework/kafka/support/converter Expand file tree Collapse file tree 1 file changed +3
-2
lines changed Original file line number Diff line number Diff line change 3232import org .springframework .kafka .support .KafkaNull ;
3333import org .springframework .kafka .support .mapping .DefaultJackson2JavaTypeMapper ;
3434import org .springframework .kafka .support .mapping .Jackson2JavaTypeMapper ;
35- import org .springframework .kafka .support .mapping .Jackson2JavaTypeMapper .TypePrecedence ;
3635import org .springframework .messaging .Message ;
3736import org .springframework .messaging .converter .JacksonJsonMessageConverter ;
3837import org .springframework .util .Assert ;
4948 * @deprecated since 4.0 in favor of {@link JacksonJsonMessageConverter} for Jackson 3.
5049 */
5150@ Deprecated (forRemoval = true , since = "4.0" )
51+ @ SuppressWarnings ("removal" )
5252public class JsonMessageConverter extends MessagingMessageConverter {
5353
5454 private static final JavaType OBJECT = TypeFactory .defaultInstance ().constructType (Object .class );
@@ -133,7 +133,8 @@ else if (value instanceof byte[]) {
133133 }
134134
135135 private JavaType determineJavaType (ConsumerRecord <?, ?> record , @ Nullable Type type ) {
136- JavaType javaType = this .typeMapper .getTypePrecedence ().equals (TypePrecedence .INFERRED ) && type != null
136+ JavaType javaType = this .typeMapper .getTypePrecedence ()
137+ .equals (org .springframework .kafka .support .mapping .Jackson2JavaTypeMapper .TypePrecedence .INFERRED ) && type != null
137138 ? TypeFactory .defaultInstance ().constructType (type )
138139 : this .typeMapper .toJavaType (record .headers ());
139140 if (javaType == null ) { // no headers
You can’t perform that action at this time.
0 commit comments