Вызов функций на основе результата другой функции (Кафка)

Question

У меня есть функции A, B & C. Когда я вызываю функцию A (), она отправляет уведомление kafka, и когда уведомление обрабатывается и ответ отправляется обратно, мне нужно вызвать функцию B (), и сноваотправьте уведомление kafka и так далее, а затем, как только он будет обработан, нам нужно вызвать C ().

Есть ли способ реализовать это, кроме вызова B () в ответе дескриптора A ()?

Например:

Sub Project Service has 
Class TestService
{
    function A()
     {
        Call Kafka Producer From SubProject KafkaProducer()
     }

function B()
     {
          Call Kafka Producer From SubProject KafkaProducer()
     }

}


Sub Project "KafkaService" has 
Class KafkaSvc
{
    @KafkaListener
    Process KafkaMessage()
    {
       Process Kafka Message and send back result to ReceivedResult.

    }
}


Sub Project "ReceivedResult" has

Class KafkaReceive
{

    @KafkaListener
    process KafkaMessageReceived()
    {
       Once it's processed here, B() has to be triggered
    }
}