Skip to content

Commit

Permalink
Properly trace cloud events (#3271)
Browse files Browse the repository at this point in the history
* Properly trace cloud events

* Trying to avoid flaky test on PojoServiceIt

* Revert "Trying to avoid flaky test on PojoServiceIt"

This reverts commit 8a6a38a.

* Try setting test order

* Revert "Try setting test order"

This reverts commit 57e6a5b.
  • Loading branch information
fjtirado authored Nov 6, 2023
1 parent 1807cd5 commit da0919b
Showing 1 changed file with 3 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -52,7 +52,9 @@ public static <T extends DataEvent<?>> JsonPath waitForKogitoProcessInstanceEven

kafkaClient.consume(KOGITO_PROCESSINSTANCES_EVENTS, rawCloudEvent -> {
JsonPath path = new JsonPath(rawCloudEvent);
LOGGER.debug("CLOUD EVENT:\n{}" + path.prettyPrint());
if (LOGGER.isDebugEnabled()) {
LOGGER.debug("CLOUD EVENT: {}", path.prettyPrint());
}
String type = path.get("type");
if (eventType.getSimpleName().equals(type) && predicate.test(path)) {
cloudEvent.set(path);
Expand Down

0 comments on commit da0919b

Please sign in to comment.