Ниже мой слушатель сообщений, который слушает 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());
}
}