类com.alibaba.dubbo.rpc.cluster.Merger源码实例Demo

下面列出了怎么用com.alibaba.dubbo.rpc.cluster.Merger的API类实例代码及写法,或者点击链接到github查看源代码。

源代码1 项目: dubbo-2.6.5   文件: MergerFactory.java
public static <T> Merger<T> getMerger(Class<T> returnType) {
    Merger result;
    if (returnType.isArray()) {
        Class type = returnType.getComponentType();
        result = mergerCache.get(type);
        if (result == null) {
            loadMergers();
            result = mergerCache.get(type);
        }
        if (result == null && !type.isPrimitive()) {
            result = ArrayMerger.INSTANCE;
        }
    } else {
        result = mergerCache.get(returnType);
        if (result == null) {
            loadMergers();
            result = mergerCache.get(returnType);
        }
    }
    return result;
}
 
源代码2 项目: dubbox   文件: MergerFactory.java
public static <T> Merger<T> getMerger(Class<T> returnType) {
    Merger result;
    if (returnType.isArray()) {
        Class type = returnType.getComponentType();
        result = mergerCache.get(type);
        if (result == null) {
            loadMergers();
            result = mergerCache.get(type);
        }
        if(result == null && ! type.isPrimitive()) {
            result = ArrayMerger.INSTANCE;
        }
    } else {
        result = mergerCache.get(returnType);
        if (result == null) {
            loadMergers();
            result = mergerCache.get(returnType);
        }
    }
    return result;
}
 
源代码3 项目: dubbox-hystrix   文件: MergerFactory.java
public static <T> Merger<T> getMerger(Class<T> returnType) {
    Merger result;
    if (returnType.isArray()) {
        Class type = returnType.getComponentType();
        result = mergerCache.get(type);
        if (result == null) {
            loadMergers();
            result = mergerCache.get(type);
        }
        if(result == null && ! type.isPrimitive()) {
            result = ArrayMerger.INSTANCE;
        }
    } else {
        result = mergerCache.get(returnType);
        if (result == null) {
            loadMergers();
            result = mergerCache.get(returnType);
        }
    }
    return result;
}
 
源代码4 项目: dubbo3   文件: MergerFactory.java
public static <T> Merger<T> getMerger(Class<T> returnType) {
    Merger result;
    if (returnType.isArray()) {
        Class type = returnType.getComponentType();
        result = mergerCache.get(type);
        if (result == null) {
            loadMergers();
            result = mergerCache.get(type);
        }
        if(result == null && ! type.isPrimitive()) {
            result = ArrayMerger.INSTANCE;
        }
    } else {
        result = mergerCache.get(returnType);
        if (result == null) {
            loadMergers();
            result = mergerCache.get(returnType);
        }
    }
    return result;
}
 
源代码5 项目: dubbox   文件: MergerFactory.java
public static <T> Merger<T> getMerger(Class<T> returnType) {
    Merger result;
    if (returnType.isArray()) {
        Class type = returnType.getComponentType();
        result = mergerCache.get(type);
        if (result == null) {
            loadMergers();
            result = mergerCache.get(type);
        }
        if(result == null && ! type.isPrimitive()) {
            result = ArrayMerger.INSTANCE;
        }
    } else {
        result = mergerCache.get(returnType);
        if (result == null) {
            loadMergers();
            result = mergerCache.get(returnType);
        }
    }
    return result;
}
 
源代码6 项目: dubbox   文件: MergerFactory.java
public static <T> Merger<T> getMerger(Class<T> returnType) {
    Merger result;
    if (returnType.isArray()) {
        Class type = returnType.getComponentType();
        result = mergerCache.get(type);
        if (result == null) {
            loadMergers();
            result = mergerCache.get(type);
        }
        if(result == null && ! type.isPrimitive()) {
            result = ArrayMerger.INSTANCE;
        }
    } else {
        result = mergerCache.get(returnType);
        if (result == null) {
            loadMergers();
            result = mergerCache.get(returnType);
        }
    }
    return result;
}
 
源代码7 项目: dubbo-2.6.5   文件: MergerFactory.java
static void loadMergers() {
    Set<String> names = ExtensionLoader.getExtensionLoader(Merger.class)
            .getSupportedExtensions();
    for (String name : names) {
        Merger m = ExtensionLoader.getExtensionLoader(Merger.class).getExtension(name);
        mergerCache.putIfAbsent(ReflectUtils.getGenericClass(m.getClass()), m);
    }
}
 
源代码8 项目: dubbox   文件: MergerFactory.java
static void loadMergers() {
    Set<String> names = ExtensionLoader.getExtensionLoader(Merger.class)
            .getSupportedExtensions();
    for (String name : names) {
        Merger m = ExtensionLoader.getExtensionLoader(Merger.class).getExtension(name);
        mergerCache.putIfAbsent(ReflectUtils.getGenericClass(m.getClass()), m);
    }
}
 
源代码9 项目: dubbox-hystrix   文件: MergerFactory.java
static void loadMergers() {
    Set<String> names = ExtensionLoader.getExtensionLoader(Merger.class)
            .getSupportedExtensions();
    for (String name : names) {
        Merger m = ExtensionLoader.getExtensionLoader(Merger.class).getExtension(name);
        mergerCache.putIfAbsent(ReflectUtils.getGenericClass(m.getClass()), m);
    }
}
 
源代码10 项目: dubbo3   文件: MergerFactory.java
static void loadMergers() {
    Set<String> names = ExtensionLoader.getExtensionLoader(Merger.class)
            .getSupportedExtensions();
    for (String name : names) {
        Merger m = ExtensionLoader.getExtensionLoader(Merger.class).getExtension(name);
        mergerCache.putIfAbsent(ReflectUtils.getGenericClass(m.getClass()), m);
    }
}
 
源代码11 项目: dubbox   文件: MergerFactory.java
static void loadMergers() {
    Set<String> names = ExtensionLoader.getExtensionLoader(Merger.class)
            .getSupportedExtensions();
    for (String name : names) {
        Merger m = ExtensionLoader.getExtensionLoader(Merger.class).getExtension(name);
        mergerCache.putIfAbsent(ReflectUtils.getGenericClass(m.getClass()), m);
    }
}
 
源代码12 项目: dubbox   文件: MergerFactory.java
static void loadMergers() {
    Set<String> names = ExtensionLoader.getExtensionLoader(Merger.class)
            .getSupportedExtensions();
    for (String name : names) {
        Merger m = ExtensionLoader.getExtensionLoader(Merger.class).getExtension(name);
        mergerCache.putIfAbsent(ReflectUtils.getGenericClass(m.getClass()), m);
    }
}
 
 类所在包
 类方法
 同包方法