DefaultMessageSender.java 文件源码

private void lockAndRun(InternalMessage message, Member destination, int retry) {
    try {
        RemoteEndpoint.Basic basic = destination.getSession().getBasicRemote();
        synchronized (destination) {
            basic.sendObject(message.transformToExternalMessage());
        }
    } catch (Exception e) {
        if (retry >= 0) {
            log.warn("Retrying... " + message.transformToExternalMessage());
            send(message, --retry);
        }
        log.error("Unable to send message: " + message.transformToExternalMessage() + " error during sending!");
        throw new RuntimeException("Unable to send message: " + message.transformToExternalMessage(), e);
    }
}