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 <[email protected]> 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: [email protected] For additional commands, e-mail: [email protected]
