AudioConnectClient.java 文件源码

private void finishHandshake(ChannelHandlerContext ctx, FullHttpResponse response) {
    if (response.getStatus().equals(HttpResponseStatus.SWITCHING_PROTOCOLS)) {
        try {
            handshaker.finishHandshake(ctx.channel(), response);
            connection.handshakeFuture.setSuccess();

            logger.info("Successfully connected to AudioConnect server!");
            return;
        } catch (Exception e) {
            connection.handshakeFuture.setFailure(e);
        }
    } else {
        connection.handshakeFuture.setFailure(new InvalidConfigurationException());
    }

    String responseMsg = response.content().toString(StandardCharsets.UTF_8);
    logger.severe("Failed to Connect with AudioConnect server: " + responseMsg);
    logger.severe("Stopping client event loop due to failure to establish connection with AudioConnect server");

    disconnect();
}