Examples of DisconnectRequest

com.couchbase.client.core.message.cluster.DisconnectRequest
Disconnects all open buckets. @author Michael Nitschinger @since 1.0
com.mcbans.firestar.mcbans.request.DisconnectRequest

Examples of com.couchbase.client.core.message.cluster.DisconnectRequest

    }


    @Override
    public Observable<Boolean> disconnect() {
        return core
            .<DisconnectResponse>send(new DisconnectRequest())
            .flatMap(new Func1<DisconnectResponse, Observable<Boolean>>() {
                @Override
                public Observable<Boolean> call(DisconnectResponse disconnectResponse) {
                    return sharedEnvironment ? Observable.just(true) : environment.shutdown();
                }

View Full Code Here

Examples of com.couchbase.client.core.message.cluster.DisconnectRequest

    }


    @Override
    public Observable<Boolean> disconnect() {
        return core
            .<DisconnectResponse>send(new DisconnectRequest())
            .flatMap(new Func1<DisconnectResponse, Observable<Boolean>>() {
                @Override
                public Observable<Boolean> call(DisconnectResponse disconnectResponse) {
                    return sharedEnvironment ? Observable.just(true) : environment.shutdown();
                }

View Full Code Here

Examples of com.mcbans.firestar.mcbans.request.DisconnectRequest

    }


    @EventHandler(priority = EventPriority.HIGHEST)
    public void onPlayerQuit(final PlayerQuitEvent event) {
        // send disconnect request
        (new Thread(new DisconnectRequest(plugin, event.getPlayer().getName()))).start();
        
        if (plugin.mcbStaff.contains(event.getPlayer().getName())){
            plugin.mcbStaff.remove(event.getPlayer().getName());
        }
    }

View Full Code Here

TOP

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.