[prev in list] [next in list] [prev in thread] [next in thread] 

List:       james-dev
Subject:    [4/6] james-project git commit: MAILBOX-297 Remove concurrent support for James chunker
From:       btellier () apache ! org
Date:       2017-05-29 10:14:21
Message-ID: 537a0966c1b44d3db4c252ae3633d5aa () git ! apache ! org
[Download RAW message or body]

MAILBOX-297 Remove concurrent support for James chunker


Project: http://git-wip-us.apache.org/repos/asf/james-project/repo
Commit: http://git-wip-us.apache.org/repos/asf/james-project/commit/32fa0542
Tree: http://git-wip-us.apache.org/repos/asf/james-project/tree/32fa0542
Diff: http://git-wip-us.apache.org/repos/asf/james-project/diff/32fa0542

Branch: refs/heads/master
Commit: 32fa054267b26b450d1946bb5b932dfc8f992a0f
Parents: e82c858
Author: benwa <btellier@linagora.com>
Authored: Wed May 24 15:16:41 2017 +0700
Committer: benwa <btellier@linagora.com>
Committed: Mon May 29 17:02:50 2017 +0700

----------------------------------------------------------------------
 .../java/org/apache/james/util/streams/JamesCollectors.java     | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/james-project/blob/32fa0542/server/container/util-java8/src/main/java/org/apache/james/util/streams/JamesCollectors.java
                
----------------------------------------------------------------------
diff --git a/server/container/util-java8/src/main/java/org/apache/james/util/streams/JamesCollectors.java \
b/server/container/util-java8/src/main/java/org/apache/james/util/streams/JamesCollectors.java
 index adfac75..e705063 100644
--- a/server/container/util-java8/src/main/java/org/apache/james/util/streams/JamesCollectors.java
                
+++ b/server/container/util-java8/src/main/java/org/apache/james/util/streams/JamesCollectors.java
 @@ -33,7 +33,6 @@ import com.google.common.base.Preconditions;
 import com.google.common.collect.ArrayListMultimap;
 import com.google.common.collect.ImmutableSet;
 import com.google.common.collect.Multimap;
-import com.google.common.collect.Multimaps;
 
 public class JamesCollectors {
     public static <D> Collector<D, ?, Stream<Collection<D>>> chunker(int chunkSize) \
{ @@ -52,7 +51,7 @@ public class JamesCollectors {
 
         @Override
         public Supplier<Multimap<Integer, D>> supplier() {
-            return () -> \
Multimaps.synchronizedListMultimap(ArrayListMultimap.<Integer, D>create()); +         \
return ArrayListMultimap::create;  }
 
         @Override
@@ -75,7 +74,7 @@ public class JamesCollectors {
 
         @Override
         public Set<Characteristics> characteristics() {
-            return ImmutableSet.of(Characteristics.CONCURRENT);
+            return ImmutableSet.of();
         }
     }
 }


---------------------------------------------------------------------
To unsubscribe, e-mail: server-dev-unsubscribe@james.apache.org
For additional commands, e-mail: server-dev-help@james.apache.org


[prev in list] [next in list] [prev in thread] [next in thread]