james-server-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From adup...@apache.org
Subject [4/4] james-project git commit: JAMES-1945 Solve intelliJ warning in CassandraTableManager
Date Tue, 21 Feb 2017 13:24:36 GMT
JAMES-1945 Solve intelliJ warning in CassandraTableManager


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

Branch: refs/heads/master
Commit: 2b52e39e7c932c6f1b7a388037ac29ddb9898da1
Parents: 322d579
Author: Benoit Tellier <btellier@linagora.com>
Authored: Tue Feb 21 11:51:12 2017 +0700
Committer: Antoine Duprat <aduprat@linagora.com>
Committed: Tue Feb 21 14:23:08 2017 +0100

----------------------------------------------------------------------
 .../james/backends/cassandra/init/CassandraTableManager.java   | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/james-project/blob/2b52e39e/backends-common/cassandra/src/main/java/org/apache/james/backends/cassandra/init/CassandraTableManager.java
----------------------------------------------------------------------
diff --git a/backends-common/cassandra/src/main/java/org/apache/james/backends/cassandra/init/CassandraTableManager.java
b/backends-common/cassandra/src/main/java/org/apache/james/backends/cassandra/init/CassandraTableManager.java
index 862ba69..4dad62d 100644
--- a/backends-common/cassandra/src/main/java/org/apache/james/backends/cassandra/init/CassandraTableManager.java
+++ b/backends-common/cassandra/src/main/java/org/apache/james/backends/cassandra/init/CassandraTableManager.java
@@ -34,15 +34,15 @@ public class CassandraTableManager {
     }
 
     public CassandraTableManager ensureAllTables() {
-        module.moduleTables().stream()
+        module.moduleTables()
             .forEach(table -> session.execute(table.getCreateStatement()));
-        module.moduleIndex().stream()
+        module.moduleIndex()
             .forEach(index -> session.execute(index.getCreateIndexStatement()));
         return this;
     }
 
     public void clearAllTables() {
-        module.moduleTables().stream()
+        module.moduleTables()
             .forEach(table -> clearTable(table.getName()));
     }
 


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


Mime
View raw message