class WebSocketErrorMessageSender implements ErrorMessageConsumer {

    @Override
    public void consumeMessage(ErrorMessage message) {
        webSocket.convertAndSend(TOPIC_ERROR, PortableErrorMessage.fromMessage(message));
    }

    @Autowired  WebSocketErrorMessageSender(SimpMessagingTemplate webSocket);

}