From 8a1e64ce3a606b52a856372d02a0ea24be75daa7 Mon Sep 17 00:00:00 2001
From: Mathias Vandaele <mathias.vandaele@camunda.com>
Date: Mon, 16 Dec 2024 16:22:01 +0100
Subject: [PATCH] fix(document-handling): fixes after Simon comment 2

---
 .../connector/e2e/RabbitMqInboundStartEventTests.java    | 9 +++++----
 1 file changed, 5 insertions(+), 4 deletions(-)

diff --git a/connectors-e2e-test/connectors-e2e-test-rabbitmq/src/test/java/io/camunda/connector/e2e/RabbitMqInboundStartEventTests.java b/connectors-e2e-test/connectors-e2e-test-rabbitmq/src/test/java/io/camunda/connector/e2e/RabbitMqInboundStartEventTests.java
index 00cbaf2d38..5a60000a93 100644
--- a/connectors-e2e-test/connectors-e2e-test-rabbitmq/src/test/java/io/camunda/connector/e2e/RabbitMqInboundStartEventTests.java
+++ b/connectors-e2e-test/connectors-e2e-test-rabbitmq/src/test/java/io/camunda/connector/e2e/RabbitMqInboundStartEventTests.java
@@ -19,6 +19,7 @@
 import static io.camunda.connector.e2e.BpmnFile.replace;
 import static org.mockito.Mockito.when;
 
+import com.fasterxml.jackson.databind.ObjectMapper;
 import com.rabbitmq.client.Channel;
 import com.rabbitmq.client.Connection;
 import com.rabbitmq.client.ConnectionFactory;
@@ -64,6 +65,7 @@ public class RabbitMqInboundStartEventTests extends BaseRabbitMqTest {
   private static String PORT;
   private static RabbitMQContainer rabbitMQContainer;
   private static ConnectionFactory factory;
+  private final ObjectMapper objectMapper = ConnectorsObjectMapperSupplier.getCopy();
 
   @Autowired ProcessStateStore processStateStore;
 
@@ -131,10 +133,9 @@ public void uriAuthenticationReceiveMessageTest() throws Exception {
 
   private void assertIntermediateCatchEventUsingModel(BpmnModelInstance model) throws Exception {
     Object expectedJsonResponse =
-        ConnectorsObjectMapperSupplier.getCopy()
-            .readValue(
-                "{\"message\":{\"consumerTag\":\"myConsumerTag\",\"body\":{\"foo\": {\"bar\": \"barValue\"}},\"properties\":{}}}",
-                Object.class);
+        this.objectMapper.readValue(
+            "{\"message\":{\"consumerTag\":\"myConsumerTag\",\"body\":{\"foo\": {\"bar\": \"barValue\"}},\"properties\":{}}}",
+            Object.class);
 
     processStateStore.update(mockProcessDefinition(model));