You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@james.apache.org by bt...@apache.org on 2023/08/24 08:15:27 UTC
[james-project] 05/05: Fix SessionWithInitializedTablesFactoryTest - updateVersion miss `.block`
This is an automated email from the ASF dual-hosted git repository.
btellier pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/james-project.git
commit b671e3660643e7db8b0989b1e0aa7cb4b8218883
Author: Tung Tran <vt...@linagora.com>
AuthorDate: Mon Aug 21 19:19:56 2023 +0700
Fix SessionWithInitializedTablesFactoryTest - updateVersion miss `.block`
---
.../cassandra/init/SessionWithInitializedTablesFactoryTest.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/backends-common/cassandra/src/test/java/org/apache/james/backends/cassandra/init/SessionWithInitializedTablesFactoryTest.java b/backends-common/cassandra/src/test/java/org/apache/james/backends/cassandra/init/SessionWithInitializedTablesFactoryTest.java
index 50425bfb76..6df654e066 100644
--- a/backends-common/cassandra/src/test/java/org/apache/james/backends/cassandra/init/SessionWithInitializedTablesFactoryTest.java
+++ b/backends-common/cassandra/src/test/java/org/apache/james/backends/cassandra/init/SessionWithInitializedTablesFactoryTest.java
@@ -99,7 +99,7 @@ class SessionWithInitializedTablesFactoryTest {
.isEqualTo(MAX_VERSION);
new CassandraTableManager(MODULE, session).clearTables(t -> true);
- versionManagerDAO(session).updateVersion(MIN_VERSION);
+ versionManagerDAO(session).updateVersion(MIN_VERSION).block();
assertThat(versionManager(session).computeVersion().block())
.isEqualTo(MIN_VERSION);
@@ -114,7 +114,7 @@ class SessionWithInitializedTablesFactoryTest {
.isEqualTo(MAX_VERSION);
new CassandraTableManager(MODULE, session).clearTables(t -> true);
- versionManagerDAO(session).updateVersion(MIN_VERSION);
+ versionManagerDAO(session).updateVersion(MIN_VERSION).block();
assertThat(versionManager(session).computeVersion().block())
.isEqualTo(MIN_VERSION);
session.execute(SchemaBuilder.dropTable(TABLE_NAME).build());
@@ -131,7 +131,7 @@ class SessionWithInitializedTablesFactoryTest {
CqlSession cluster = ClusterFactory.create(clusterConfiguration, keyspaceConfiguration);
KeyspaceFactory.createKeyspace(keyspaceConfiguration, cluster).block();
- return () -> new SessionWithInitializedTablesFactory( cluster, MODULE).get();
+ return () -> new SessionWithInitializedTablesFactory(cluster, MODULE).get();
}
private static void cleanCassandra(CqlSession session) {
---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscribe@james.apache.org
For additional commands, e-mail: notifications-help@james.apache.org