Skip to content

Commit

Permalink
fix: Added object mapper bean to fix issue with spring cloud stream 4…
Browse files Browse the repository at this point in the history
….1.3 failing to deserialize objects (spring-cloud/spring-cloud-stream#2977) causing pubsub steam dead letter test to fail
  • Loading branch information
ldetmer committed Aug 21, 2024
1 parent 20b3393 commit 125299a
Showing 1 changed file with 8 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -16,12 +16,15 @@

package com.example;

import com.fasterxml.jackson.databind.ObjectMapper;
import com.google.cloud.pubsub.v1.Subscriber;
import com.google.cloud.spring.pubsub.support.BasicAcknowledgeablePubsubMessage;
import com.google.cloud.spring.pubsub.support.GcpPubSubHeaders;
import java.util.function.Consumer;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.cloud.function.context.config.JsonMessageConverter;
import org.springframework.cloud.function.json.JacksonMapper;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.messaging.Message;
Expand Down Expand Up @@ -63,4 +66,9 @@ public Consumer<UserMessage> deadLetterMessages() {
userMessage.getUsername(),
userMessage.getBody());
}

@Bean
public JsonMessageConverter customJsonMessageConverter(ObjectMapper objectMapper) {
return new JsonMessageConverter(new JacksonMapper(objectMapper));
}
}

0 comments on commit 125299a

Please sign in to comment.