dendi-wang/thingsboard
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

updated polling options

Browse Source
This commit is contained in:
volodymyr-babak 2017-02-10 17:25:20 +02:00
parent 3bc3227004
commit c70613fd96
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
dao/src/main/java/org/thingsboard/server/dao/cassandra/CassandraCluster.java
View File

@ -18,6 +18,8 @@ package org.thingsboard.server.dao.cassandra;
import com.datastax.driver.core.Cluster; import com.datastax.driver.core.Cluster;
import com.datastax.driver.core.ConsistencyLevel; import com.datastax.driver.core.ConsistencyLevel;
import com.datastax.driver.core.HostDistance;
import com.datastax.driver.core.PoolingOptions;
import com.datastax.driver.core.ProtocolOptions.Compression; import com.datastax.driver.core.ProtocolOptions.Compression;
import com.datastax.driver.core.Session; import com.datastax.driver.core.Session;
import com.datastax.driver.core.exceptions.NoHostAvailableException; import com.datastax.driver.core.exceptions.NoHostAvailableException;
@ -95,7 +97,10 @@ public class CassandraCluster {
Cluster.Builder builder = Cluster.builder() Cluster.Builder builder = Cluster.builder()
.addContactPointsWithPorts(getContactPoints(url)) .addContactPointsWithPorts(getContactPoints(url))
.withClusterName(clusterName) .withClusterName(clusterName)
.withSocketOptions(socketOpts.getOpts()); .withSocketOptions(socketOpts.getOpts())
.withPoolingOptions(new PoolingOptions()
.setMaxRequestsPerConnection(HostDistance.LOCAL, 32768)
.setMaxRequestsPerConnection(HostDistance.REMOTE, 32768));
builder.withQueryOptions(queryOpts.getOpts()); builder.withQueryOptions(queryOpts.getOpts());
builder.withCompression(StringUtils.isEmpty(compression) ? Compression.NONE : Compression.valueOf(compression.toUpperCase())); builder.withCompression(StringUtils.isEmpty(compression) ? Compression.NONE : Compression.valueOf(compression.toUpperCase()));
if (ssl) { if (ssl) {