下面是我的消息侦听器，它侦听redis pubsub。它工作得很好。我必须以这样一种方式实现一个特性：如果在阈值/指定时间之后没有收到消息，那么我必须向websocket发送一条正确的消息（订阅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());
    }
}