Уведомление Websocket при отсутствии сообщения в PUBSUB - PullRequest
0 голосов
/ 29 мая 2020

Ниже мой слушатель сообщений, который слушает Redis PUBSUB. Работает нормально. Я должен реализовать функцию таким образом, чтобы, если сообщения не были получены после порогового / указанного времени, я должен был отправить правильное сообщение в веб-сокет (URL-адрес подписки такой же, как канал PUBSUB). Я не вижу никакого способа для этого, так как будет много клиентов, которые подписываются на разные каналы в разное время.

Любая помощь или предложение будут заметны.

public class PubSubListener implements MessageListener {        
    @Autowired
    private SimpMessagingTemplate simpMessagingTemplate ;   

    @Override
    public void onMessage(Message message, byte[] pattern) {
        logger.info(" MESSAGE RECEIVED FROM PUBSUB ");
        simpMessagingTemplate.convertAndSend(new String(pattern), message.toString());
    }
}
...