JAMES-2612 Move & copy batch sizes should be read from the configuration file
Project: http://git-wip-us.apache.org/repos/asf/james-project/repo Commit: http://git-wip-us.apache.org/repos/asf/james-project/commit/48ef09c4 Tree: http://git-wip-us.apache.org/repos/asf/james-project/tree/48ef09c4 Diff: http://git-wip-us.apache.org/repos/asf/james-project/diff/48ef09c4 Branch: refs/heads/master Commit: 48ef09c4092c93fb59a7a0e05e6081705f1a17ad Parents: dbe9c62 Author: Antoine Duprat <adup...@linagora.com> Authored: Wed Nov 28 12:23:00 2018 +0100 Committer: Raphael Ouazana <raphael.ouaz...@linagora.com> Committed: Mon Dec 3 11:16:29 2018 +0100 ---------------------------------------------------------------------- .../apache/james/modules/mailbox/CassandraMailboxModule.java | 2 ++ .../test/java/org/apache/james/CassandraJamesServerTest.java | 6 ++---- 2 files changed, 4 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/james-project/blob/48ef09c4/server/container/guice/cassandra-guice/src/main/java/org/apache/james/modules/mailbox/CassandraMailboxModule.java ---------------------------------------------------------------------- diff --git a/server/container/guice/cassandra-guice/src/main/java/org/apache/james/modules/mailbox/CassandraMailboxModule.java b/server/container/guice/cassandra-guice/src/main/java/org/apache/james/modules/mailbox/CassandraMailboxModule.java index 7668ce8..ca41b79 100644 --- a/server/container/guice/cassandra-guice/src/main/java/org/apache/james/modules/mailbox/CassandraMailboxModule.java +++ b/server/container/guice/cassandra-guice/src/main/java/org/apache/james/modules/mailbox/CassandraMailboxModule.java @@ -200,6 +200,8 @@ public class CassandraMailboxModule extends AbstractModule { cassandraMailboxManager.setQuotaManager(quotaManager); cassandraMailboxManager.setQuotaRootResolver(quotaRootResolver); cassandraMailboxManager.setBatchSizes(batchSizes); + cassandraMailboxManager.setMoveBatchSize(batchSizes); + cassandraMailboxManager.setCopyBatchSize(batchSizes); cassandraMailboxManager.init(); return cassandraMailboxManager; } http://git-wip-us.apache.org/repos/asf/james-project/blob/48ef09c4/server/container/guice/cassandra-guice/src/test/java/org/apache/james/CassandraJamesServerTest.java ---------------------------------------------------------------------- diff --git a/server/container/guice/cassandra-guice/src/test/java/org/apache/james/CassandraJamesServerTest.java b/server/container/guice/cassandra-guice/src/test/java/org/apache/james/CassandraJamesServerTest.java index 7e1dbac..c368cd7 100644 --- a/server/container/guice/cassandra-guice/src/test/java/org/apache/james/CassandraJamesServerTest.java +++ b/server/container/guice/cassandra-guice/src/test/java/org/apache/james/CassandraJamesServerTest.java @@ -46,14 +46,12 @@ class CassandraJamesServerTest implements JamesServerContract { @Test void moveBatchSizeShouldEqualsConfigurationValue(GuiceJamesServer jamesServer) { int moveBatchSize = jamesServer.getProbe(ConfigurationProbe.class).getMoveBatchSize(); - // is 100 in batchsizes.properties configuration file - assertThat(moveBatchSize).isEqualTo(200); + assertThat(moveBatchSize).isEqualTo(100); } @Test void copyBatchSizeShouldEqualsConfigurationValue(GuiceJamesServer jamesServer) { int copyBatchSize = jamesServer.getProbe(ConfigurationProbe.class).getCopyBatchSize(); - // is 100 in batchsizes.properties configuration file - assertThat(copyBatchSize).isEqualTo(200); + assertThat(copyBatchSize).isEqualTo(100); } } --------------------------------------------------------------------- To unsubscribe, e-mail: server-dev-unsubscr...@james.apache.org For additional commands, e-mail: server-dev-h...@james.apache.org
