Package com.basho.riak.pbc

Examples of com.basho.riak.pbc.RiakConnectionPool.start()

67
68
69
70
71
72
73
74
75
                                                               hostAddress, conf.getPort(),
                                                               conf.getConnectionWaitTimeoutMillis(),
                                                               conf.getSocketBufferSizeKb(),
                                                               conf.getIdleConnectionTTLMillis());

        pool.start();
        return new PBClientAdapter(new RiakClient(pool));
    }
}
View Full Code Here
64
65
66
67
68
69
70
71
72
73
74
            clusterSemaphore = RiakConnectionPool.getSemaphore(totalMaxConnections);
        }

        for (PBClientConfig node : clusterConfig.getClients()) {
            final RiakConnectionPool hostPool = makePool(clusterSemaphore, node);
            hostPool.start();
            clients.add(new PBClientAdapter(new RiakClient(hostPool)));
        }
        return clients.toArray(new RawClient[clients.size()]);
    }
View Full Code Here
68
69
70
71
72
73
74
75
76
                                                               conf.getConnectionWaitTimeoutMillis(),
                                                               conf.getSocketBufferSizeKb(),
                                                               conf.getIdleConnectionTTLMillis(),
                                                               conf.getRequestTimeoutMillis());

        pool.start();
        return new PBClientAdapter(new RiakClient(pool));
    }
}
View Full Code Here
64
65
66
67
68
69
70
71
72
73
74
            clusterSemaphore = RiakConnectionPool.getSemaphore(totalMaxConnections);
        }

        for (PBClientConfig node : clusterConfig.getClients()) {
            final RiakConnectionPool hostPool = makePool(clusterSemaphore, node);
            hostPool.start();
            clients.add(new PBClientAdapter(new RiakClient(hostPool)));
        }
        return clients.toArray(new RawClient[clients.size()]);
    }
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.