Package org.apache.bookkeeper.client.QuorumEngine.SubOp

Examples of org.apache.bookkeeper.client.QuorumEngine.SubOp.SubStopOp

136
137
138
139
140
141
142
143
144
145
146
   
    private synchronized void sendStop(){
        try{
            noreception = true;
            LOG.debug("Sending stop signal");
            incomingQueue.put(new ToSend(null, new SubStopOp(new StopOp()), -1));
            LOG.debug("Sent stop signal");
        } catch(InterruptedException e) {
            LOG.fatal("Interrupted while sending stop signal to bookie handle");
        }      
    }
View Full Code Here
136
137
138
139
140
141
142
143
144
145
146
   
    private synchronized void sendStop(){
        try{
            noreception = true;
            LOG.debug("Sending stop signal");
            incomingQueue.put(new ToSend(null, new SubStopOp(new StopOp()), -1));
            LOG.debug("Sent stop signal");
        } catch(InterruptedException e) {
            LOG.fatal("Interrupted while sending stop signal to bookie handle");
        }      
    }
View Full Code Here
TOP

Related Classes of org.apache.bookkeeper.client.QuorumEngine.SubOp.SubStopOp

  • org.apache.bookkeeper.client.BookieHandle
    • 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.