Repository: james-project Updated Branches: refs/heads/master f0992ccca -> db6dd056c
JAMES-2021 Add pooling options to the cluster builder Project: http://git-wip-us.apache.org/repos/asf/james-project/repo Commit: http://git-wip-us.apache.org/repos/asf/james-project/commit/ee19c2fc Tree: http://git-wip-us.apache.org/repos/asf/james-project/tree/ee19c2fc Diff: http://git-wip-us.apache.org/repos/asf/james-project/diff/ee19c2fc Branch: refs/heads/master Commit: ee19c2fcab54805c757539aaa1ef0be9cfd969f8 Parents: d42bfc8 Author: benwa <[email protected]> Authored: Thu May 11 10:29:14 2017 +0700 Committer: benwa <[email protected]> Committed: Thu May 11 10:29:42 2017 +0700 ---------------------------------------------------------------------- .../org/apache/james/modules/mailbox/CassandraSessionModule.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/james-project/blob/ee19c2fc/server/container/guice/cassandra-guice/src/main/java/org/apache/james/modules/mailbox/CassandraSessionModule.java ---------------------------------------------------------------------- diff --git a/server/container/guice/cassandra-guice/src/main/java/org/apache/james/modules/mailbox/CassandraSessionModule.java b/server/container/guice/cassandra-guice/src/main/java/org/apache/james/modules/mailbox/CassandraSessionModule.java index 7bf535a..ecaca94 100644 --- a/server/container/guice/cassandra-guice/src/main/java/org/apache/james/modules/mailbox/CassandraSessionModule.java +++ b/server/container/guice/cassandra-guice/src/main/java/org/apache/james/modules/mailbox/CassandraSessionModule.java @@ -120,6 +120,7 @@ public class CassandraSessionModule extends AbstractModule { return context -> ClusterWithKeyspaceCreatedFactory .config(ClusterBuilder.builder() .servers(servers) + .poolingOptions(readPoolingOptions(configuration)) .queryLoggerConfiguration(queryLoggerConfiguration) .readTimeoutMillis(configuration.getInt("cassandra.readTimeoutMillis", DEFAULT_READ_TIMEOUT_MILLIS)) .connectTimeoutMillis(configuration.getInt("cassandra.connectTimeoutMillis", DEFAULT_CONNECT_TIMEOUT_MILLIS)) --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
