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 2019/10/18 06:40:43 UTC
[james-project] 10/17: JAMES-2813 prevent cassandra cleanup to
happen before countdown latch release
This is an automated email from the ASF dual-hosted git repository.
rouazana pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/james-project.git
commit 0f0b834878c2fb79b5357efd290c0d6ebcb6c8bd
Author: Matthieu Baechler <ma...@apache.org>
AuthorDate: Wed Oct 9 15:22:29 2019 +0200
JAMES-2813 prevent cassandra cleanup to happen before countdown latch release
---
.../task/eventsourcing/distributed/DistributedTaskManagerTest.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/server/task/task-distributed/src/test/java/org/apache/james/task/eventsourcing/distributed/DistributedTaskManagerTest.java b/server/task/task-distributed/src/test/java/org/apache/james/task/eventsourcing/distributed/DistributedTaskManagerTest.java
index 4017965..6774b67 100644
--- a/server/task/task-distributed/src/test/java/org/apache/james/task/eventsourcing/distributed/DistributedTaskManagerTest.java
+++ b/server/task/task-distributed/src/test/java/org/apache/james/task/eventsourcing/distributed/DistributedTaskManagerTest.java
@@ -73,7 +73,6 @@ import org.junit.jupiter.api.extension.RegisterExtension;
import com.github.steveash.guavate.Guavate;
-@ExtendWith(CountDownLatchExtension.class)
class DistributedTaskManagerTest implements TaskManagerContract {
private static class TrackedRabbitMQWorkQueueSupplier implements WorkQueueSupplier {
@@ -127,6 +126,9 @@ class DistributedTaskManagerTest implements TaskManagerContract {
@RegisterExtension
static CassandraEventStoreExtension eventStoreExtension = new CassandraEventStoreExtension(cassandraCluster, MODULES);
+ @RegisterExtension
+ static CountDownLatchExtension countDownLatchExtension = new CountDownLatchExtension();
+
private final CassandraCluster cassandra = cassandraCluster.getCassandraCluster();
private final CassandraTaskExecutionDetailsProjectionDAO cassandraTaskExecutionDetailsProjectionDAO = new CassandraTaskExecutionDetailsProjectionDAO(cassandra.getConf(), cassandra.getTypesProvider(), jsonTaskAdditionalInformationsSerializer);
private final TaskExecutionDetailsProjection executionDetailsProjection = new CassandraTaskExecutionDetailsProjection(cassandraTaskExecutionDetailsProjectionDAO);
---------------------------------------------------------------------
To unsubscribe, e-mail: server-dev-unsubscribe@james.apache.org
For additional commands, e-mail: server-dev-help@james.apache.org