Блокировать утилиту GetMapping для получения сообщения от Redis при загрузке Spring

У меня есть две службы: Служба A и Служба B, использующие Redis для связи между службами.

Служба A с использованием Spring загрузки.

Служба B с использованием expressjs (это похоже на потребителя, потребляет сообщение, а затем публикует сообщение, уведомляющее службу A: «Эй, служба A, я закончил»)

Служба А должна предоставить две конечные точки: /api-publish и /api-consume. Когда пользователь отправляет запрос к конечной точке /api-publish, Служба A должна опубликовать сообщение в теме Redis с именем topic1.

Служба B должна быть настроена на получение сообщений от topic1. После успешной обработки сообщения от topic1 Служба B должна опубликовать сообщение в другой теме Redis с именем topic2.

Все, что я хочу сделать — запросить конечную точку /api-consume в Службе A, служба должна подождать, пока Служба B успешно не опубликует сообщение для topic2. Только тогда Служба А должна вернуть ответ пользователю.

Вот моя конфигурация Redis в сервисе A:

@Configuration
public class RedisConfig {

    @Value("${spring.data.redis.host}")
    private String redisHost;

    @Value("${spring.data.redis.port}")
    private int redisPort;

    @Bean
    public RedisConnectionFactory lettuceConnectionFactory() {
        return new LettuceConnectionFactory(new RedisStandaloneConfiguration(redisHost, redisPort));
    }

    @Bean
    public RedisTemplate<?, ?> redisTemplate() {
        RedisTemplate<?, ?> template = new RedisTemplate<>();
        template.setConnectionFactory(lettuceConnectionFactory());
        template.setHashKeySerializer(new StringRedisSerializer());
        template.setKeySerializer(new StringRedisSerializer());
        template.setHashValueSerializer(new StringRedisSerializer());
        template.setValueSerializer(new StringRedisSerializer());
        return template;
    }

    @Bean
    MessageListenerAdapter messageListener() {
        return new MessageListenerAdapter(new RedisMessageSubscriber());
    }

    @Bean
    ChannelTopic topic() {
        return new ChannelTopic("topic2");
    }

    @Bean
    RedisMessageListenerContainer redisContainer() {
        RedisMessageListenerContainer container
                = new RedisMessageListenerContainer();
        container.setConnectionFactory(lettuceConnectionFactory());
        container.addMessageListener(messageListener(), topic());
        return container;
    }

}

Вот сервис, который получает сообщение из темы 2:

@Service
public class RedisMessageSubscriber implements MessageListener {
    private final BlockingQueue<String> queue = new LinkedBlockingQueue<>();

    @Override
    public void onMessage(Message message, byte[] pattern) {
        String receivedMessage = new String(message.getBody());
        try {
            queue.put(receivedMessage);
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
    }

    public String waitForMessage(long timeout, TimeUnit unit) throws InterruptedException {
        return queue.poll(timeout, unit);
    }
}

Вот простой контроллер:

@RestController
public class TestController {
    @Autowired
    private RedisTemplate<String, Object> template;
    @Autowired
    private RedisMessageSubscriber subscriber;

    @GetMapping("/api/v1/public/test")
    public String test() {
        try {
            String message = subscriber.waitForMessage(5, TimeUnit.SECONDS);
            if (message != null) {
                return "Received message from Service B: " + message;
            } else {
                return "Timeout waiting for message from Service B";
            }
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
            return "Failed to receive message";
        }
    }
}