diff --git a/apps-integration-tests/integration-tests-jobs-service/integration-tests-jobs-service-quarkus/integration-tests-jobs-service-quarkus-knative-eventing/src/test/java/org/kie/kogito/it/jobs/SwitchStateTimeoutsIT.java b/apps-integration-tests/integration-tests-jobs-service/integration-tests-jobs-service-quarkus/integration-tests-jobs-service-quarkus-knative-eventing/src/test/java/org/kie/kogito/it/jobs/SwitchStateTimeoutsIT.java
index 8d04406264..62ab32d779 100644
--- a/apps-integration-tests/integration-tests-jobs-service/integration-tests-jobs-service-quarkus/integration-tests-jobs-service-quarkus-knative-eventing/src/test/java/org/kie/kogito/it/jobs/SwitchStateTimeoutsIT.java
+++ b/apps-integration-tests/integration-tests-jobs-service/integration-tests-jobs-service-quarkus/integration-tests-jobs-service-quarkus-knative-eventing/src/test/java/org/kie/kogito/it/jobs/SwitchStateTimeoutsIT.java
@@ -49,9 +49,9 @@ protected void verifyNoDecisionEventWasProduced(String processInstanceId) throws
                 .with().pollInterval(1, SECONDS)
                 .untilAsserted(() -> sink.verify(1,
                         postRequestedFor(urlEqualTo("/"))
-                                .withRequestBody(matchingJsonPath("kogitoprocinstanceid", equalTo(processInstanceId)))
-                                .withRequestBody(matchingJsonPath("type", equalTo(PROCESS_RESULT_EVENT_TYPE)))
-                                .withRequestBody(matchingJsonPath("data.decision", equalTo(DECISION_NO_DECISION)))));
+                                .withHeader("ce-kogitoprocinstanceid", equalTo(processInstanceId))
+                                .withHeader("ce-type", equalTo(PROCESS_RESULT_EVENT_TYPE))
+                                .withRequestBody(matchingJsonPath("decision", equalTo(DECISION_NO_DECISION)))));
 
     }