AbstractInvocationStrategy.java 文件源码

public void send(Throwable error, Object value) {
    if( responded.compareAndSet(false, true) ) {
        Class resultType = getResultType(method);
        try {
            serializationStrategy.encodeResponse(loader, resultType, value, error, responseStream);
        } catch (Exception e) {
            // we failed to encode the response.. reposition and write that error.
            try {
                responseStream.position(pos);
                serializationStrategy.encodeResponse(loader, resultType, value, new ServiceException(e.toString()), responseStream);
            } catch (Exception unexpected) {
                LOGGER.error("Error while servicing "+method,unexpected);
            }
        } finally {
            onComplete.run();
        }
    }
}