Zastanawiam się w jaki sposób powinienem zaimplementować metodę , którą mam nadzieję w miarę jasno opisałem... mniej więcej tak to wygląda :)
public void createProduct(int howManyProducts) {
if (!isEnoughInStorage().test(MATERIALS)) { //sprawdzenie warunku
orderProducer.accept("Not enough MATERIALS");
// jezeli brakuje ten producer wysyła na Kafke info.
//I w tym momencie chciałbym przeczekać dopoki inny serwis nie wysle na Kafke potrzebnych materiałów
// i ponownie chciałbym sprawdzić warunek. Problem polega na tym, że dopóki nie wyjdę z tej metody drugi serwis
// nie wyśle mi wiadomości.
} else {
createNewProducts(howManyProducts);
}
}