diff --git a/build.gradle b/build.gradle index 6d98ac6..75332b3 100644 --- a/build.gradle +++ b/build.gradle @@ -1,5 +1,5 @@ plugins { - id 'org.springframework.boot' version '3.5.11' + id 'org.springframework.boot' version '4.0.3' id 'io.spring.dependency-management' version '1.1.7' id 'java' id "au.com.dius.pact" version "4.6.20" diff --git a/src/main/java/io/pactflow/example/kafka/ProductMessageBuilder.java b/src/main/java/io/pactflow/example/kafka/ProductMessageBuilder.java index b5eb050..2dba71c 100644 --- a/src/main/java/io/pactflow/example/kafka/ProductMessageBuilder.java +++ b/src/main/java/io/pactflow/example/kafka/ProductMessageBuilder.java @@ -1,8 +1,8 @@ package io.pactflow.example.kafka; import org.springframework.messaging.Message; -import com.fasterxml.jackson.core.JsonProcessingException; -import com.fasterxml.jackson.databind.ObjectMapper; +import tools.jackson.core.JacksonException; +import tools.jackson.databind.ObjectMapper; import org.springframework.kafka.support.KafkaHeaders; import org.springframework.messaging.support.MessageBuilder; @@ -15,7 +15,7 @@ public ProductMessageBuilder withProduct(ProductEvent product) { return this; } - public Message build() throws JsonProcessingException { + public Message build() throws JacksonException { return MessageBuilder.withPayload(this.mapper.writeValueAsString(this.product)) .setHeader(KafkaHeaders.TOPIC, "products").setHeader("Content-Type", "application/json; charset=utf-8") .build(); diff --git a/src/main/java/io/pactflow/example/kafka/ProductRepository.java b/src/main/java/io/pactflow/example/kafka/ProductRepository.java index de977f2..4d582f3 100644 --- a/src/main/java/io/pactflow/example/kafka/ProductRepository.java +++ b/src/main/java/io/pactflow/example/kafka/ProductRepository.java @@ -1,6 +1,6 @@ package io.pactflow.example.kafka; -import com.fasterxml.jackson.core.JsonProcessingException; +import tools.jackson.core.JacksonException; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -22,7 +22,7 @@ public void save(final ProductEvent product) { Message message = new ProductMessageBuilder().withProduct(product).build(); this.template.send(message); - } catch (final JsonProcessingException e) { + } catch (final JacksonException e) { logger.error("unable to serialise product to JSON", e); } } diff --git a/src/test/java/io/pactflow/example/kafka/ProductsKafkaProducerTest.java b/src/test/java/io/pactflow/example/kafka/ProductsKafkaProducerTest.java index 2dfd9d2..3331caf 100644 --- a/src/test/java/io/pactflow/example/kafka/ProductsKafkaProducerTest.java +++ b/src/test/java/io/pactflow/example/kafka/ProductsKafkaProducerTest.java @@ -15,7 +15,7 @@ import java.util.HashMap; -import com.fasterxml.jackson.core.JsonProcessingException; +import tools.jackson.core.JacksonException; import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.TestTemplate; @@ -42,7 +42,7 @@ void before(PactVerificationContext context) { } @PactVerifyProvider("a product event update") - public MessageAndMetadata productUpdateEvent() throws JsonProcessingException { + public MessageAndMetadata productUpdateEvent() throws JacksonException { ProductEvent product = new ProductEvent("id1", "product name", "product type", "v1", EventType.UPDATED, 15.00); Message message = new ProductMessageBuilder().withProduct(product).build(); @@ -50,7 +50,7 @@ public MessageAndMetadata productUpdateEvent() throws JsonProcessingException { } @PactVerifyProvider("a product created event") - public MessageAndMetadata productCreatedEvent() throws JsonProcessingException { + public MessageAndMetadata productCreatedEvent() throws JacksonException { ProductEvent product = new ProductEvent("id1", "product name", "product type", "v1", EventType.CREATED, 27.00); Message message = new ProductMessageBuilder().withProduct(product).build();