You are viewing a plain text version of this content. The canonical link for it is here.
Posted to server-dev@james.apache.org by ro...@apache.org on 2018/12/03 10:17:27 UTC
[05/10] james-project git commit: JAMES-2612 MessageBatcher should
give its size
JAMES-2612 MessageBatcher should give its size
Project: http://git-wip-us.apache.org/repos/asf/james-project/repo
Commit: http://git-wip-us.apache.org/repos/asf/james-project/commit/793e5951
Tree: http://git-wip-us.apache.org/repos/asf/james-project/tree/793e5951
Diff: http://git-wip-us.apache.org/repos/asf/james-project/diff/793e5951
Branch: refs/heads/master
Commit: 793e5951c33227bb38cbc551dd71d9e4bba6a3fa
Parents: f713d56
Author: Antoine Duprat <ad...@linagora.com>
Authored: Wed Nov 28 13:58:30 2018 +0100
Committer: Raphael Ouazana <ra...@linagora.com>
Committed: Mon Dec 3 11:16:29 2018 +0100
----------------------------------------------------------------------
.../java/org/apache/james/mailbox/store/MessageBatcher.java | 4 ++++
.../org/apache/james/mailbox/store/MessageBatcherTest.java | 6 ++++++
2 files changed, 10 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/james-project/blob/793e5951/mailbox/store/src/main/java/org/apache/james/mailbox/store/MessageBatcher.java
----------------------------------------------------------------------
diff --git a/mailbox/store/src/main/java/org/apache/james/mailbox/store/MessageBatcher.java b/mailbox/store/src/main/java/org/apache/james/mailbox/store/MessageBatcher.java
index 1848ca2..9f1fdc8 100644
--- a/mailbox/store/src/main/java/org/apache/james/mailbox/store/MessageBatcher.java
+++ b/mailbox/store/src/main/java/org/apache/james/mailbox/store/MessageBatcher.java
@@ -42,6 +42,10 @@ public class MessageBatcher {
this.batchSize = batchSize;
}
+ public int getBatchSize() {
+ return batchSize;
+ }
+
public List<MessageRange> batchMessages(MessageRange set, BatchedOperation batchedOperation) throws MailboxException {
if (batchSize > 0) {
List<MessageRange> movedRanges = new ArrayList<>();
http://git-wip-us.apache.org/repos/asf/james-project/blob/793e5951/mailbox/store/src/test/java/org/apache/james/mailbox/store/MessageBatcherTest.java
----------------------------------------------------------------------
diff --git a/mailbox/store/src/test/java/org/apache/james/mailbox/store/MessageBatcherTest.java b/mailbox/store/src/test/java/org/apache/james/mailbox/store/MessageBatcherTest.java
index 97dade9..1da24d5 100644
--- a/mailbox/store/src/test/java/org/apache/james/mailbox/store/MessageBatcherTest.java
+++ b/mailbox/store/src/test/java/org/apache/james/mailbox/store/MessageBatcherTest.java
@@ -66,4 +66,10 @@ public class MessageBatcherTest {
new MessageBatcher(-1);
}
+ @Test
+ public void getBatchSizeShouldReturnTheBatchSize() {
+ int batchSize = 123;
+ MessageBatcher messageBatcher = new MessageBatcher(batchSize);
+ assertThat(messageBatcher.getBatchSize()).isEqualTo(batchSize);
+ }
}
---------------------------------------------------------------------
To unsubscribe, e-mail: server-dev-unsubscribe@james.apache.org
For additional commands, e-mail: server-dev-help@james.apache.org