import java.net.URI;
import java.util.Arrays;
import java.util.List;

import net.spy.memcached.FailureMode;

import com.couchbase.client.CouchbaseClient;
import com.couchbase.client.CouchbaseConnectionFactory;
import com.couchbase.client.CouchbaseConnectionFactoryBuilder;

public class App {
        public static void main(String[] args) throws Exception {
                // (Subset) of nodes in the cluster to establish a connection
                List<URI> hosts = Arrays
                                .asList(new URI("http://10.4.2.106:8091/pools"));

                // Name of the Bucket to connect to
                String bucket = "default";

                // Password of the bucket (empty) string if none
                String password = "";
                CouchbaseConnectionFactoryBuilder builder = new CouchbaseConnectionFactoryBuilder();
                builder.setFailureMode(FailureMode.Redistribute);
                builder.setReadBufferSize(16384);
                builder.setOpQueueMaxBlockTime(60000);
                builder.setViewTimeout(60000);
                builder.setMaxReconnectDelay(10000);
                builder.setTimeoutExceptionThreshold(10);
                builder.setOpTimeout(50);
                builder.setAuthWaitTime(500);
                CouchbaseClient client = null;
                // Connect to the Cluster
                CouchbaseConnectionFactory connectionFactory;
                try {
                        connectionFactory = builder.buildCouchbaseConnection(hosts, bucket,
                                        "");
                        client = new CouchbaseClient(connectionFactory);
                } catch (Exception e) {

                }

                // Store a Document
                client.set("my-first-document", "Hello Couchbase!").get();

                long start, end;
                int consecutiveFailures = 0;
                while (true) {
                        start = System.currentTimeMillis();
                        try {
                                client.get("my-first-document");
                                end = System.currentTimeMillis();
                                consecutiveFailures = 0;
                                System.out.println("In normal run couchbase takes " + (end - start)
                                                + " milliseconds");
                        } catch (Exception e) {
                                consecutiveFailures++;
                                end = System.currentTimeMillis();
                                System.out.println("Consecutive failures :" + consecutiveFailures);
                                System.out.println("In case of error couchbase takes " + (end - start)+ " milliseconds");
                        }
                }

        }
}