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 d798b40d2de987aa3aa8f0f88253512f0ff7a55f Author: Gautier DI FOLCO <gdifo...@linagora.com> AuthorDate: Tue Sep 24 12:01:48 2019 +0200 JAMES-2898 Move org.apache.james.backend.rabbitmq to org.apache.james.backends.rabbitmq --- .../{backend => backends}/rabbitmq/Constants.java | 2 +- .../rabbitmq/RabbitMQChannelPool.java | 2 +- .../rabbitmq/RabbitMQConfiguration.java | 2 +- .../rabbitmq/RabbitMQConnectionFactory.java | 2 +- .../rabbitmq/RabbitMQHealthCheck.java | 2 +- .../rabbitmq/RabbitMQManagementAPI.java | 2 +- .../rabbitmq/ReactorRabbitMQChannelPool.java | 2 +- .../rabbitmq/SimpleChannelPool.java | 2 +- .../rabbitmq/SimpleConnectionPool.java | 2 +- .../rabbitmq/ChannelPoolContract.java | 2 +- .../rabbitmq/DockerClusterRabbitMQExtension.java | 2 +- .../rabbitmq/DockerRabbitMQ.java | 4 +-- .../rabbitmq/DockerRabbitMQSingleton.java | 2 +- .../rabbitmq/DockerRabbitMQTestRule.java | 4 +-- .../rabbitmq/InMemoryConsumer.java | 2 +- .../rabbitmq/RabbitMQClusterTest.java | 22 ++++++++-------- .../rabbitmq/RabbitMQConfigurationTest.java | 8 +++--- .../rabbitmq/RabbitMQConnectionFactoryTest.java | 4 +-- .../rabbitmq/RabbitMQExtension.java | 4 +-- .../rabbitmq/RabbitMQFixture.java | 2 +- .../rabbitmq/RabbitMQHealthCheckTest.java | 2 +- .../rabbitmq/RabbitMQTest.java | 30 +++++++++++----------- .../rabbitmq/RabbitMQWaitStrategy.java | 2 +- .../rabbitmq/ReactorRabbitMQChannelPoolTest.java | 4 +-- .../james/mailbox/events/EventDispatcher.java | 4 +-- .../james/mailbox/events/GroupConsumerRetry.java | 6 ++--- .../james/mailbox/events/GroupRegistration.java | 10 ++++---- .../mailbox/events/KeyRegistrationHandler.java | 8 +++--- .../james/mailbox/events/RabbitMQEventBus.java | 4 +-- .../james/mailbox/events/RoutingKeyConverter.java | 2 +- .../james/mailbox/events/RabbitMQEventBusTest.java | 22 ++++++++-------- .../rabbitmq/RabbitMQAuthenticatePlainTest.java | 2 +- .../rabbitmq/RabbitMQAuthenticatedStateTest.java | 2 +- .../rabbitmq/RabbitMQConcurrentSessionsTest.java | 2 +- .../rabbitmq/RabbitMQCondstoreTest.java | 2 +- .../mpt/imapmailbox/rabbitmq/RabbitMQCopyTest.java | 2 +- .../imapmailbox/rabbitmq/RabbitMQEventsTest.java | 2 +- .../rabbitmq/RabbitMQFetchBodySectionTest.java | 2 +- .../rabbitmq/RabbitMQFetchBodyStructureTest.java | 2 +- .../rabbitmq/RabbitMQFetchHeadersTest.java | 2 +- .../imapmailbox/rabbitmq/RabbitMQFetchTest.java | 2 +- .../imapmailbox/rabbitmq/RabbitMQListingTest.java | 2 +- .../rabbitmq/RabbitMQListingWithSharingTest.java | 2 +- .../rabbitmq/RabbitMQMailboxAnnotationTest.java | 2 +- .../RabbitMQMailboxWithLongNameErrorTest.java | 2 +- .../mpt/imapmailbox/rabbitmq/RabbitMQMoveTest.java | 2 +- .../RabbitMQNonAuthenticatedStateTest.java | 2 +- .../rabbitmq/RabbitMQPartialFetchTest.java | 2 +- .../imapmailbox/rabbitmq/RabbitMQQuotaTest.java | 2 +- .../imapmailbox/rabbitmq/RabbitMQRenameTest.java | 2 +- .../imapmailbox/rabbitmq/RabbitMQSearchTest.java | 2 +- .../imapmailbox/rabbitmq/RabbitMQSecurityTest.java | 2 +- .../imapmailbox/rabbitmq/RabbitMQSelectTest.java | 2 +- .../rabbitmq/RabbitMQSelectedInboxTest.java | 2 +- .../rabbitmq/RabbitMQSelectedStateTest.java | 2 +- .../rabbitmq/RabbitMQUidSearchTest.java | 2 +- .../rabbitmq/RabbitMQUserFlagsSupportTest.java | 2 +- .../rabbitmq/host/RabbitMQEventBusHostSystem.java | 4 +-- .../host/RabbitMQEventBusHostSystemRule.java | 2 +- .../CassandraRabbitMQAwsS3SmtpTestRuleFactory.java | 2 +- .../james/CassandraRabbitMQAwsS3JmapTestRule.java | 2 +- .../james/CassandraRabbitMQSwiftJmapTestRule.java | 2 +- .../apache/james/modules/DockerRabbitMQRule.java | 8 +++--- .../apache/james/modules/RabbitMQExtension.java | 2 +- .../apache/james/modules/TestRabbitMQModule.java | 6 ++--- .../james/modules/rabbitmq/RabbitMQModule.java | 8 +++--- .../apache/james/queue/rabbitmq/RabbitClient.java | 12 ++++----- .../rabbitmq/RabbitMQMailQueueManagement.java | 4 +-- .../RabbitMQMailQueueConfigurationChangeTest.java | 2 +- .../queue/rabbitmq/RabbitMQMailQueueTest.java | 4 +-- .../rabbitmq/RabbitMqMailQueueFactoryTest.java | 2 +- .../distributed/RabbitMQTerminationSubscriber.java | 4 +-- .../distributed/RabbitMQWorkQueue.java | 4 +-- .../distributed/RabbitMQWorkQueueSupplier.scala | 3 ++- .../distributed/DistributedTaskManagerTest.java | 2 +- .../RabbitMQTerminationSubscriberTest.java | 2 +- .../distributed/RabbitMQWorkQueueTest.java | 2 +- 77 files changed, 148 insertions(+), 149 deletions(-) diff --git a/backends-common/rabbitmq/src/main/java/org/apache/james/backend/rabbitmq/Constants.java b/backends-common/rabbitmq/src/main/java/org/apache/james/backends/rabbitmq/Constants.java similarity index 97% rename from backends-common/rabbitmq/src/main/java/org/apache/james/backend/rabbitmq/Constants.java rename to backends-common/rabbitmq/src/main/java/org/apache/james/backends/rabbitmq/Constants.java index e6cea0f..89455c0 100644 --- a/backends-common/rabbitmq/src/main/java/org/apache/james/backend/rabbitmq/Constants.java +++ b/backends-common/rabbitmq/src/main/java/org/apache/james/backends/rabbitmq/Constants.java @@ -17,7 +17,7 @@ * under the License. * ****************************************************************/ -package org.apache.james.backend.rabbitmq; +package org.apache.james.backends.rabbitmq; import com.google.common.collect.ImmutableMap; import com.rabbitmq.client.AMQP; diff --git a/backends-common/rabbitmq/src/main/java/org/apache/james/backend/rabbitmq/RabbitMQChannelPool.java b/backends-common/rabbitmq/src/main/java/org/apache/james/backends/rabbitmq/RabbitMQChannelPool.java similarity index 97% rename from backends-common/rabbitmq/src/main/java/org/apache/james/backend/rabbitmq/RabbitMQChannelPool.java rename to backends-common/rabbitmq/src/main/java/org/apache/james/backends/rabbitmq/RabbitMQChannelPool.java index e8fef49..a544efb 100644 --- a/backends-common/rabbitmq/src/main/java/org/apache/james/backend/rabbitmq/RabbitMQChannelPool.java +++ b/backends-common/rabbitmq/src/main/java/org/apache/james/backends/rabbitmq/RabbitMQChannelPool.java @@ -17,7 +17,7 @@ * under the License. * ****************************************************************/ -package org.apache.james.backend.rabbitmq; +package org.apache.james.backends.rabbitmq; import com.rabbitmq.client.Channel; import reactor.core.publisher.Flux; diff --git a/backends-common/rabbitmq/src/main/java/org/apache/james/backend/rabbitmq/RabbitMQConfiguration.java b/backends-common/rabbitmq/src/main/java/org/apache/james/backends/rabbitmq/RabbitMQConfiguration.java similarity index 99% rename from backends-common/rabbitmq/src/main/java/org/apache/james/backend/rabbitmq/RabbitMQConfiguration.java rename to backends-common/rabbitmq/src/main/java/org/apache/james/backends/rabbitmq/RabbitMQConfiguration.java index 70e3428..8b12e2a 100644 --- a/backends-common/rabbitmq/src/main/java/org/apache/james/backend/rabbitmq/RabbitMQConfiguration.java +++ b/backends-common/rabbitmq/src/main/java/org/apache/james/backends/rabbitmq/RabbitMQConfiguration.java @@ -16,7 +16,7 @@ * specific language governing permissions and limitations * * under the License. * ****************************************************************/ -package org.apache.james.backend.rabbitmq; +package org.apache.james.backends.rabbitmq; import java.net.URI; import java.util.Arrays; diff --git a/backends-common/rabbitmq/src/main/java/org/apache/james/backend/rabbitmq/RabbitMQConnectionFactory.java b/backends-common/rabbitmq/src/main/java/org/apache/james/backends/rabbitmq/RabbitMQConnectionFactory.java similarity index 98% rename from backends-common/rabbitmq/src/main/java/org/apache/james/backend/rabbitmq/RabbitMQConnectionFactory.java rename to backends-common/rabbitmq/src/main/java/org/apache/james/backends/rabbitmq/RabbitMQConnectionFactory.java index d733914..1f4d0fd 100644 --- a/backends-common/rabbitmq/src/main/java/org/apache/james/backend/rabbitmq/RabbitMQConnectionFactory.java +++ b/backends-common/rabbitmq/src/main/java/org/apache/james/backends/rabbitmq/RabbitMQConnectionFactory.java @@ -16,7 +16,7 @@ * specific language governing permissions and limitations * * under the License. * ****************************************************************/ -package org.apache.james.backend.rabbitmq; +package org.apache.james.backends.rabbitmq; import java.time.Duration; diff --git a/backends-common/rabbitmq/src/main/java/org/apache/james/backend/rabbitmq/RabbitMQHealthCheck.java b/backends-common/rabbitmq/src/main/java/org/apache/james/backends/rabbitmq/RabbitMQHealthCheck.java similarity index 98% rename from backends-common/rabbitmq/src/main/java/org/apache/james/backend/rabbitmq/RabbitMQHealthCheck.java rename to backends-common/rabbitmq/src/main/java/org/apache/james/backends/rabbitmq/RabbitMQHealthCheck.java index a3b02a4..d766a5f 100644 --- a/backends-common/rabbitmq/src/main/java/org/apache/james/backend/rabbitmq/RabbitMQHealthCheck.java +++ b/backends-common/rabbitmq/src/main/java/org/apache/james/backends/rabbitmq/RabbitMQHealthCheck.java @@ -17,7 +17,7 @@ * under the License. * ****************************************************************/ -package org.apache.james.backend.rabbitmq; +package org.apache.james.backends.rabbitmq; import javax.inject.Inject; diff --git a/backends-common/rabbitmq/src/main/java/org/apache/james/backend/rabbitmq/RabbitMQManagementAPI.java b/backends-common/rabbitmq/src/main/java/org/apache/james/backends/rabbitmq/RabbitMQManagementAPI.java similarity index 99% rename from backends-common/rabbitmq/src/main/java/org/apache/james/backend/rabbitmq/RabbitMQManagementAPI.java rename to backends-common/rabbitmq/src/main/java/org/apache/james/backends/rabbitmq/RabbitMQManagementAPI.java index 15be247..9f688e8 100644 --- a/backends-common/rabbitmq/src/main/java/org/apache/james/backend/rabbitmq/RabbitMQManagementAPI.java +++ b/backends-common/rabbitmq/src/main/java/org/apache/james/backends/rabbitmq/RabbitMQManagementAPI.java @@ -17,7 +17,7 @@ * under the License. * ****************************************************************/ -package org.apache.james.backend.rabbitmq; +package org.apache.james.backends.rabbitmq; import java.util.Date; import java.util.List; diff --git a/backends-common/rabbitmq/src/main/java/org/apache/james/backend/rabbitmq/ReactorRabbitMQChannelPool.java b/backends-common/rabbitmq/src/main/java/org/apache/james/backends/rabbitmq/ReactorRabbitMQChannelPool.java similarity index 99% rename from backends-common/rabbitmq/src/main/java/org/apache/james/backend/rabbitmq/ReactorRabbitMQChannelPool.java rename to backends-common/rabbitmq/src/main/java/org/apache/james/backends/rabbitmq/ReactorRabbitMQChannelPool.java index 814e70a..dfba0ba 100644 --- a/backends-common/rabbitmq/src/main/java/org/apache/james/backend/rabbitmq/ReactorRabbitMQChannelPool.java +++ b/backends-common/rabbitmq/src/main/java/org/apache/james/backends/rabbitmq/ReactorRabbitMQChannelPool.java @@ -17,7 +17,7 @@ * under the License. * ****************************************************************/ -package org.apache.james.backend.rabbitmq; +package org.apache.james.backends.rabbitmq; import java.time.Duration; import java.util.Comparator; diff --git a/backends-common/rabbitmq/src/main/java/org/apache/james/backend/rabbitmq/SimpleChannelPool.java b/backends-common/rabbitmq/src/main/java/org/apache/james/backends/rabbitmq/SimpleChannelPool.java similarity index 99% rename from backends-common/rabbitmq/src/main/java/org/apache/james/backend/rabbitmq/SimpleChannelPool.java rename to backends-common/rabbitmq/src/main/java/org/apache/james/backends/rabbitmq/SimpleChannelPool.java index 16a8a7f..f99ab43 100644 --- a/backends-common/rabbitmq/src/main/java/org/apache/james/backend/rabbitmq/SimpleChannelPool.java +++ b/backends-common/rabbitmq/src/main/java/org/apache/james/backends/rabbitmq/SimpleChannelPool.java @@ -17,7 +17,7 @@ * under the License. * ****************************************************************/ -package org.apache.james.backend.rabbitmq; +package org.apache.james.backends.rabbitmq; import java.io.IOException; import java.time.Duration; diff --git a/backends-common/rabbitmq/src/main/java/org/apache/james/backend/rabbitmq/SimpleConnectionPool.java b/backends-common/rabbitmq/src/main/java/org/apache/james/backends/rabbitmq/SimpleConnectionPool.java similarity index 98% rename from backends-common/rabbitmq/src/main/java/org/apache/james/backend/rabbitmq/SimpleConnectionPool.java rename to backends-common/rabbitmq/src/main/java/org/apache/james/backends/rabbitmq/SimpleConnectionPool.java index 5f07719..4ffebfd 100644 --- a/backends-common/rabbitmq/src/main/java/org/apache/james/backend/rabbitmq/SimpleConnectionPool.java +++ b/backends-common/rabbitmq/src/main/java/org/apache/james/backends/rabbitmq/SimpleConnectionPool.java @@ -17,7 +17,7 @@ * under the License. * ****************************************************************/ -package org.apache.james.backend.rabbitmq; +package org.apache.james.backends.rabbitmq; import java.io.IOException; import java.time.Duration; diff --git a/backends-common/rabbitmq/src/test/java/org/apache/james/backend/rabbitmq/ChannelPoolContract.java b/backends-common/rabbitmq/src/test/java/org/apache/james/backends/rabbitmq/ChannelPoolContract.java similarity index 98% rename from backends-common/rabbitmq/src/test/java/org/apache/james/backend/rabbitmq/ChannelPoolContract.java rename to backends-common/rabbitmq/src/test/java/org/apache/james/backends/rabbitmq/ChannelPoolContract.java index 7543883..1bccee7 100644 --- a/backends-common/rabbitmq/src/test/java/org/apache/james/backend/rabbitmq/ChannelPoolContract.java +++ b/backends-common/rabbitmq/src/test/java/org/apache/james/backends/rabbitmq/ChannelPoolContract.java @@ -17,7 +17,7 @@ * under the License. * ****************************************************************/ -package org.apache.james.backend.rabbitmq; +package org.apache.james.backends.rabbitmq; import static org.assertj.core.api.Assertions.assertThat; import static org.assertj.core.api.Assertions.assertThatThrownBy; diff --git a/backends-common/rabbitmq/src/test/java/org/apache/james/backend/rabbitmq/DockerClusterRabbitMQExtension.java b/backends-common/rabbitmq/src/test/java/org/apache/james/backends/rabbitmq/DockerClusterRabbitMQExtension.java similarity index 99% rename from backends-common/rabbitmq/src/test/java/org/apache/james/backend/rabbitmq/DockerClusterRabbitMQExtension.java rename to backends-common/rabbitmq/src/test/java/org/apache/james/backends/rabbitmq/DockerClusterRabbitMQExtension.java index 05278ca..a9a172c 100644 --- a/backends-common/rabbitmq/src/test/java/org/apache/james/backend/rabbitmq/DockerClusterRabbitMQExtension.java +++ b/backends-common/rabbitmq/src/test/java/org/apache/james/backends/rabbitmq/DockerClusterRabbitMQExtension.java @@ -16,7 +16,7 @@ * specific language governing permissions and limitations * * under the License. * ****************************************************************/ -package org.apache.james.backend.rabbitmq; +package org.apache.james.backends.rabbitmq; import java.nio.charset.StandardCharsets; import java.util.UUID; diff --git a/backends-common/rabbitmq/src/test/java/org/apache/james/backend/rabbitmq/DockerRabbitMQ.java b/backends-common/rabbitmq/src/test/java/org/apache/james/backends/rabbitmq/DockerRabbitMQ.java similarity index 98% rename from backends-common/rabbitmq/src/test/java/org/apache/james/backend/rabbitmq/DockerRabbitMQ.java rename to backends-common/rabbitmq/src/test/java/org/apache/james/backends/rabbitmq/DockerRabbitMQ.java index e786d6c..69db7ba 100644 --- a/backends-common/rabbitmq/src/test/java/org/apache/james/backend/rabbitmq/DockerRabbitMQ.java +++ b/backends-common/rabbitmq/src/test/java/org/apache/james/backends/rabbitmq/DockerRabbitMQ.java @@ -16,9 +16,9 @@ * specific language governing permissions and limitations * * under the License. * ****************************************************************/ -package org.apache.james.backend.rabbitmq; +package org.apache.james.backends.rabbitmq; -import static org.apache.james.backend.rabbitmq.RabbitMQFixture.DEFAULT_MANAGEMENT_CREDENTIAL; +import static org.apache.james.backends.rabbitmq.RabbitMQFixture.DEFAULT_MANAGEMENT_CREDENTIAL; import java.net.URI; import java.net.URISyntaxException; diff --git a/backends-common/rabbitmq/src/test/java/org/apache/james/backend/rabbitmq/DockerRabbitMQSingleton.java b/backends-common/rabbitmq/src/test/java/org/apache/james/backends/rabbitmq/DockerRabbitMQSingleton.java similarity index 97% rename from backends-common/rabbitmq/src/test/java/org/apache/james/backend/rabbitmq/DockerRabbitMQSingleton.java rename to backends-common/rabbitmq/src/test/java/org/apache/james/backends/rabbitmq/DockerRabbitMQSingleton.java index 591b979..022ac52 100644 --- a/backends-common/rabbitmq/src/test/java/org/apache/james/backend/rabbitmq/DockerRabbitMQSingleton.java +++ b/backends-common/rabbitmq/src/test/java/org/apache/james/backends/rabbitmq/DockerRabbitMQSingleton.java @@ -17,7 +17,7 @@ * under the License. * ****************************************************************/ -package org.apache.james.backend.rabbitmq; +package org.apache.james.backends.rabbitmq; public class DockerRabbitMQSingleton { diff --git a/backends-common/rabbitmq/src/test/java/org/apache/james/backend/rabbitmq/DockerRabbitMQTestRule.java b/backends-common/rabbitmq/src/test/java/org/apache/james/backends/rabbitmq/DockerRabbitMQTestRule.java similarity index 94% rename from backends-common/rabbitmq/src/test/java/org/apache/james/backend/rabbitmq/DockerRabbitMQTestRule.java rename to backends-common/rabbitmq/src/test/java/org/apache/james/backends/rabbitmq/DockerRabbitMQTestRule.java index 1e8a2a5..7b921a7 100644 --- a/backends-common/rabbitmq/src/test/java/org/apache/james/backend/rabbitmq/DockerRabbitMQTestRule.java +++ b/backends-common/rabbitmq/src/test/java/org/apache/james/backends/rabbitmq/DockerRabbitMQTestRule.java @@ -16,9 +16,9 @@ * specific language governing permissions and limitations * * under the License. * ****************************************************************/ -package org.apache.james.backend.rabbitmq; +package org.apache.james.backends.rabbitmq; -import static org.apache.james.backend.rabbitmq.RabbitMQFixture.DEFAULT_MANAGEMENT_CREDENTIAL; +import static org.apache.james.backends.rabbitmq.RabbitMQFixture.DEFAULT_MANAGEMENT_CREDENTIAL; import org.junit.rules.ExternalResource; diff --git a/backends-common/rabbitmq/src/test/java/org/apache/james/backend/rabbitmq/InMemoryConsumer.java b/backends-common/rabbitmq/src/test/java/org/apache/james/backends/rabbitmq/InMemoryConsumer.java similarity index 98% rename from backends-common/rabbitmq/src/test/java/org/apache/james/backend/rabbitmq/InMemoryConsumer.java rename to backends-common/rabbitmq/src/test/java/org/apache/james/backends/rabbitmq/InMemoryConsumer.java index 3cc93ae..8fc8611 100644 --- a/backends-common/rabbitmq/src/test/java/org/apache/james/backend/rabbitmq/InMemoryConsumer.java +++ b/backends-common/rabbitmq/src/test/java/org/apache/james/backends/rabbitmq/InMemoryConsumer.java @@ -16,7 +16,7 @@ * specific language governing permissions and limitations * * under the License. * ****************************************************************/ -package org.apache.james.backend.rabbitmq; +package org.apache.james.backends.rabbitmq; import java.io.IOException; import java.nio.charset.StandardCharsets; diff --git a/backends-common/rabbitmq/src/test/java/org/apache/james/backend/rabbitmq/RabbitMQClusterTest.java b/backends-common/rabbitmq/src/test/java/org/apache/james/backends/rabbitmq/RabbitMQClusterTest.java similarity index 94% rename from backends-common/rabbitmq/src/test/java/org/apache/james/backend/rabbitmq/RabbitMQClusterTest.java rename to backends-common/rabbitmq/src/test/java/org/apache/james/backends/rabbitmq/RabbitMQClusterTest.java index b4066a1..1541f52 100644 --- a/backends-common/rabbitmq/src/test/java/org/apache/james/backend/rabbitmq/RabbitMQClusterTest.java +++ b/backends-common/rabbitmq/src/test/java/org/apache/james/backends/rabbitmq/RabbitMQClusterTest.java @@ -16,16 +16,16 @@ * specific language governing permissions and limitations * * under the License. * ****************************************************************/ -package org.apache.james.backend.rabbitmq; - -import static org.apache.james.backend.rabbitmq.Constants.AUTO_DELETE; -import static org.apache.james.backend.rabbitmq.Constants.DIRECT_EXCHANGE; -import static org.apache.james.backend.rabbitmq.Constants.DURABLE; -import static org.apache.james.backend.rabbitmq.Constants.EXCLUSIVE; -import static org.apache.james.backend.rabbitmq.Constants.NO_PROPERTIES; -import static org.apache.james.backend.rabbitmq.RabbitMQFixture.EXCHANGE_NAME; -import static org.apache.james.backend.rabbitmq.RabbitMQFixture.ROUTING_KEY; -import static org.apache.james.backend.rabbitmq.RabbitMQFixture.awaitAtMostOneMinute; +package org.apache.james.backends.rabbitmq; + +import static org.apache.james.backends.rabbitmq.Constants.AUTO_DELETE; +import static org.apache.james.backends.rabbitmq.Constants.DIRECT_EXCHANGE; +import static org.apache.james.backends.rabbitmq.Constants.DURABLE; +import static org.apache.james.backends.rabbitmq.Constants.EXCLUSIVE; +import static org.apache.james.backends.rabbitmq.Constants.NO_PROPERTIES; +import static org.apache.james.backends.rabbitmq.RabbitMQFixture.EXCHANGE_NAME; +import static org.apache.james.backends.rabbitmq.RabbitMQFixture.ROUTING_KEY; +import static org.apache.james.backends.rabbitmq.RabbitMQFixture.awaitAtMostOneMinute; import static org.assertj.core.api.Assertions.assertThat; import java.io.IOException; @@ -36,7 +36,7 @@ import java.util.concurrent.TimeoutException; import java.util.concurrent.atomic.AtomicInteger; import java.util.stream.IntStream; -import org.apache.james.backend.rabbitmq.DockerClusterRabbitMQExtension.DockerRabbitMQCluster; +import org.apache.james.backends.rabbitmq.DockerClusterRabbitMQExtension.DockerRabbitMQCluster; import org.awaitility.Awaitility; import org.awaitility.Duration; import org.junit.jupiter.api.AfterAll; diff --git a/backends-common/rabbitmq/src/test/java/org/apache/james/backend/rabbitmq/RabbitMQConfigurationTest.java b/backends-common/rabbitmq/src/test/java/org/apache/james/backends/rabbitmq/RabbitMQConfigurationTest.java similarity index 98% rename from backends-common/rabbitmq/src/test/java/org/apache/james/backend/rabbitmq/RabbitMQConfigurationTest.java rename to backends-common/rabbitmq/src/test/java/org/apache/james/backends/rabbitmq/RabbitMQConfigurationTest.java index 7dfe03e..84bb762 100644 --- a/backends-common/rabbitmq/src/test/java/org/apache/james/backend/rabbitmq/RabbitMQConfigurationTest.java +++ b/backends-common/rabbitmq/src/test/java/org/apache/james/backends/rabbitmq/RabbitMQConfigurationTest.java @@ -16,11 +16,11 @@ * specific language governing permissions and limitations * * under the License. * ****************************************************************/ -package org.apache.james.backend.rabbitmq; +package org.apache.james.backends.rabbitmq; -import static org.apache.james.backend.rabbitmq.RabbitMQFixture.DEFAULT_MANAGEMENT_CREDENTIAL; -import static org.apache.james.backend.rabbitmq.RabbitMQFixture.DEFAULT_PASSWORD_STRING; -import static org.apache.james.backend.rabbitmq.RabbitMQFixture.DEFAULT_USER; +import static org.apache.james.backends.rabbitmq.RabbitMQFixture.DEFAULT_MANAGEMENT_CREDENTIAL; +import static org.apache.james.backends.rabbitmq.RabbitMQFixture.DEFAULT_PASSWORD_STRING; +import static org.apache.james.backends.rabbitmq.RabbitMQFixture.DEFAULT_USER; import static org.assertj.core.api.Assertions.assertThat; import static org.assertj.core.api.Assertions.assertThatThrownBy; diff --git a/backends-common/rabbitmq/src/test/java/org/apache/james/backend/rabbitmq/RabbitMQConnectionFactoryTest.java b/backends-common/rabbitmq/src/test/java/org/apache/james/backends/rabbitmq/RabbitMQConnectionFactoryTest.java similarity index 95% rename from backends-common/rabbitmq/src/test/java/org/apache/james/backend/rabbitmq/RabbitMQConnectionFactoryTest.java rename to backends-common/rabbitmq/src/test/java/org/apache/james/backends/rabbitmq/RabbitMQConnectionFactoryTest.java index 3dce665..052aa90 100644 --- a/backends-common/rabbitmq/src/test/java/org/apache/james/backend/rabbitmq/RabbitMQConnectionFactoryTest.java +++ b/backends-common/rabbitmq/src/test/java/org/apache/james/backends/rabbitmq/RabbitMQConnectionFactoryTest.java @@ -16,9 +16,9 @@ * specific language governing permissions and limitations * * under the License. * ****************************************************************/ -package org.apache.james.backend.rabbitmq; +package org.apache.james.backends.rabbitmq; -import static org.apache.james.backend.rabbitmq.RabbitMQFixture.DEFAULT_MANAGEMENT_CREDENTIAL; +import static org.apache.james.backends.rabbitmq.RabbitMQFixture.DEFAULT_MANAGEMENT_CREDENTIAL; import static org.assertj.core.api.Assertions.assertThatThrownBy; import java.net.URI; diff --git a/backends-common/rabbitmq/src/test/java/org/apache/james/backend/rabbitmq/RabbitMQExtension.java b/backends-common/rabbitmq/src/test/java/org/apache/james/backends/rabbitmq/RabbitMQExtension.java similarity index 97% rename from backends-common/rabbitmq/src/test/java/org/apache/james/backend/rabbitmq/RabbitMQExtension.java rename to backends-common/rabbitmq/src/test/java/org/apache/james/backends/rabbitmq/RabbitMQExtension.java index 1c9f46d..577be12 100644 --- a/backends-common/rabbitmq/src/test/java/org/apache/james/backend/rabbitmq/RabbitMQExtension.java +++ b/backends-common/rabbitmq/src/test/java/org/apache/james/backends/rabbitmq/RabbitMQExtension.java @@ -16,9 +16,9 @@ * specific language governing permissions and limitations * * under the License. * ****************************************************************/ -package org.apache.james.backend.rabbitmq; +package org.apache.james.backends.rabbitmq; -import static org.apache.james.backend.rabbitmq.RabbitMQFixture.DEFAULT_MANAGEMENT_CREDENTIAL; +import static org.apache.james.backends.rabbitmq.RabbitMQFixture.DEFAULT_MANAGEMENT_CREDENTIAL; import java.net.URISyntaxException; import java.util.function.Consumer; diff --git a/backends-common/rabbitmq/src/test/java/org/apache/james/backend/rabbitmq/RabbitMQFixture.java b/backends-common/rabbitmq/src/test/java/org/apache/james/backends/rabbitmq/RabbitMQFixture.java similarity index 98% rename from backends-common/rabbitmq/src/test/java/org/apache/james/backend/rabbitmq/RabbitMQFixture.java rename to backends-common/rabbitmq/src/test/java/org/apache/james/backends/rabbitmq/RabbitMQFixture.java index e8e63fc..c1d73f5 100644 --- a/backends-common/rabbitmq/src/test/java/org/apache/james/backend/rabbitmq/RabbitMQFixture.java +++ b/backends-common/rabbitmq/src/test/java/org/apache/james/backends/rabbitmq/RabbitMQFixture.java @@ -17,7 +17,7 @@ * under the License. * ****************************************************************/ -package org.apache.james.backend.rabbitmq; +package org.apache.james.backends.rabbitmq; import static org.awaitility.Duration.ONE_HUNDRED_MILLISECONDS; import static org.awaitility.Duration.ONE_MINUTE; diff --git a/backends-common/rabbitmq/src/test/java/org/apache/james/backend/rabbitmq/RabbitMQHealthCheckTest.java b/backends-common/rabbitmq/src/test/java/org/apache/james/backends/rabbitmq/RabbitMQHealthCheckTest.java similarity index 98% rename from backends-common/rabbitmq/src/test/java/org/apache/james/backend/rabbitmq/RabbitMQHealthCheckTest.java rename to backends-common/rabbitmq/src/test/java/org/apache/james/backends/rabbitmq/RabbitMQHealthCheckTest.java index 6b811a0..15c22c3 100644 --- a/backends-common/rabbitmq/src/test/java/org/apache/james/backend/rabbitmq/RabbitMQHealthCheckTest.java +++ b/backends-common/rabbitmq/src/test/java/org/apache/james/backends/rabbitmq/RabbitMQHealthCheckTest.java @@ -17,7 +17,7 @@ * under the License. * ****************************************************************/ -package org.apache.james.backend.rabbitmq; +package org.apache.james.backends.rabbitmq; import static org.assertj.core.api.Assertions.assertThat; diff --git a/backends-common/rabbitmq/src/test/java/org/apache/james/backend/rabbitmq/RabbitMQTest.java b/backends-common/rabbitmq/src/test/java/org/apache/james/backends/rabbitmq/RabbitMQTest.java similarity index 94% rename from backends-common/rabbitmq/src/test/java/org/apache/james/backend/rabbitmq/RabbitMQTest.java rename to backends-common/rabbitmq/src/test/java/org/apache/james/backends/rabbitmq/RabbitMQTest.java index d858258..b673a10 100644 --- a/backends-common/rabbitmq/src/test/java/org/apache/james/backend/rabbitmq/RabbitMQTest.java +++ b/backends-common/rabbitmq/src/test/java/org/apache/james/backends/rabbitmq/RabbitMQTest.java @@ -16,21 +16,21 @@ * specific language governing permissions and limitations * * under the License. * ****************************************************************/ -package org.apache.james.backend.rabbitmq; - -import static org.apache.james.backend.rabbitmq.Constants.AUTO_ACK; -import static org.apache.james.backend.rabbitmq.Constants.AUTO_DELETE; -import static org.apache.james.backend.rabbitmq.Constants.DIRECT_EXCHANGE; -import static org.apache.james.backend.rabbitmq.Constants.DURABLE; -import static org.apache.james.backend.rabbitmq.Constants.EXCLUSIVE; -import static org.apache.james.backend.rabbitmq.Constants.MULTIPLE; -import static org.apache.james.backend.rabbitmq.Constants.NO_LOCAL; -import static org.apache.james.backend.rabbitmq.Constants.NO_PROPERTIES; -import static org.apache.james.backend.rabbitmq.Constants.REQUEUE; -import static org.apache.james.backend.rabbitmq.RabbitMQFixture.EXCHANGE_NAME; -import static org.apache.james.backend.rabbitmq.RabbitMQFixture.ROUTING_KEY; -import static org.apache.james.backend.rabbitmq.RabbitMQFixture.WORK_QUEUE; -import static org.apache.james.backend.rabbitmq.RabbitMQFixture.awaitAtMostOneMinute; +package org.apache.james.backends.rabbitmq; + +import static org.apache.james.backends.rabbitmq.Constants.AUTO_ACK; +import static org.apache.james.backends.rabbitmq.Constants.AUTO_DELETE; +import static org.apache.james.backends.rabbitmq.Constants.DIRECT_EXCHANGE; +import static org.apache.james.backends.rabbitmq.Constants.DURABLE; +import static org.apache.james.backends.rabbitmq.Constants.EXCLUSIVE; +import static org.apache.james.backends.rabbitmq.Constants.MULTIPLE; +import static org.apache.james.backends.rabbitmq.Constants.NO_LOCAL; +import static org.apache.james.backends.rabbitmq.Constants.NO_PROPERTIES; +import static org.apache.james.backends.rabbitmq.Constants.REQUEUE; +import static org.apache.james.backends.rabbitmq.RabbitMQFixture.EXCHANGE_NAME; +import static org.apache.james.backends.rabbitmq.RabbitMQFixture.ROUTING_KEY; +import static org.apache.james.backends.rabbitmq.RabbitMQFixture.WORK_QUEUE; +import static org.apache.james.backends.rabbitmq.RabbitMQFixture.awaitAtMostOneMinute; import static org.assertj.core.api.Assertions.assertThat; import static org.assertj.core.api.Assertions.assertThatThrownBy; diff --git a/backends-common/rabbitmq/src/test/java/org/apache/james/backend/rabbitmq/RabbitMQWaitStrategy.java b/backends-common/rabbitmq/src/test/java/org/apache/james/backends/rabbitmq/RabbitMQWaitStrategy.java similarity index 98% rename from backends-common/rabbitmq/src/test/java/org/apache/james/backend/rabbitmq/RabbitMQWaitStrategy.java rename to backends-common/rabbitmq/src/test/java/org/apache/james/backends/rabbitmq/RabbitMQWaitStrategy.java index 29b5193..99136f7 100644 --- a/backends-common/rabbitmq/src/test/java/org/apache/james/backend/rabbitmq/RabbitMQWaitStrategy.java +++ b/backends-common/rabbitmq/src/test/java/org/apache/james/backends/rabbitmq/RabbitMQWaitStrategy.java @@ -17,7 +17,7 @@ * under the License. * ****************************************************************/ -package org.apache.james.backend.rabbitmq; +package org.apache.james.backends.rabbitmq; import java.io.IOException; import java.time.Duration; diff --git a/backends-common/rabbitmq/src/test/java/org/apache/james/backend/rabbitmq/ReactorRabbitMQChannelPoolTest.java b/backends-common/rabbitmq/src/test/java/org/apache/james/backends/rabbitmq/ReactorRabbitMQChannelPoolTest.java similarity index 96% rename from backends-common/rabbitmq/src/test/java/org/apache/james/backend/rabbitmq/ReactorRabbitMQChannelPoolTest.java rename to backends-common/rabbitmq/src/test/java/org/apache/james/backends/rabbitmq/ReactorRabbitMQChannelPoolTest.java index 24146dc..81994c8 100644 --- a/backends-common/rabbitmq/src/test/java/org/apache/james/backend/rabbitmq/ReactorRabbitMQChannelPoolTest.java +++ b/backends-common/rabbitmq/src/test/java/org/apache/james/backends/rabbitmq/ReactorRabbitMQChannelPoolTest.java @@ -17,7 +17,7 @@ * under the License. * ****************************************************************/ -package org.apache.james.backend.rabbitmq; +package org.apache.james.backends.rabbitmq; import static org.assertj.core.api.Assertions.assertThat; import static org.assertj.core.api.Assertions.assertThatThrownBy; @@ -28,8 +28,6 @@ import java.util.List; import java.util.concurrent.ConcurrentLinkedQueue; import java.util.concurrent.ExecutionException; -import org.apache.james.backend.rabbitmq.RabbitMQExtension; -import org.apache.james.backend.rabbitmq.ReactorRabbitMQChannelPool; import org.apache.james.util.concurrency.ConcurrentTestRunner; import org.junit.jupiter.api.AfterEach; import org.junit.jupiter.api.BeforeEach; diff --git a/mailbox/event/event-rabbitmq/src/main/java/org/apache/james/mailbox/events/EventDispatcher.java b/mailbox/event/event-rabbitmq/src/main/java/org/apache/james/mailbox/events/EventDispatcher.java index b9d7884..ebfa205 100644 --- a/mailbox/event/event-rabbitmq/src/main/java/org/apache/james/mailbox/events/EventDispatcher.java +++ b/mailbox/event/event-rabbitmq/src/main/java/org/apache/james/mailbox/events/EventDispatcher.java @@ -19,8 +19,8 @@ package org.apache.james.mailbox.events; -import static org.apache.james.backend.rabbitmq.Constants.DIRECT_EXCHANGE; -import static org.apache.james.backend.rabbitmq.Constants.DURABLE; +import static org.apache.james.backends.rabbitmq.Constants.DIRECT_EXCHANGE; +import static org.apache.james.backends.rabbitmq.Constants.DURABLE; import static org.apache.james.mailbox.events.RabbitMQEventBus.EVENT_BUS_ID; import static org.apache.james.mailbox.events.RabbitMQEventBus.MAILBOX_EVENT_EXCHANGE_NAME; diff --git a/mailbox/event/event-rabbitmq/src/main/java/org/apache/james/mailbox/events/GroupConsumerRetry.java b/mailbox/event/event-rabbitmq/src/main/java/org/apache/james/mailbox/events/GroupConsumerRetry.java index 54a78ca..991be75 100644 --- a/mailbox/event/event-rabbitmq/src/main/java/org/apache/james/mailbox/events/GroupConsumerRetry.java +++ b/mailbox/event/event-rabbitmq/src/main/java/org/apache/james/mailbox/events/GroupConsumerRetry.java @@ -19,9 +19,9 @@ package org.apache.james.mailbox.events; -import static org.apache.james.backend.rabbitmq.Constants.DIRECT_EXCHANGE; -import static org.apache.james.backend.rabbitmq.Constants.DURABLE; -import static org.apache.james.backend.rabbitmq.Constants.EMPTY_ROUTING_KEY; +import static org.apache.james.backends.rabbitmq.Constants.DIRECT_EXCHANGE; +import static org.apache.james.backends.rabbitmq.Constants.DURABLE; +import static org.apache.james.backends.rabbitmq.Constants.EMPTY_ROUTING_KEY; import static org.apache.james.mailbox.events.GroupRegistration.RETRY_COUNT; import static org.apache.james.mailbox.events.RabbitMQEventBus.MAILBOX_EVENT; diff --git a/mailbox/event/event-rabbitmq/src/main/java/org/apache/james/mailbox/events/GroupRegistration.java b/mailbox/event/event-rabbitmq/src/main/java/org/apache/james/mailbox/events/GroupRegistration.java index 8d477e7..79aa6a8 100644 --- a/mailbox/event/event-rabbitmq/src/main/java/org/apache/james/mailbox/events/GroupRegistration.java +++ b/mailbox/event/event-rabbitmq/src/main/java/org/apache/james/mailbox/events/GroupRegistration.java @@ -19,11 +19,11 @@ package org.apache.james.mailbox.events; -import static org.apache.james.backend.rabbitmq.Constants.AUTO_DELETE; -import static org.apache.james.backend.rabbitmq.Constants.DURABLE; -import static org.apache.james.backend.rabbitmq.Constants.EMPTY_ROUTING_KEY; -import static org.apache.james.backend.rabbitmq.Constants.EXCLUSIVE; -import static org.apache.james.backend.rabbitmq.Constants.NO_ARGUMENTS; +import static org.apache.james.backends.rabbitmq.Constants.AUTO_DELETE; +import static org.apache.james.backends.rabbitmq.Constants.DURABLE; +import static org.apache.james.backends.rabbitmq.Constants.EMPTY_ROUTING_KEY; +import static org.apache.james.backends.rabbitmq.Constants.EXCLUSIVE; +import static org.apache.james.backends.rabbitmq.Constants.NO_ARGUMENTS; import static org.apache.james.mailbox.events.RabbitMQEventBus.MAILBOX_EVENT; import static org.apache.james.mailbox.events.RabbitMQEventBus.MAILBOX_EVENT_EXCHANGE_NAME; diff --git a/mailbox/event/event-rabbitmq/src/main/java/org/apache/james/mailbox/events/KeyRegistrationHandler.java b/mailbox/event/event-rabbitmq/src/main/java/org/apache/james/mailbox/events/KeyRegistrationHandler.java index 5f5d2b3..7910152 100644 --- a/mailbox/event/event-rabbitmq/src/main/java/org/apache/james/mailbox/events/KeyRegistrationHandler.java +++ b/mailbox/event/event-rabbitmq/src/main/java/org/apache/james/mailbox/events/KeyRegistrationHandler.java @@ -19,10 +19,10 @@ package org.apache.james.mailbox.events; -import static org.apache.james.backend.rabbitmq.Constants.AUTO_DELETE; -import static org.apache.james.backend.rabbitmq.Constants.DURABLE; -import static org.apache.james.backend.rabbitmq.Constants.EXCLUSIVE; -import static org.apache.james.backend.rabbitmq.Constants.NO_ARGUMENTS; +import static org.apache.james.backends.rabbitmq.Constants.AUTO_DELETE; +import static org.apache.james.backends.rabbitmq.Constants.DURABLE; +import static org.apache.james.backends.rabbitmq.Constants.EXCLUSIVE; +import static org.apache.james.backends.rabbitmq.Constants.NO_ARGUMENTS; import static org.apache.james.mailbox.events.RabbitMQEventBus.EVENT_BUS_ID; import java.nio.charset.StandardCharsets; diff --git a/mailbox/event/event-rabbitmq/src/main/java/org/apache/james/mailbox/events/RabbitMQEventBus.java b/mailbox/event/event-rabbitmq/src/main/java/org/apache/james/mailbox/events/RabbitMQEventBus.java index 36795c6..a659062 100644 --- a/mailbox/event/event-rabbitmq/src/main/java/org/apache/james/mailbox/events/RabbitMQEventBus.java +++ b/mailbox/event/event-rabbitmq/src/main/java/org/apache/james/mailbox/events/RabbitMQEventBus.java @@ -24,8 +24,8 @@ import java.util.Set; import javax.annotation.PreDestroy; import javax.inject.Inject; -import org.apache.james.backend.rabbitmq.ReactorRabbitMQChannelPool; -import org.apache.james.backend.rabbitmq.SimpleConnectionPool; +import org.apache.james.backends.rabbitmq.ReactorRabbitMQChannelPool; +import org.apache.james.backends.rabbitmq.SimpleConnectionPool; import org.apache.james.event.json.EventSerializer; import org.apache.james.lifecycle.api.Startable; import org.apache.james.metrics.api.MetricFactory; diff --git a/mailbox/event/event-rabbitmq/src/main/java/org/apache/james/mailbox/events/RoutingKeyConverter.java b/mailbox/event/event-rabbitmq/src/main/java/org/apache/james/mailbox/events/RoutingKeyConverter.java index 7e0edb8..bf84ec1 100644 --- a/mailbox/event/event-rabbitmq/src/main/java/org/apache/james/mailbox/events/RoutingKeyConverter.java +++ b/mailbox/event/event-rabbitmq/src/main/java/org/apache/james/mailbox/events/RoutingKeyConverter.java @@ -19,7 +19,7 @@ package org.apache.james.mailbox.events; -import static org.apache.james.backend.rabbitmq.Constants.EMPTY_ROUTING_KEY; +import static org.apache.james.backends.rabbitmq.Constants.EMPTY_ROUTING_KEY; import java.util.List; import java.util.Optional; diff --git a/mailbox/event/event-rabbitmq/src/test/java/org/apache/james/mailbox/events/RabbitMQEventBusTest.java b/mailbox/event/event-rabbitmq/src/test/java/org/apache/james/mailbox/events/RabbitMQEventBusTest.java index bbb169c..ab6d885 100644 --- a/mailbox/event/event-rabbitmq/src/test/java/org/apache/james/mailbox/events/RabbitMQEventBusTest.java +++ b/mailbox/event/event-rabbitmq/src/test/java/org/apache/james/mailbox/events/RabbitMQEventBusTest.java @@ -19,12 +19,12 @@ package org.apache.james.mailbox.events; -import static org.apache.james.backend.rabbitmq.Constants.AUTO_DELETE; -import static org.apache.james.backend.rabbitmq.Constants.DIRECT_EXCHANGE; -import static org.apache.james.backend.rabbitmq.Constants.DURABLE; -import static org.apache.james.backend.rabbitmq.Constants.EMPTY_ROUTING_KEY; -import static org.apache.james.backend.rabbitmq.Constants.EXCLUSIVE; -import static org.apache.james.backend.rabbitmq.Constants.NO_ARGUMENTS; +import static org.apache.james.backends.rabbitmq.Constants.AUTO_DELETE; +import static org.apache.james.backends.rabbitmq.Constants.DIRECT_EXCHANGE; +import static org.apache.james.backends.rabbitmq.Constants.DURABLE; +import static org.apache.james.backends.rabbitmq.Constants.EMPTY_ROUTING_KEY; +import static org.apache.james.backends.rabbitmq.Constants.EXCLUSIVE; +import static org.apache.james.backends.rabbitmq.Constants.NO_ARGUMENTS; import static org.apache.james.mailbox.events.EventBusConcurrentTestContract.newCountingListener; import static org.apache.james.mailbox.events.EventBusTestFixture.ALL_GROUPS; import static org.apache.james.mailbox.events.EventBusTestFixture.EVENT; @@ -52,11 +52,11 @@ import java.nio.charset.StandardCharsets; import java.time.Duration; import java.util.concurrent.TimeUnit; -import org.apache.james.backend.rabbitmq.RabbitMQExtension; -import org.apache.james.backend.rabbitmq.RabbitMQExtension.DockerRestartPolicy; -import org.apache.james.backend.rabbitmq.RabbitMQFixture; -import org.apache.james.backend.rabbitmq.RabbitMQManagementAPI; -import org.apache.james.backend.rabbitmq.SimpleConnectionPool; +import org.apache.james.backends.rabbitmq.RabbitMQExtension; +import org.apache.james.backends.rabbitmq.RabbitMQExtension.DockerRestartPolicy; +import org.apache.james.backends.rabbitmq.RabbitMQFixture; +import org.apache.james.backends.rabbitmq.RabbitMQManagementAPI; +import org.apache.james.backends.rabbitmq.SimpleConnectionPool; import org.apache.james.event.json.EventSerializer; import org.apache.james.mailbox.events.EventBusTestFixture.GroupA; import org.apache.james.mailbox.events.EventBusTestFixture.MailboxListenerCountingSuccessfulExecution; diff --git a/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQAuthenticatePlainTest.java b/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQAuthenticatePlainTest.java index 71417b6..7884439 100644 --- a/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQAuthenticatePlainTest.java +++ b/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQAuthenticatePlainTest.java @@ -19,7 +19,7 @@ package org.apache.james.mpt.imapmailbox.rabbitmq; -import org.apache.james.backend.rabbitmq.DockerRabbitMQTestRule; +import org.apache.james.backends.rabbitmq.DockerRabbitMQTestRule; import org.apache.james.mpt.api.ImapHostSystem; import org.apache.james.mpt.imapmailbox.rabbitmq.host.RabbitMQEventBusHostSystemRule; import org.apache.james.mpt.imapmailbox.suite.AuthenticatePlain; diff --git a/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQAuthenticatedStateTest.java b/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQAuthenticatedStateTest.java index 0e830e2..12c5feb 100644 --- a/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQAuthenticatedStateTest.java +++ b/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQAuthenticatedStateTest.java @@ -19,7 +19,7 @@ package org.apache.james.mpt.imapmailbox.rabbitmq; -import org.apache.james.backend.rabbitmq.DockerRabbitMQTestRule; +import org.apache.james.backends.rabbitmq.DockerRabbitMQTestRule; import org.apache.james.mpt.api.ImapHostSystem; import org.apache.james.mpt.imapmailbox.rabbitmq.host.RabbitMQEventBusHostSystemRule; import org.apache.james.mpt.imapmailbox.suite.AuthenticatedState; diff --git a/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQConcurrentSessionsTest.java b/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQConcurrentSessionsTest.java index d3a259f..f2fa662 100644 --- a/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQConcurrentSessionsTest.java +++ b/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQConcurrentSessionsTest.java @@ -19,7 +19,7 @@ package org.apache.james.mpt.imapmailbox.rabbitmq; -import org.apache.james.backend.rabbitmq.DockerRabbitMQTestRule; +import org.apache.james.backends.rabbitmq.DockerRabbitMQTestRule; import org.apache.james.mpt.api.ImapHostSystem; import org.apache.james.mpt.imapmailbox.rabbitmq.host.RabbitMQEventBusHostSystemRule; import org.apache.james.mpt.imapmailbox.suite.ConcurrentSessions; diff --git a/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQCondstoreTest.java b/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQCondstoreTest.java index af8e899..2232338 100644 --- a/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQCondstoreTest.java +++ b/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQCondstoreTest.java @@ -19,7 +19,7 @@ package org.apache.james.mpt.imapmailbox.rabbitmq; -import org.apache.james.backend.rabbitmq.DockerRabbitMQTestRule; +import org.apache.james.backends.rabbitmq.DockerRabbitMQTestRule; import org.apache.james.mpt.host.JamesImapHostSystem; import org.apache.james.mpt.imapmailbox.rabbitmq.host.RabbitMQEventBusHostSystemRule; import org.apache.james.mpt.imapmailbox.suite.Condstore; diff --git a/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQCopyTest.java b/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQCopyTest.java index dd041b0..bcf7cde 100644 --- a/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQCopyTest.java +++ b/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQCopyTest.java @@ -19,7 +19,7 @@ package org.apache.james.mpt.imapmailbox.rabbitmq; -import org.apache.james.backend.rabbitmq.DockerRabbitMQTestRule; +import org.apache.james.backends.rabbitmq.DockerRabbitMQTestRule; import org.apache.james.mpt.api.ImapHostSystem; import org.apache.james.mpt.imapmailbox.rabbitmq.host.RabbitMQEventBusHostSystemRule; import org.apache.james.mpt.imapmailbox.suite.Copy; diff --git a/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQEventsTest.java b/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQEventsTest.java index 463789c..9dbd98c 100644 --- a/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQEventsTest.java +++ b/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQEventsTest.java @@ -19,7 +19,7 @@ package org.apache.james.mpt.imapmailbox.rabbitmq; -import org.apache.james.backend.rabbitmq.DockerRabbitMQTestRule; +import org.apache.james.backends.rabbitmq.DockerRabbitMQTestRule; import org.apache.james.mpt.api.ImapHostSystem; import org.apache.james.mpt.imapmailbox.rabbitmq.host.RabbitMQEventBusHostSystemRule; import org.apache.james.mpt.imapmailbox.suite.Events; diff --git a/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQFetchBodySectionTest.java b/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQFetchBodySectionTest.java index 3e24b2b..f6b8fc1 100644 --- a/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQFetchBodySectionTest.java +++ b/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQFetchBodySectionTest.java @@ -19,7 +19,7 @@ package org.apache.james.mpt.imapmailbox.rabbitmq; -import org.apache.james.backend.rabbitmq.DockerRabbitMQTestRule; +import org.apache.james.backends.rabbitmq.DockerRabbitMQTestRule; import org.apache.james.mpt.api.ImapHostSystem; import org.apache.james.mpt.imapmailbox.rabbitmq.host.RabbitMQEventBusHostSystemRule; import org.apache.james.mpt.imapmailbox.suite.FetchBodySection; diff --git a/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQFetchBodyStructureTest.java b/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQFetchBodyStructureTest.java index ad54345..c035570 100644 --- a/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQFetchBodyStructureTest.java +++ b/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQFetchBodyStructureTest.java @@ -19,7 +19,7 @@ package org.apache.james.mpt.imapmailbox.rabbitmq; -import org.apache.james.backend.rabbitmq.DockerRabbitMQTestRule; +import org.apache.james.backends.rabbitmq.DockerRabbitMQTestRule; import org.apache.james.mpt.api.ImapHostSystem; import org.apache.james.mpt.imapmailbox.rabbitmq.host.RabbitMQEventBusHostSystemRule; import org.apache.james.mpt.imapmailbox.suite.FetchBodyStructure; diff --git a/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQFetchHeadersTest.java b/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQFetchHeadersTest.java index 72d7c9e..a021a8d 100644 --- a/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQFetchHeadersTest.java +++ b/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQFetchHeadersTest.java @@ -19,7 +19,7 @@ package org.apache.james.mpt.imapmailbox.rabbitmq; -import org.apache.james.backend.rabbitmq.DockerRabbitMQTestRule; +import org.apache.james.backends.rabbitmq.DockerRabbitMQTestRule; import org.apache.james.mpt.api.ImapHostSystem; import org.apache.james.mpt.imapmailbox.rabbitmq.host.RabbitMQEventBusHostSystemRule; import org.apache.james.mpt.imapmailbox.suite.FetchHeaders; diff --git a/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQFetchTest.java b/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQFetchTest.java index 62a32cb..25749d0 100644 --- a/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQFetchTest.java +++ b/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQFetchTest.java @@ -19,7 +19,7 @@ package org.apache.james.mpt.imapmailbox.rabbitmq; -import org.apache.james.backend.rabbitmq.DockerRabbitMQTestRule; +import org.apache.james.backends.rabbitmq.DockerRabbitMQTestRule; import org.apache.james.mpt.api.ImapHostSystem; import org.apache.james.mpt.imapmailbox.rabbitmq.host.RabbitMQEventBusHostSystemRule; import org.apache.james.mpt.imapmailbox.suite.Fetch; diff --git a/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQListingTest.java b/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQListingTest.java index 035b7ec..f714173 100644 --- a/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQListingTest.java +++ b/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQListingTest.java @@ -19,7 +19,7 @@ package org.apache.james.mpt.imapmailbox.rabbitmq; -import org.apache.james.backend.rabbitmq.DockerRabbitMQTestRule; +import org.apache.james.backends.rabbitmq.DockerRabbitMQTestRule; import org.apache.james.mpt.api.ImapHostSystem; import org.apache.james.mpt.imapmailbox.rabbitmq.host.RabbitMQEventBusHostSystemRule; import org.apache.james.mpt.imapmailbox.suite.Listing; diff --git a/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQListingWithSharingTest.java b/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQListingWithSharingTest.java index 80f4f99..86288e2 100644 --- a/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQListingWithSharingTest.java +++ b/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQListingWithSharingTest.java @@ -19,7 +19,7 @@ package org.apache.james.mpt.imapmailbox.rabbitmq; -import org.apache.james.backend.rabbitmq.DockerRabbitMQTestRule; +import org.apache.james.backends.rabbitmq.DockerRabbitMQTestRule; import org.apache.james.mpt.api.ImapHostSystem; import org.apache.james.mpt.imapmailbox.rabbitmq.host.RabbitMQEventBusHostSystemRule; import org.apache.james.mpt.imapmailbox.suite.ListingWithSharingTest; diff --git a/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQMailboxAnnotationTest.java b/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQMailboxAnnotationTest.java index a5bb24b..d093a37 100644 --- a/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQMailboxAnnotationTest.java +++ b/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQMailboxAnnotationTest.java @@ -19,7 +19,7 @@ package org.apache.james.mpt.imapmailbox.rabbitmq; -import org.apache.james.backend.rabbitmq.DockerRabbitMQTestRule; +import org.apache.james.backends.rabbitmq.DockerRabbitMQTestRule; import org.apache.james.mpt.api.ImapHostSystem; import org.apache.james.mpt.imapmailbox.rabbitmq.host.RabbitMQEventBusHostSystemRule; import org.apache.james.mpt.imapmailbox.suite.MailboxAnnotation; diff --git a/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQMailboxWithLongNameErrorTest.java b/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQMailboxWithLongNameErrorTest.java index f7cbb42..15e2936 100644 --- a/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQMailboxWithLongNameErrorTest.java +++ b/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQMailboxWithLongNameErrorTest.java @@ -19,7 +19,7 @@ package org.apache.james.mpt.imapmailbox.rabbitmq; -import org.apache.james.backend.rabbitmq.DockerRabbitMQTestRule; +import org.apache.james.backends.rabbitmq.DockerRabbitMQTestRule; import org.apache.james.mpt.api.ImapHostSystem; import org.apache.james.mpt.imapmailbox.rabbitmq.host.RabbitMQEventBusHostSystemRule; import org.apache.james.mpt.imapmailbox.suite.MailboxWithLongNameError; diff --git a/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQMoveTest.java b/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQMoveTest.java index 428f024..5358cf7 100644 --- a/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQMoveTest.java +++ b/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQMoveTest.java @@ -19,7 +19,7 @@ package org.apache.james.mpt.imapmailbox.rabbitmq; -import org.apache.james.backend.rabbitmq.DockerRabbitMQTestRule; +import org.apache.james.backends.rabbitmq.DockerRabbitMQTestRule; import org.apache.james.mpt.api.ImapHostSystem; import org.apache.james.mpt.imapmailbox.rabbitmq.host.RabbitMQEventBusHostSystemRule; import org.apache.james.mpt.imapmailbox.suite.Move; diff --git a/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQNonAuthenticatedStateTest.java b/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQNonAuthenticatedStateTest.java index 8657056..ba1bbf4 100644 --- a/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQNonAuthenticatedStateTest.java +++ b/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQNonAuthenticatedStateTest.java @@ -19,7 +19,7 @@ package org.apache.james.mpt.imapmailbox.rabbitmq; -import org.apache.james.backend.rabbitmq.DockerRabbitMQTestRule; +import org.apache.james.backends.rabbitmq.DockerRabbitMQTestRule; import org.apache.james.mpt.api.ImapHostSystem; import org.apache.james.mpt.imapmailbox.rabbitmq.host.RabbitMQEventBusHostSystemRule; import org.apache.james.mpt.imapmailbox.suite.NonAuthenticatedState; diff --git a/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQPartialFetchTest.java b/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQPartialFetchTest.java index 75f4ba6..6773d25 100644 --- a/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQPartialFetchTest.java +++ b/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQPartialFetchTest.java @@ -19,7 +19,7 @@ package org.apache.james.mpt.imapmailbox.rabbitmq; -import org.apache.james.backend.rabbitmq.DockerRabbitMQTestRule; +import org.apache.james.backends.rabbitmq.DockerRabbitMQTestRule; import org.apache.james.mpt.api.ImapHostSystem; import org.apache.james.mpt.imapmailbox.rabbitmq.host.RabbitMQEventBusHostSystemRule; import org.apache.james.mpt.imapmailbox.suite.PartialFetch; diff --git a/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQQuotaTest.java b/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQQuotaTest.java index 9d94fd7..dd9b39f 100644 --- a/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQQuotaTest.java +++ b/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQQuotaTest.java @@ -19,7 +19,7 @@ package org.apache.james.mpt.imapmailbox.rabbitmq; -import org.apache.james.backend.rabbitmq.DockerRabbitMQTestRule; +import org.apache.james.backends.rabbitmq.DockerRabbitMQTestRule; import org.apache.james.mpt.api.ImapHostSystem; import org.apache.james.mpt.imapmailbox.rabbitmq.host.RabbitMQEventBusHostSystemRule; import org.apache.james.mpt.imapmailbox.suite.QuotaTest; diff --git a/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQRenameTest.java b/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQRenameTest.java index ea705a8..aa643ef 100644 --- a/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQRenameTest.java +++ b/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQRenameTest.java @@ -19,7 +19,7 @@ package org.apache.james.mpt.imapmailbox.rabbitmq; -import org.apache.james.backend.rabbitmq.DockerRabbitMQTestRule; +import org.apache.james.backends.rabbitmq.DockerRabbitMQTestRule; import org.apache.james.mpt.api.ImapHostSystem; import org.apache.james.mpt.imapmailbox.rabbitmq.host.RabbitMQEventBusHostSystemRule; import org.apache.james.mpt.imapmailbox.suite.Rename; diff --git a/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQSearchTest.java b/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQSearchTest.java index 65132bd..9d0f260 100644 --- a/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQSearchTest.java +++ b/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQSearchTest.java @@ -19,7 +19,7 @@ package org.apache.james.mpt.imapmailbox.rabbitmq; -import org.apache.james.backend.rabbitmq.DockerRabbitMQTestRule; +import org.apache.james.backends.rabbitmq.DockerRabbitMQTestRule; import org.apache.james.mpt.api.ImapHostSystem; import org.apache.james.mpt.imapmailbox.rabbitmq.host.RabbitMQEventBusHostSystemRule; import org.apache.james.mpt.imapmailbox.suite.Search; diff --git a/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQSecurityTest.java b/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQSecurityTest.java index 519b3b4..db61a4a 100644 --- a/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQSecurityTest.java +++ b/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQSecurityTest.java @@ -19,7 +19,7 @@ package org.apache.james.mpt.imapmailbox.rabbitmq; -import org.apache.james.backend.rabbitmq.DockerRabbitMQTestRule; +import org.apache.james.backends.rabbitmq.DockerRabbitMQTestRule; import org.apache.james.mpt.api.ImapHostSystem; import org.apache.james.mpt.imapmailbox.rabbitmq.host.RabbitMQEventBusHostSystemRule; import org.apache.james.mpt.imapmailbox.suite.Security; diff --git a/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQSelectTest.java b/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQSelectTest.java index 2c68d5c..750b2e1 100644 --- a/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQSelectTest.java +++ b/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQSelectTest.java @@ -19,7 +19,7 @@ package org.apache.james.mpt.imapmailbox.rabbitmq; -import org.apache.james.backend.rabbitmq.DockerRabbitMQTestRule; +import org.apache.james.backends.rabbitmq.DockerRabbitMQTestRule; import org.apache.james.mpt.api.ImapHostSystem; import org.apache.james.mpt.imapmailbox.rabbitmq.host.RabbitMQEventBusHostSystemRule; import org.apache.james.mpt.imapmailbox.suite.Select; diff --git a/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQSelectedInboxTest.java b/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQSelectedInboxTest.java index cd169a6..67502e1 100644 --- a/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQSelectedInboxTest.java +++ b/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQSelectedInboxTest.java @@ -19,7 +19,7 @@ package org.apache.james.mpt.imapmailbox.rabbitmq; -import org.apache.james.backend.rabbitmq.DockerRabbitMQTestRule; +import org.apache.james.backends.rabbitmq.DockerRabbitMQTestRule; import org.apache.james.mpt.api.ImapHostSystem; import org.apache.james.mpt.imapmailbox.rabbitmq.host.RabbitMQEventBusHostSystemRule; import org.apache.james.mpt.imapmailbox.suite.SelectedInbox; diff --git a/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQSelectedStateTest.java b/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQSelectedStateTest.java index 409c2b5..35387aa 100644 --- a/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQSelectedStateTest.java +++ b/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQSelectedStateTest.java @@ -19,7 +19,7 @@ package org.apache.james.mpt.imapmailbox.rabbitmq; -import org.apache.james.backend.rabbitmq.DockerRabbitMQTestRule; +import org.apache.james.backends.rabbitmq.DockerRabbitMQTestRule; import org.apache.james.mpt.api.ImapHostSystem; import org.apache.james.mpt.imapmailbox.rabbitmq.host.RabbitMQEventBusHostSystemRule; import org.apache.james.mpt.imapmailbox.suite.SelectedState; diff --git a/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQUidSearchTest.java b/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQUidSearchTest.java index a263a5f..6c27aa1 100644 --- a/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQUidSearchTest.java +++ b/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQUidSearchTest.java @@ -19,7 +19,7 @@ package org.apache.james.mpt.imapmailbox.rabbitmq; -import org.apache.james.backend.rabbitmq.DockerRabbitMQTestRule; +import org.apache.james.backends.rabbitmq.DockerRabbitMQTestRule; import org.apache.james.mpt.api.ImapHostSystem; import org.apache.james.mpt.imapmailbox.rabbitmq.host.RabbitMQEventBusHostSystemRule; import org.apache.james.mpt.imapmailbox.suite.UidSearch; diff --git a/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQUserFlagsSupportTest.java b/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQUserFlagsSupportTest.java index e737707..92dfe8f 100644 --- a/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQUserFlagsSupportTest.java +++ b/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/RabbitMQUserFlagsSupportTest.java @@ -19,7 +19,7 @@ package org.apache.james.mpt.imapmailbox.rabbitmq; -import org.apache.james.backend.rabbitmq.DockerRabbitMQTestRule; +import org.apache.james.backends.rabbitmq.DockerRabbitMQTestRule; import org.apache.james.mpt.api.ImapHostSystem; import org.apache.james.mpt.imapmailbox.rabbitmq.host.RabbitMQEventBusHostSystemRule; import org.apache.james.mpt.imapmailbox.suite.UserFlagsSupport; diff --git a/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/host/RabbitMQEventBusHostSystem.java b/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/host/RabbitMQEventBusHostSystem.java index c21b185..e93ac4f 100644 --- a/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/host/RabbitMQEventBusHostSystem.java +++ b/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/host/RabbitMQEventBusHostSystem.java @@ -23,8 +23,8 @@ package org.apache.james.mpt.imapmailbox.rabbitmq.host; import java.net.URISyntaxException; import java.util.concurrent.TimeUnit; -import org.apache.james.backend.rabbitmq.DockerRabbitMQ; -import org.apache.james.backend.rabbitmq.SimpleConnectionPool; +import org.apache.james.backends.rabbitmq.DockerRabbitMQ; +import org.apache.james.backends.rabbitmq.SimpleConnectionPool; import org.apache.james.core.quota.QuotaCount; import org.apache.james.core.quota.QuotaSize; import org.apache.james.event.json.EventSerializer; diff --git a/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/host/RabbitMQEventBusHostSystemRule.java b/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/host/RabbitMQEventBusHostSystemRule.java index d449eb0..8fb818b 100644 --- a/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/host/RabbitMQEventBusHostSystemRule.java +++ b/mpt/impl/imap-mailbox/rabbitmq/src/test/java/org/apache/james/mpt/imapmailbox/rabbitmq/host/RabbitMQEventBusHostSystemRule.java @@ -19,7 +19,7 @@ package org.apache.james.mpt.imapmailbox.rabbitmq.host; -import org.apache.james.backend.rabbitmq.DockerRabbitMQTestRule; +import org.apache.james.backends.rabbitmq.DockerRabbitMQTestRule; import org.junit.rules.TestRule; import org.junit.runner.Description; import org.junit.runners.model.Statement; diff --git a/mpt/impl/smtp/cassandra-rabbitmq-object-storage/src/test/java/org/apache/james/mpt/smtp/CassandraRabbitMQAwsS3SmtpTestRuleFactory.java b/mpt/impl/smtp/cassandra-rabbitmq-object-storage/src/test/java/org/apache/james/mpt/smtp/CassandraRabbitMQAwsS3SmtpTestRuleFactory.java index ed8fd35..5229411 100644 --- a/mpt/impl/smtp/cassandra-rabbitmq-object-storage/src/test/java/org/apache/james/mpt/smtp/CassandraRabbitMQAwsS3SmtpTestRuleFactory.java +++ b/mpt/impl/smtp/cassandra-rabbitmq-object-storage/src/test/java/org/apache/james/mpt/smtp/CassandraRabbitMQAwsS3SmtpTestRuleFactory.java @@ -22,7 +22,7 @@ import org.apache.commons.configuration2.BaseHierarchicalConfiguration; import org.apache.james.CassandraJamesServerMain; import org.apache.james.CleanupTasksPerformer; import org.apache.james.GuiceJamesServer; -import org.apache.james.backend.rabbitmq.DockerRabbitMQSingleton; +import org.apache.james.backends.rabbitmq.DockerRabbitMQSingleton; import org.apache.james.backends.cassandra.init.configuration.ClusterConfiguration; import org.apache.james.dnsservice.api.DNSService; import org.apache.james.modules.TestAwsS3BlobStoreModule; diff --git a/server/container/guice/cassandra-rabbitmq-guice/src/test/java/org/apache/james/CassandraRabbitMQAwsS3JmapTestRule.java b/server/container/guice/cassandra-rabbitmq-guice/src/test/java/org/apache/james/CassandraRabbitMQAwsS3JmapTestRule.java index e6c295b..e7fcab7 100644 --- a/server/container/guice/cassandra-rabbitmq-guice/src/test/java/org/apache/james/CassandraRabbitMQAwsS3JmapTestRule.java +++ b/server/container/guice/cassandra-rabbitmq-guice/src/test/java/org/apache/james/CassandraRabbitMQAwsS3JmapTestRule.java @@ -21,7 +21,7 @@ package org.apache.james; import java.io.IOException; -import org.apache.james.backend.rabbitmq.DockerRabbitMQSingleton; +import org.apache.james.backends.rabbitmq.DockerRabbitMQSingleton; import org.apache.james.mailbox.extractor.TextExtractor; import org.apache.james.mailbox.store.search.PDFTextExtractor; import org.apache.james.modules.TestDockerESMetricReporterModule; diff --git a/server/container/guice/cassandra-rabbitmq-guice/src/test/java/org/apache/james/CassandraRabbitMQSwiftJmapTestRule.java b/server/container/guice/cassandra-rabbitmq-guice/src/test/java/org/apache/james/CassandraRabbitMQSwiftJmapTestRule.java index f9e7918..e9a78ed 100644 --- a/server/container/guice/cassandra-rabbitmq-guice/src/test/java/org/apache/james/CassandraRabbitMQSwiftJmapTestRule.java +++ b/server/container/guice/cassandra-rabbitmq-guice/src/test/java/org/apache/james/CassandraRabbitMQSwiftJmapTestRule.java @@ -21,7 +21,7 @@ package org.apache.james; import java.io.IOException; -import org.apache.james.backend.rabbitmq.DockerRabbitMQSingleton; +import org.apache.james.backends.rabbitmq.DockerRabbitMQSingleton; import org.apache.james.mailbox.extractor.TextExtractor; import org.apache.james.mailbox.store.search.PDFTextExtractor; import org.apache.james.modules.TestDockerESMetricReporterModule; diff --git a/server/container/guice/cassandra-rabbitmq-guice/src/test/java/org/apache/james/modules/DockerRabbitMQRule.java b/server/container/guice/cassandra-rabbitmq-guice/src/test/java/org/apache/james/modules/DockerRabbitMQRule.java index 3e701a6..b107e2c 100644 --- a/server/container/guice/cassandra-rabbitmq-guice/src/test/java/org/apache/james/modules/DockerRabbitMQRule.java +++ b/server/container/guice/cassandra-rabbitmq-guice/src/test/java/org/apache/james/modules/DockerRabbitMQRule.java @@ -19,15 +19,15 @@ package org.apache.james.modules; -import static org.apache.james.backend.rabbitmq.RabbitMQFixture.DEFAULT_MANAGEMENT_CREDENTIAL; +import static org.apache.james.backends.rabbitmq.RabbitMQFixture.DEFAULT_MANAGEMENT_CREDENTIAL; import java.net.URISyntaxException; import org.apache.james.CleanupTasksPerformer; import org.apache.james.GuiceModuleTestRule; -import org.apache.james.backend.rabbitmq.DockerRabbitMQ; -import org.apache.james.backend.rabbitmq.DockerRabbitMQSingleton; -import org.apache.james.backend.rabbitmq.RabbitMQConfiguration; +import org.apache.james.backends.rabbitmq.DockerRabbitMQ; +import org.apache.james.backends.rabbitmq.DockerRabbitMQSingleton; +import org.apache.james.backends.rabbitmq.RabbitMQConfiguration; import org.junit.runner.Description; import org.junit.runners.model.Statement; diff --git a/server/container/guice/cassandra-rabbitmq-guice/src/test/java/org/apache/james/modules/RabbitMQExtension.java b/server/container/guice/cassandra-rabbitmq-guice/src/test/java/org/apache/james/modules/RabbitMQExtension.java index 6651549..2677b5a 100644 --- a/server/container/guice/cassandra-rabbitmq-guice/src/test/java/org/apache/james/modules/RabbitMQExtension.java +++ b/server/container/guice/cassandra-rabbitmq-guice/src/test/java/org/apache/james/modules/RabbitMQExtension.java @@ -20,7 +20,7 @@ package org.apache.james.modules; import org.apache.james.GuiceModuleTestExtension; -import org.apache.james.backend.rabbitmq.DockerRabbitMQ; +import org.apache.james.backends.rabbitmq.DockerRabbitMQ; import org.junit.jupiter.api.extension.ExtensionContext; import com.google.inject.Module; diff --git a/server/container/guice/cassandra-rabbitmq-guice/src/test/java/org/apache/james/modules/TestRabbitMQModule.java b/server/container/guice/cassandra-rabbitmq-guice/src/test/java/org/apache/james/modules/TestRabbitMQModule.java index 2118830..e17539b 100644 --- a/server/container/guice/cassandra-rabbitmq-guice/src/test/java/org/apache/james/modules/TestRabbitMQModule.java +++ b/server/container/guice/cassandra-rabbitmq-guice/src/test/java/org/apache/james/modules/TestRabbitMQModule.java @@ -19,7 +19,7 @@ package org.apache.james.modules; -import static org.apache.james.backend.rabbitmq.RabbitMQFixture.DEFAULT_MANAGEMENT_CREDENTIAL; +import static org.apache.james.backends.rabbitmq.RabbitMQFixture.DEFAULT_MANAGEMENT_CREDENTIAL; import java.net.URISyntaxException; import java.time.Duration; @@ -28,8 +28,8 @@ import javax.inject.Inject; import javax.inject.Singleton; import org.apache.james.CleanupTasksPerformer; -import org.apache.james.backend.rabbitmq.DockerRabbitMQ; -import org.apache.james.backend.rabbitmq.RabbitMQConfiguration; +import org.apache.james.backends.rabbitmq.DockerRabbitMQ; +import org.apache.james.backends.rabbitmq.RabbitMQConfiguration; import org.apache.james.queue.rabbitmq.RabbitMQMailQueueManagement; import org.apache.james.queue.rabbitmq.view.cassandra.configuration.CassandraMailQueueViewConfiguration; diff --git a/server/container/guice/rabbitmq/src/main/java/org/apache/james/modules/rabbitmq/RabbitMQModule.java b/server/container/guice/rabbitmq/src/main/java/org/apache/james/modules/rabbitmq/RabbitMQModule.java index b01a7bb..09a7bfe 100644 --- a/server/container/guice/rabbitmq/src/main/java/org/apache/james/modules/rabbitmq/RabbitMQModule.java +++ b/server/container/guice/rabbitmq/src/main/java/org/apache/james/modules/rabbitmq/RabbitMQModule.java @@ -25,11 +25,11 @@ import javax.inject.Singleton; import org.apache.commons.configuration2.Configuration; import org.apache.commons.configuration2.ex.ConfigurationException; -import org.apache.james.backend.rabbitmq.RabbitMQChannelPool; -import org.apache.james.backend.rabbitmq.RabbitMQConfiguration; -import org.apache.james.backend.rabbitmq.RabbitMQHealthCheck; -import org.apache.james.backend.rabbitmq.SimpleChannelPool; import org.apache.james.backends.cassandra.components.CassandraModule; +import org.apache.james.backends.rabbitmq.RabbitMQChannelPool; +import org.apache.james.backends.rabbitmq.RabbitMQConfiguration; +import org.apache.james.backends.rabbitmq.RabbitMQHealthCheck; +import org.apache.james.backends.rabbitmq.SimpleChannelPool; import org.apache.james.core.healthcheck.HealthCheck; import org.apache.james.eventsourcing.eventstore.cassandra.dto.EventDTOModule; import org.apache.james.queue.api.MailQueueFactory; diff --git a/server/queue/queue-rabbitmq/src/main/java/org/apache/james/queue/rabbitmq/RabbitClient.java b/server/queue/queue-rabbitmq/src/main/java/org/apache/james/queue/rabbitmq/RabbitClient.java index 4a19a8d..779e71e 100644 --- a/server/queue/queue-rabbitmq/src/main/java/org/apache/james/queue/rabbitmq/RabbitClient.java +++ b/server/queue/queue-rabbitmq/src/main/java/org/apache/james/queue/rabbitmq/RabbitClient.java @@ -19,17 +19,17 @@ package org.apache.james.queue.rabbitmq; -import static org.apache.james.backend.rabbitmq.Constants.AUTO_DELETE; -import static org.apache.james.backend.rabbitmq.Constants.DURABLE; -import static org.apache.james.backend.rabbitmq.Constants.EMPTY_ROUTING_KEY; -import static org.apache.james.backend.rabbitmq.Constants.EXCLUSIVE; -import static org.apache.james.backend.rabbitmq.Constants.NO_ARGUMENTS; +import static org.apache.james.backends.rabbitmq.Constants.AUTO_DELETE; +import static org.apache.james.backends.rabbitmq.Constants.DURABLE; +import static org.apache.james.backends.rabbitmq.Constants.EMPTY_ROUTING_KEY; +import static org.apache.james.backends.rabbitmq.Constants.EXCLUSIVE; +import static org.apache.james.backends.rabbitmq.Constants.NO_ARGUMENTS; import java.io.IOException; import javax.inject.Inject; -import org.apache.james.backend.rabbitmq.RabbitMQChannelPool; +import org.apache.james.backends.rabbitmq.RabbitMQChannelPool; import org.apache.james.queue.api.MailQueue; import com.rabbitmq.client.AMQP; diff --git a/server/queue/queue-rabbitmq/src/main/java/org/apache/james/queue/rabbitmq/RabbitMQMailQueueManagement.java b/server/queue/queue-rabbitmq/src/main/java/org/apache/james/queue/rabbitmq/RabbitMQMailQueueManagement.java index 4d0c261..c2a634c 100644 --- a/server/queue/queue-rabbitmq/src/main/java/org/apache/james/queue/rabbitmq/RabbitMQMailQueueManagement.java +++ b/server/queue/queue-rabbitmq/src/main/java/org/apache/james/queue/rabbitmq/RabbitMQMailQueueManagement.java @@ -23,8 +23,8 @@ import java.util.stream.Stream; import javax.inject.Inject; -import org.apache.james.backend.rabbitmq.RabbitMQConfiguration; -import org.apache.james.backend.rabbitmq.RabbitMQManagementAPI; +import org.apache.james.backends.rabbitmq.RabbitMQConfiguration; +import org.apache.james.backends.rabbitmq.RabbitMQManagementAPI; import org.apache.james.util.OptionalUtils; import com.google.common.annotations.VisibleForTesting; diff --git a/server/queue/queue-rabbitmq/src/test/java/org/apache/james/queue/rabbitmq/RabbitMQMailQueueConfigurationChangeTest.java b/server/queue/queue-rabbitmq/src/test/java/org/apache/james/queue/rabbitmq/RabbitMQMailQueueConfigurationChangeTest.java index 2e95d87..b17e938 100644 --- a/server/queue/queue-rabbitmq/src/test/java/org/apache/james/queue/rabbitmq/RabbitMQMailQueueConfigurationChangeTest.java +++ b/server/queue/queue-rabbitmq/src/test/java/org/apache/james/queue/rabbitmq/RabbitMQMailQueueConfigurationChangeTest.java @@ -31,7 +31,7 @@ import java.util.function.Function; import java.util.stream.IntStream; import java.util.stream.Stream; -import org.apache.james.backend.rabbitmq.RabbitMQExtension; +import org.apache.james.backends.rabbitmq.RabbitMQExtension; import org.apache.james.backends.cassandra.CassandraCluster; import org.apache.james.backends.cassandra.CassandraClusterExtension; import org.apache.james.backends.cassandra.components.CassandraModule; diff --git a/server/queue/queue-rabbitmq/src/test/java/org/apache/james/queue/rabbitmq/RabbitMQMailQueueTest.java b/server/queue/queue-rabbitmq/src/test/java/org/apache/james/queue/rabbitmq/RabbitMQMailQueueTest.java index 6e9abdf..703b233 100644 --- a/server/queue/queue-rabbitmq/src/test/java/org/apache/james/queue/rabbitmq/RabbitMQMailQueueTest.java +++ b/server/queue/queue-rabbitmq/src/test/java/org/apache/james/queue/rabbitmq/RabbitMQMailQueueTest.java @@ -30,8 +30,8 @@ import java.util.function.Function; import java.util.stream.IntStream; import java.util.stream.Stream; -import org.apache.james.backend.rabbitmq.DockerRabbitMQ; -import org.apache.james.backend.rabbitmq.RabbitMQExtension; +import org.apache.james.backends.rabbitmq.DockerRabbitMQ; +import org.apache.james.backends.rabbitmq.RabbitMQExtension; import org.apache.james.backends.cassandra.CassandraCluster; import org.apache.james.backends.cassandra.CassandraClusterExtension; import org.apache.james.backends.cassandra.components.CassandraModule; diff --git a/server/queue/queue-rabbitmq/src/test/java/org/apache/james/queue/rabbitmq/RabbitMqMailQueueFactoryTest.java b/server/queue/queue-rabbitmq/src/test/java/org/apache/james/queue/rabbitmq/RabbitMqMailQueueFactoryTest.java index a432c4f..6280d41 100644 --- a/server/queue/queue-rabbitmq/src/test/java/org/apache/james/queue/rabbitmq/RabbitMqMailQueueFactoryTest.java +++ b/server/queue/queue-rabbitmq/src/test/java/org/apache/james/queue/rabbitmq/RabbitMqMailQueueFactoryTest.java @@ -29,7 +29,7 @@ import java.time.Duration; import java.util.Set; import java.util.concurrent.ConcurrentHashMap; -import org.apache.james.backend.rabbitmq.RabbitMQExtension; +import org.apache.james.backends.rabbitmq.RabbitMQExtension; import org.apache.james.blob.api.HashBlobId; import org.apache.james.blob.mail.MimeMessageStore; import org.apache.james.metrics.api.NoopGaugeRegistry; diff --git a/server/task-distributed/src/main/java/org/apache/james/task/eventsourcing/distributed/RabbitMQTerminationSubscriber.java b/server/task-distributed/src/main/java/org/apache/james/task/eventsourcing/distributed/RabbitMQTerminationSubscriber.java index 89d6e96..fd8317a 100644 --- a/server/task-distributed/src/main/java/org/apache/james/task/eventsourcing/distributed/RabbitMQTerminationSubscriber.java +++ b/server/task-distributed/src/main/java/org/apache/james/task/eventsourcing/distributed/RabbitMQTerminationSubscriber.java @@ -28,8 +28,8 @@ import java.util.UUID; import javax.annotation.PreDestroy; import javax.inject.Inject; -import org.apache.james.backend.rabbitmq.ReactorRabbitMQChannelPool; -import org.apache.james.backend.rabbitmq.SimpleConnectionPool; +import org.apache.james.backends.rabbitmq.ReactorRabbitMQChannelPool; +import org.apache.james.backends.rabbitmq.SimpleConnectionPool; import org.apache.james.eventsourcing.Event; import org.apache.james.eventsourcing.eventstore.cassandra.JsonEventSerializer; import org.apache.james.lifecycle.api.Startable; diff --git a/server/task-distributed/src/main/java/org/apache/james/task/eventsourcing/distributed/RabbitMQWorkQueue.java b/server/task-distributed/src/main/java/org/apache/james/task/eventsourcing/distributed/RabbitMQWorkQueue.java index 7b80e6d..34b3f5b 100644 --- a/server/task-distributed/src/main/java/org/apache/james/task/eventsourcing/distributed/RabbitMQWorkQueue.java +++ b/server/task-distributed/src/main/java/org/apache/james/task/eventsourcing/distributed/RabbitMQWorkQueue.java @@ -26,8 +26,8 @@ import java.util.UUID; import javax.annotation.PreDestroy; -import org.apache.james.backend.rabbitmq.ReactorRabbitMQChannelPool; -import org.apache.james.backend.rabbitmq.SimpleConnectionPool; +import org.apache.james.backends.rabbitmq.ReactorRabbitMQChannelPool; +import org.apache.james.backends.rabbitmq.SimpleConnectionPool; import org.apache.james.lifecycle.api.Startable; import org.apache.james.server.task.json.JsonTaskSerializer; import org.apache.james.task.Task; diff --git a/server/task-distributed/src/main/scala/org/apache/james/task/eventsourcing/distributed/RabbitMQWorkQueueSupplier.scala b/server/task-distributed/src/main/scala/org/apache/james/task/eventsourcing/distributed/RabbitMQWorkQueueSupplier.scala index fc5d7e2..5e26147 100644 --- a/server/task-distributed/src/main/scala/org/apache/james/task/eventsourcing/distributed/RabbitMQWorkQueueSupplier.scala +++ b/server/task-distributed/src/main/scala/org/apache/james/task/eventsourcing/distributed/RabbitMQWorkQueueSupplier.scala @@ -19,7 +19,8 @@ package org.apache.james.task.eventsourcing.distributed import javax.inject.Inject -import org.apache.james.backend.rabbitmq.SimpleConnectionPool + +import org.apache.james.backends.rabbitmq.SimpleConnectionPool import org.apache.james.eventsourcing.EventSourcingSystem import org.apache.james.server.task.json.JsonTaskSerializer import org.apache.james.task.eventsourcing.{WorkQueueSupplier, WorkerStatusListener} diff --git a/server/task-distributed/src/test/java/org/apache/james/task/eventsourcing/distributed/DistributedTaskManagerTest.java b/server/task-distributed/src/test/java/org/apache/james/task/eventsourcing/distributed/DistributedTaskManagerTest.java index a8e43c5..767d0ff 100644 --- a/server/task-distributed/src/test/java/org/apache/james/task/eventsourcing/distributed/DistributedTaskManagerTest.java +++ b/server/task-distributed/src/test/java/org/apache/james/task/eventsourcing/distributed/DistributedTaskManagerTest.java @@ -27,7 +27,7 @@ import java.util.concurrent.CountDownLatch; import java.util.concurrent.TimeUnit; import org.apache.commons.lang3.tuple.Pair; -import org.apache.james.backend.rabbitmq.RabbitMQExtension; +import org.apache.james.backends.rabbitmq.RabbitMQExtension; import org.apache.james.backends.cassandra.CassandraCluster; import org.apache.james.backends.cassandra.CassandraClusterExtension; import org.apache.james.backends.cassandra.components.CassandraModule; diff --git a/server/task-distributed/src/test/java/org/apache/james/task/eventsourcing/distributed/RabbitMQTerminationSubscriberTest.java b/server/task-distributed/src/test/java/org/apache/james/task/eventsourcing/distributed/RabbitMQTerminationSubscriberTest.java index ec48a42..9da45e8 100644 --- a/server/task-distributed/src/test/java/org/apache/james/task/eventsourcing/distributed/RabbitMQTerminationSubscriberTest.java +++ b/server/task-distributed/src/test/java/org/apache/james/task/eventsourcing/distributed/RabbitMQTerminationSubscriberTest.java @@ -25,7 +25,7 @@ import static org.assertj.core.api.Assertions.assertThat; import java.util.List; import java.util.Set; -import org.apache.james.backend.rabbitmq.RabbitMQExtension; +import org.apache.james.backends.rabbitmq.RabbitMQExtension; import org.apache.james.eventsourcing.Event; import org.apache.james.eventsourcing.eventstore.cassandra.JsonEventSerializer; import org.apache.james.eventsourcing.eventstore.cassandra.dto.EventDTOModule; diff --git a/server/task-distributed/src/test/java/org/apache/james/task/eventsourcing/distributed/RabbitMQWorkQueueTest.java b/server/task-distributed/src/test/java/org/apache/james/task/eventsourcing/distributed/RabbitMQWorkQueueTest.java index 2383695..1615ecc 100644 --- a/server/task-distributed/src/test/java/org/apache/james/task/eventsourcing/distributed/RabbitMQWorkQueueTest.java +++ b/server/task-distributed/src/test/java/org/apache/james/task/eventsourcing/distributed/RabbitMQWorkQueueTest.java @@ -30,7 +30,7 @@ import static org.mockito.Mockito.when; import java.util.stream.IntStream; -import org.apache.james.backend.rabbitmq.RabbitMQExtension; +import org.apache.james.backends.rabbitmq.RabbitMQExtension; import org.apache.james.server.task.json.JsonTaskSerializer; import org.apache.james.server.task.json.TestTask; import org.apache.james.server.task.json.dto.TestTaskDTOModules; --------------------------------------------------------------------- To unsubscribe, e-mail: server-dev-unsubscr...@james.apache.org For additional commands, e-mail: server-dev-h...@james.apache.org