TimeSender.java 文件源码

@Scheduled(fixedRate = 5000)
public void run() {
    String time = LocalTime.now().format(TIME_FORMAT);

    log.info("Time broadcast: {}", time);
    broker.convertAndSend("/topic/greetings", new Greeting("Current time is " + time));
}