Skip to content

Commit

Permalink
fix(document-handling): fixes after Simon comment 2
Browse files Browse the repository at this point in the history
  • Loading branch information
mathias-vandaele committed Dec 16, 2024
1 parent e7ec9c5 commit 8a1e64c
Showing 1 changed file with 5 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down Expand Up @@ -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;

Expand Down Expand Up @@ -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));

Expand Down

0 comments on commit 8a1e64c

Please sign in to comment.