testPriorityQueue
[10, 9, 6, 7, 8, 2, 5, 1, 4, 3]
poll : 10
[9, 8, 6, 7, 3, 2, 5, 1, 4]
peek : 9
[9, 8, 6, 7, 3, 2, 5, 1, 4]

    @Test
    public void testPriorityQueue() {
        System.out.println("testPriorityQueue");
         List<Integer> list =  IntStream.rangeClosed(1, 10).boxed().collect(Collectors.toList());
        
         
         PriorityBlockingQueue<Integer> integerPriorityQueue = new PriorityBlockingQueue<>(list.size(), ( i1,  i2) -> i2.compareTo(i1) );
         integerPriorityQueue.addAll(list);
         
        
        System.out.println(integerPriorityQueue);
        System.out.println("poll : "+integerPriorityQueue.poll());//Удаление
        System.out.println("peek : "+integerPriorityQueue.peek());//Получение 
        System.out.println(integerPriorityQueue);
    }

@Controller
public class WsController {

    @Autowired
    private  MessageSendingOperations<String> messagingTemplate;
    
    @Scheduled(fixedDelay = 1000)
    public void sendQuotes() {
           System.out.println("sendQuotes");
            String destination = "/topic/greetings";
            this.messagingTemplate.convertAndSend(destination, Calendar.getInstance().getTime().toString());
        
    }

@Controller
public class WsController {

    @Autowired
    private  MessageSendingOperations<String> messagingTemplate;
    
    @Scheduled(fixedDelay = 1000)
    public void sendQuotes() {
           System.out.println("sendQuotes");
            String destination = "/topic/greetings";
            this.messagingTemplate.convertAndSend(destination, Calendar.getInstance().getTime().toString());
        
    }

@EnableScheduling
@Component
public class ScheduledTasks {

    private static final SimpleDateFormat dateFormat = new SimpleDateFormat("HH:mm:ss");

    @Scheduled(fixedDelay = 2000)
    public void reportCurrentTime() {
        System.out.println("The time is now " + dateFormat.format(new Date()));
    }
}

@Configuration
@EnableWebSocketMessageBroker
public class StompWebSocketConfig extends AbstractWebSocketMessageBrokerConfigurer {

	@Override
	public void configureMessageBroker(MessageBrokerRegistry config) {
		config.enableSimpleBroker("/topic");
		config.setApplicationDestinationPrefixes("/app");
	}

	@Override
	public void registerStompEndpoints(StompEndpointRegistry registry) {
		registry.addEndpoint("/hello").withSockJS();
	}

    @Override
    public void configureWebSocketTransport(WebSocketTransportRegistration registration) {
        registration.setSendTimeLimit(2*1000).setSendBufferSizeLimit(512 * 1024);
    }
        
        

}

@Controller
public class WsController {
   
    
    @MessageMapping("/hello")
    @SendTo("/topic/greetings")
    public Greeting greeting(HelloMessage message) throws Exception {
        return new Greeting("Hello, " + message.getName() + "!");
    }