Package com.yahoo.omid.tso.persistence.LoggerAsyncCallback

Examples of com.yahoo.omid.tso.persistence.LoggerAsyncCallback.LoggerInitCallback


                                        Ids.OPEN_ACL_UNSAFE,
                                        CreateMode.EPHEMERAL,
                                        new LockCreateCallback(),
                                        ctx);
       
        new BookKeeperStateLogger(zk).initialize(new LoggerInitCallback(){
            public void loggerInitComplete(int rc, StateLogger sl, Object ctx){               
                if(rc == Code.OK){
                    if(LOG.isDebugEnabled()){
                        LOG.debug("Logger is ok.");
                    }
View Full Code Here


        //异步触发LockCreateCallback->LedgerIdReadCallback->buildStateFromLedger->LoggerExecutor
        //主线程不阻塞,继续执行下面的代码
        zk.create(LoggerConstants.OMID_LOCK_PATH, new byte[0], Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL,
                new LockCreateCallback(), ctx);

        new BookKeeperStateLogger(zk).initialize(new LoggerInitCallback() {
            public void loggerInitComplete(int rc, StateLogger sl, Object ctx) {
                if (rc == Code.OK) {
                    if (LOG.isDebugEnabled()) {
                        LOG.debug("Logger is ok.");
                    }
View Full Code Here

TOP

Related Classes of com.yahoo.omid.tso.persistence.LoggerAsyncCallback.LoggerInitCallback

Copyright © 2018 www.massapicom. 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.