Examples of DisconfStoreProcessor


Examples of com.baidu.disconf.client.store.DisconfStoreProcessor

     * @return
     */
    private static void transformUpdateService(
            Map<DisconfKey, List<IDisconfUpdate>> disconfUpdateServiceInverseIndexMap) {

        DisconfStoreProcessor disconfStoreProcessorFile = DisconfStoreProcessorFactory
                .getDisconfStoreFileProcessor();
        DisconfStoreProcessor disconfStoreProcessorItem = DisconfStoreProcessorFactory
                .getDisconfStoreItemProcessor();

        for (DisconfKey disconfKey : disconfUpdateServiceInverseIndexMap
                .keySet()) {

            //
            //
            //

            try {
                if (disconfKey.getDisConfigTypeEnum().equals(
                        DisConfigTypeEnum.FILE)) {

                    if (!disconfStoreProcessorFile.hasThisConf(disconfKey
                            .getKey())) {
                        throw new Exception();
                    }

                    disconfStoreProcessorFile
                            .addUpdateCallbackList(disconfKey.getKey(),
                                    disconfUpdateServiceInverseIndexMap
                                            .get(disconfKey));

                } else if (disconfKey.getDisConfigTypeEnum().equals(
                        DisConfigTypeEnum.ITEM)) {

                    if (!disconfStoreProcessorItem.hasThisConf(disconfKey
                            .getKey())) {
                        throw new Exception();
                    }

                    disconfStoreProcessorItem
                            .addUpdateCallbackList(disconfKey.getKey(),
                                    disconfUpdateServiceInverseIndexMap
                                            .get(disconfKey));
                }

View Full Code Here

Examples of com.baidu.disconf.client.store.DisconfStoreProcessor

        if (field != null) {

            //
            // 请求仓库配置数据
            //
            DisconfStoreProcessor disconfStoreProcessor = DisconfStoreProcessorFactory
                    .getDisconfStoreFileProcessor();
            Object ret = disconfStoreProcessor.getConfig(
                    disconfFile.filename(), disconfFileItem.name());
            if (ret != null) {
                LOGGER.info("using disconf store value: "
                        + disconfFile.filename() + " ("
                        + disconfFileItem.name() + " , " + ret + ")");
View Full Code Here

Examples of com.baidu.disconf.client.store.DisconfStoreProcessor

            throws Throwable {

        //
        // 请求仓库配置数据
        //
        DisconfStoreProcessor disconfStoreProcessor = DisconfStoreProcessorFactory
                .getDisconfStoreItemProcessor();
        Object ret = disconfStoreProcessor.getConfig(null, disconfItem.key());
        if (ret != null) {
            LOGGER.info("using disconf store value: (" + disconfItem.key()
                    + " , " + ret + ")");
            return ret;
        }
View Full Code Here

Examples of com.baidu.disconf.client.store.DisconfStoreProcessor

     * @return
     */
    private static void transformUpdateService(
            Map<DisconfKey, List<IDisconfUpdate>> disconfUpdateServiceInverseIndexMap) {

        DisconfStoreProcessor disconfStoreProcessorFile = DisconfStoreProcessorFactory
                .getDisconfStoreFileProcessor();
        DisconfStoreProcessor disconfStoreProcessorItem = DisconfStoreProcessorFactory
                .getDisconfStoreItemProcessor();

        for (DisconfKey disconfKey : disconfUpdateServiceInverseIndexMap
                .keySet()) {

            //
            //
            //

            try {
                if (disconfKey.getDisConfigTypeEnum().equals(
                        DisConfigTypeEnum.FILE)) {

                    if (!disconfStoreProcessorFile.hasThisConf(disconfKey
                            .getKey())) {
                        throw new Exception();
                    }

                    disconfStoreProcessorFile
                            .addUpdateCallbackList(disconfKey.getKey(),
                                    disconfUpdateServiceInverseIndexMap
                                            .get(disconfKey));

                } else if (disconfKey.getDisConfigTypeEnum().equals(
                        DisConfigTypeEnum.ITEM)) {

                    if (!disconfStoreProcessorItem.hasThisConf(disconfKey
                            .getKey())) {
                        throw new Exception();
                    }

                    disconfStoreProcessorItem
                            .addUpdateCallbackList(disconfKey.getKey(),
                                    disconfUpdateServiceInverseIndexMap
                                            .get(disconfKey));
                }

View Full Code Here

Examples of com.baidu.disconf.client.store.DisconfStoreProcessor

     * @return
     */
    private static void transformUpdateService(
            Map<DisconfKey, List<IDisconfUpdate>> disconfUpdateServiceInverseIndexMap) {

        DisconfStoreProcessor disconfStoreProcessorFile = DisconfStoreProcessorFactory
                .getDisconfStoreFileProcessor();
        DisconfStoreProcessor disconfStoreProcessorItem = DisconfStoreProcessorFactory
                .getDisconfStoreItemProcessor();

        for (DisconfKey disconfKey : disconfUpdateServiceInverseIndexMap
                .keySet()) {

            //
            //
            //

            try {
                if (disconfKey.getDisConfigTypeEnum().equals(
                        DisConfigTypeEnum.FILE)) {

                    if (!disconfStoreProcessorFile.hasThisConf(disconfKey
                            .getKey())) {
                        throw new Exception();
                    }

                    disconfStoreProcessorFile
                            .addUpdateCallbackList(disconfKey.getKey(),
                                    disconfUpdateServiceInverseIndexMap
                                            .get(disconfKey));

                } else if (disconfKey.getDisConfigTypeEnum().equals(
                        DisConfigTypeEnum.ITEM)) {

                    if (!disconfStoreProcessorItem.hasThisConf(disconfKey
                            .getKey())) {
                        throw new Exception();
                    }

                    disconfStoreProcessorItem
                            .addUpdateCallbackList(disconfKey.getKey(),
                                    disconfUpdateServiceInverseIndexMap
                                            .get(disconfKey));
                }

View Full Code Here

Examples of com.baidu.disconf.client.store.DisconfStoreProcessor

        if (field != null) {

            //
            // 请求仓库配置数据
            //
            DisconfStoreProcessor disconfStoreProcessor = DisconfStoreProcessorFactory
                    .getDisconfStoreFileProcessor();
            Object ret = disconfStoreProcessor.getConfig(
                    disconfFile.filename(), disconfFileItem.name());
            if (ret != null) {
                LOGGER.info("using disconf store value: "
                        + disconfFile.filename() + " ("
                        + disconfFileItem.name() + " , " + ret + ")");
View Full Code Here

Examples of com.baidu.disconf.client.store.DisconfStoreProcessor

            throws Throwable {

        //
        // 请求仓库配置数据
        //
        DisconfStoreProcessor disconfStoreProcessor = DisconfStoreProcessorFactory
                .getDisconfStoreItemProcessor();
        Object ret = disconfStoreProcessor.getConfig(null, disconfItem.key());
        if (ret != null) {
            LOGGER.info("using disconf store value: (" + disconfItem.key()
                    + " , " + ret + ")");
            return ret;
        }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.