This is an automated email from the ASF dual-hosted git repository. hqtran pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/james-project.git
commit 6d918dab317664b9e9faaee0b43d5583811b9ab0 Author: Quan Tran <[email protected]> AuthorDate: Thu Sep 18 11:54:38 2025 +0700 [BUILD] [james-server-distributed-app] Remove unused CassandraRabbitMQAwsS3JmapTestRule --- .../james/CassandraRabbitMQAwsS3JmapTestRule.java | 101 --------------------- 1 file changed, 101 deletions(-) diff --git a/server/apps/distributed-app/src/test/java/org/apache/james/CassandraRabbitMQAwsS3JmapTestRule.java b/server/apps/distributed-app/src/test/java/org/apache/james/CassandraRabbitMQAwsS3JmapTestRule.java deleted file mode 100644 index 21a4b5062d..0000000000 --- a/server/apps/distributed-app/src/test/java/org/apache/james/CassandraRabbitMQAwsS3JmapTestRule.java +++ /dev/null @@ -1,101 +0,0 @@ -/**************************************************************** - * Licensed to the Apache Software Foundation (ASF) under one * - * or more contributor license agreements. See the NOTICE file * - * distributed with this work for additional information * - * regarding copyright ownership. The ASF licenses this file * - * to you under the Apache License, Version 2.0 (the * - * "License"); you may not use this file except in compliance * - * with the License. You may obtain a copy of the License at * - * * - * http://www.apache.org/licenses/LICENSE-2.0 * - * * - * Unless required by applicable law or agreed to in writing, * - * software distributed under the License is distributed on an * - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY * - * KIND, either express or implied. See the License for the * - * specific language governing permissions and limitations * - * under the License. * - ****************************************************************/ - -package org.apache.james; - -import java.io.IOException; - -import org.apache.james.backends.rabbitmq.DockerRabbitMQSingleton; -import org.apache.james.modules.TestJMAPServerModule; -import org.apache.james.modules.TestRabbitMQModule; -import org.apache.james.modules.blobstore.BlobStoreConfiguration; -import org.apache.james.modules.objectstorage.aws.s3.DockerAwsS3TestRule; -import org.apache.james.webadmin.WebAdminConfiguration; -import org.junit.rules.TemporaryFolder; -import org.junit.rules.TestRule; -import org.junit.runner.Description; -import org.junit.runners.model.Statement; - -import com.google.inject.Module; - -public class CassandraRabbitMQAwsS3JmapTestRule implements TestRule { - - public static final int TWO_SECONDS = 2000; - private final TemporaryFolder temporaryFolder; - - public static CassandraRabbitMQAwsS3JmapTestRule defaultTestRule() { - return new CassandraRabbitMQAwsS3JmapTestRule(); - } - - private final GuiceModuleTestRule guiceModuleTestRule; - private final DockerOpenSearchRule dockerOpenSearchRule; - - public CassandraRabbitMQAwsS3JmapTestRule(GuiceModuleTestRule... guiceModuleTestRule) { - TempFilesystemTestRule tempFilesystemTestRule = new TempFilesystemTestRule(); - this.dockerOpenSearchRule = new DockerOpenSearchRule(); - this.temporaryFolder = tempFilesystemTestRule.getTemporaryFolder(); - this.guiceModuleTestRule = - AggregateGuiceModuleTestRule - .of(guiceModuleTestRule) - .aggregate(dockerOpenSearchRule) - .aggregate(tempFilesystemTestRule); - } - - public GuiceJamesServer jmapServer(Module... additionals) throws IOException { - CassandraRabbitMQJamesConfiguration configuration = CassandraRabbitMQJamesConfiguration.builder() - .workingDirectory(temporaryFolder.newFolder()) - .configurationFromClasspath() - .blobStore(BlobStoreConfiguration.builder() - .s3() - .disableCache() - .deduplication() - .noCryptoConfig()) - .searchConfiguration(SearchConfiguration.openSearch()) - .build(); - - return CassandraRabbitMQJamesServerMain.createServer(configuration) - .overrideWith(new TestRabbitMQModule(DockerRabbitMQSingleton.SINGLETON)) - .overrideWith(new DockerAwsS3TestRule().getModule()) - .overrideWith(new TestJMAPServerModule()) - .overrideWith(guiceModuleTestRule.getModule()) - .overrideWith((binder -> binder.bind(CleanupTasksPerformer.class).asEagerSingleton())) - .overrideWith(binder -> binder.bind(WebAdminConfiguration.class).toInstance(WebAdminConfiguration.TEST_CONFIGURATION)) - .overrideWith(additionals); - } - - @Override - public Statement apply(Statement base, Description description) { - return guiceModuleTestRule.apply(base, description); - } - - public void await() { - awaitProcessingStart(); - guiceModuleTestRule.await(); - } - - private void awaitProcessingStart() { - // As the RabbitMQEventBus is asynchronous we have otherwise no guaranties that the processing to be awaiting for did start - try { - Thread.sleep(TWO_SECONDS); - } catch (InterruptedException e) { - throw new RuntimeException(e); - } - } -} - --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
