this.eventGateway = eventGateway;
}
public Ingredients fetchIngredients(Order order, String processId, TestConfigurationHolder testConfigurationHolder) throws Exception {
TestConfigurationHolder.TEST_CONFIG.set(testConfigurationHolder);
log.info("Fetching ingredients for order [{}] , processId [{}], span [{}]", order, processId, SpanContextHolder.isTracing() ?
<BUG>SpanContextHolder.getCurrentSpan() : "");
</BUG>
CompletableFuture completableFuture = CompletableFuture.supplyAsync(() -> {
TestConfigurationHolder.TEST_CONFIG.set(testConfigurationHolder);
ingredientsCollector.collectIngredients(order, processId).stream()

this.eventGateway = eventGateway;
}
public Ingredients fetchIngredients(Order order, String processId, TestConfigurationHolder testConfigurationHolder) throws Exception {
TestConfigurationHolder.TEST_CONFIG.set(testConfigurationHolder);
log.info("Fetching ingredients for order [{}] , processId [{}], span [{}]", order, processId, SpanContextHolder.isTracing() ?
SpanContextHolder.getCurrentSpan().getTraceId() : "");
CompletableFuture completableFuture = CompletableFuture.supplyAsync(() -> {
TestConfigurationHolder.TEST_CONFIG.set(testConfigurationHolder);
ingredientsCollector.collectIngredients(order, processId).stream()
