diff --git a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/AbstractAxonServerIT.java b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/AbstractAxonServerIT.java deleted file mode 100644 index d7b9f31d1a..0000000000 --- a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/AbstractAxonServerIT.java +++ /dev/null @@ -1,107 +0,0 @@ -/* - * Copyright (c) 2010-2026. Axon Framework - * - * Licensed 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.axonframework.integrationtests.testsuite; - -import org.axonframework.axonserver.connector.AxonServerConfiguration; -import org.axonframework.common.configuration.ApplicationConfigurer; -import org.axonframework.common.configuration.AxonConfiguration; -import org.axonframework.messaging.commandhandling.gateway.CommandGateway; -import org.axonframework.test.server.AxonServerContainer; -import org.axonframework.test.server.AxonServerContainerUtils; -import org.junit.jupiter.api.*; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -import java.io.IOException; -import java.util.Random; - -/** - * Abstract test suite for integration tests using an AxonServerContainer. Concrete implementations have to provide a - * specific {@link ApplicationConfigurer}. The server is started using the default {@link AxonServerConfiguration}. The - * started configuration and the associated {@link CommandGateway} are available through member-variables. - * - * @author Mitchell Herrijgers - */ -public abstract class AbstractAxonServerIT { - - protected static final Logger logger = LoggerFactory.getLogger(AbstractAxonServerIT.class); - - private static final AxonServerContainer container = - new AxonServerContainer("docker.axoniq.io/axoniq/axonserver:2025.2.0") - .withAxonServerHostname("localhost") - .withDevMode(true) - .withReuse(true) - .withDcbContext(true); - - protected CommandGateway commandGateway; - protected AxonConfiguration startedConfiguration; - - @BeforeAll - static void beforeAll() { - container.start(); - logger.info("Using Axon Server for integration test. UI is available at http://localhost:{}", - container.getHttpPort()); - } - - @AfterEach - void tearDown() { - if (startedConfiguration != null) { - startedConfiguration.shutdown(); - } - } - - protected void startApp() { - AxonServerConfiguration axonServerConfiguration = new AxonServerConfiguration(); - axonServerConfiguration.setServers(container.getHost() + ":" + container.getGrpcPort()); - startedConfiguration = createConfigurer().componentRegistry(cr -> cr.registerComponent( - AxonServerConfiguration.class, c -> axonServerConfiguration - )) - .start(); - commandGateway = startedConfiguration.getComponent(CommandGateway.class); - } - - /** - * Creates the {@link ApplicationConfigurer} defining the Axon Framework test context. - * - * @return The {@link ApplicationConfigurer} defining the Axon Framework test context. - */ - protected abstract ApplicationConfigurer createConfigurer(); - - private static final Random RND = new Random(); - - protected static String createId(String prefix) { - return prefix + "-" + RND.nextInt(Integer.MAX_VALUE); - } - - /** - * Purges all events from the AxonServer event storage. This method can be called before tests to ensure a clean - * state, preventing events from previous test runs from affecting the current test. - */ - protected void purgeEventStorage() { - try { - logger.info("Purging events from Axon Server."); - AxonServerContainerUtils.purgeEventsFromAxonServer( - container.getHost(), - container.getHttpPort(), - "default", - AxonServerContainerUtils.DCB_CONTEXT - ); - } catch (IOException e) { - throw new RuntimeException("Failed to purge event storage", e); - } - } -} diff --git a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/AbstractAxonServerIntegrationTest.java b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/AbstractAxonServerIntegrationTest.java deleted file mode 100644 index 41401a90fb..0000000000 --- a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/AbstractAxonServerIntegrationTest.java +++ /dev/null @@ -1,86 +0,0 @@ -/* - * Copyright (c) 2010-2026. Axon Framework - * - * Licensed 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.axonframework.integrationtests.testsuite; - -import org.axonframework.axonserver.connector.AxonServerConfiguration; -import org.axonframework.messaging.commandhandling.gateway.CommandGateway; -import org.axonframework.common.configuration.ApplicationConfigurer; -import org.axonframework.common.configuration.AxonConfiguration; -import org.axonframework.test.server.AxonServerContainer; -import org.junit.jupiter.api.*; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -import java.util.Random; - -/** - * Abstract test suite for integration tests using an AxonServerContainer. Concrete implementations have to provide a - * specific {@link ApplicationConfigurer}. The server is started using the default {@link AxonServerConfiguration}. The - * started configuration and the associated {@link CommandGateway} are available through member-variables. - * - * @author Mitchell Herrijgers - */ -public abstract class AbstractAxonServerIntegrationTest { - - protected static final Logger logger = LoggerFactory.getLogger(AbstractAxonServerIntegrationTest.class); - - private static final AxonServerContainer container = new AxonServerContainer("docker.axoniq.io/axoniq/axonserver:2025.2.0") - .withAxonServerHostname("localhost") - .withDevMode(true) - .withReuse(true) - .withDcbContext(true); - - protected CommandGateway commandGateway; - protected AxonConfiguration startedConfiguration; - - @BeforeAll - static void beforeAll() { - container.start(); - logger.info("Using Axon Server for integration test. UI is available at http://localhost:{}", - container.getHttpPort()); - } - - @AfterEach - void tearDown() { - if (startedConfiguration != null) { - startedConfiguration.shutdown(); - } - } - - protected void startApp() { - AxonServerConfiguration axonServerConfiguration = new AxonServerConfiguration(); - axonServerConfiguration.setServers(container.getHost() + ":" + container.getGrpcPort()); - startedConfiguration = createConfigurer().componentRegistry(cr -> cr.registerComponent( - AxonServerConfiguration.class, c -> axonServerConfiguration - )) - .start(); - commandGateway = startedConfiguration.getComponent(CommandGateway.class); - } - - /** - * Creates the {@link ApplicationConfigurer} defining the Axon Framework test context. - * - * @return The {@link ApplicationConfigurer} defining the Axon Framework test context. - */ - protected abstract ApplicationConfigurer createConfigurer(); - - private static final Random RND = new Random(); - - protected static final String createId(String prefix) { - return prefix + "-" + RND.nextInt(Integer.MAX_VALUE); - } -} \ No newline at end of file diff --git a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/AbstractIntegrationTest.java b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/AbstractIntegrationTest.java new file mode 100644 index 0000000000..f9682d732b --- /dev/null +++ b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/AbstractIntegrationTest.java @@ -0,0 +1,126 @@ +/* + * Copyright (c) 2010-2026. Axon Framework + * + * Licensed 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.axonframework.integrationtests.testsuite; + +import org.axonframework.common.annotation.Internal; +import org.axonframework.common.configuration.ApplicationConfigurer; +import org.axonframework.common.configuration.AxonConfiguration; +import org.axonframework.integrationtests.testsuite.infrastructure.TestInfrastructure; +import org.axonframework.messaging.commandhandling.gateway.CommandGateway; +import org.junit.jupiter.api.AfterEach; + +import java.util.UUID; + +/** + * Infrastructure-agnostic base class for all integration tests in this suite. + *

+ * The specific backend (AxonServer, InMemory, Postgres, …) is supplied by leaf test classes through + * {@link #testInfrastructure()}. + *

+ * Subclasses must implement: + *

+ * and must call {@link #startApp()} (typically from a {@code @BeforeEach} method) to start the Axon configuration. + * + * @author Mateusz Nowak + * @since 5.1.0 + */ +@Internal +public abstract class AbstractIntegrationTest { + + protected CommandGateway commandGateway; + protected AxonConfiguration startedConfiguration; + + /** + * Returns the {@link TestInfrastructure} for this test. Leaf classes typically return a {@code private static + * final} instance so the infrastructure wrapper (and any heavy resources it guards, such as a shared + * Testcontainer) is created once per leaf class: + * 
{@code
+     * private static final TestInfrastructure INFRASTRUCTURE = new AxonServerTestInfrastructure();
+     *
+     * @Override
+     * protected TestInfrastructure testInfrastructure() {
+     *     return INFRASTRUCTURE;
+     * }
+     * }
+ * + * @return the infrastructure strategy to use for this test + */ + protected abstract TestInfrastructure testInfrastructure(); + + /** + * Returns the domain-specific {@link ApplicationConfigurer} for this test. Called from {@link #startApp()} each + * time the Axon configuration is started. + * + * @return the application configurer for this test + */ + protected abstract ApplicationConfigurer applicationConfigurer(); + + /** + * Shuts down the Axon configuration and releases infrastructure resources acquired during {@link #startApp()}. + * The infrastructure is only stopped when {@link #startApp()} actually completed, signalled by a non-null + * {@link #startedConfiguration}. + */ + @AfterEach + void tearDown() { + if (startedConfiguration == null) { + return; + } + try { + startedConfiguration.shutdown(); + } finally { + testInfrastructure().stop(); + } + } + + /** + * Starts the Axon Framework application using the configured infrastructure and domain configurer. + *

+ * Subclasses must call this method (directly or via {@code super.startApp()}) from a {@code @BeforeEach} method. + * The infrastructure's {@link TestInfrastructure#start()} is invoked first (idempotent), followed by building and + * starting the {@link AxonConfiguration}. + */ + protected void startApp() { + TestInfrastructure infra = testInfrastructure(); + infra.start(); + startedConfiguration = applicationConfigurer() + .componentRegistry(infra::configureInfrastructure) + .start(); + commandGateway = startedConfiguration.getComponent(CommandGateway.class); + } + + /** + * Purges persisted data via the current {@link TestInfrastructure}. Opt-in — only tests that require a clean + * initial state (e.g. event-replay tests) should call this method. + */ + protected void purgeData() { + testInfrastructure().purgeData(); + } + + /** + * Creates a unique ID string with the given {@code prefix}, suitable for use as an aggregate or entity identifier + * in tests. + * + * @param prefix a human-readable prefix for the generated ID + * @return a unique identifier string + */ + protected static String createId(String prefix) { + return prefix + "-" + UUID.randomUUID(); + } +} diff --git a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/administration/AbstractAdministrationIT.java b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/administration/AbstractAdministrationIT.java index d21427db74..d4dc8e45c6 100644 --- a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/administration/AbstractAdministrationIT.java +++ b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/administration/AbstractAdministrationIT.java @@ -18,7 +18,7 @@ import org.axonframework.common.configuration.ApplicationConfigurer; import org.axonframework.eventsourcing.configuration.EventSourcingConfigurer; -import org.axonframework.integrationtests.testsuite.AbstractAxonServerIT; +import org.axonframework.integrationtests.testsuite.AbstractIntegrationTest; import org.axonframework.integrationtests.testsuite.administration.commands.AssignTaskCommand; import org.axonframework.integrationtests.testsuite.administration.commands.ChangeEmailAddress; import org.axonframework.integrationtests.testsuite.administration.commands.CompleteTaskCommand; @@ -37,7 +37,7 @@ * Test suite for verifying polymorphic behavior of entities. Can be implemented by different test classes that verify * different ways of building the {@link org.axonframework.modelling.entity.EntityCommandHandlingComponent}. */ -public abstract class AbstractAdministrationIT extends AbstractAxonServerIT { +public abstract class AbstractAdministrationIT extends AbstractIntegrationTest { private final CreateEmployee CREATE_EMPLOYEE_1_COMMAND = new CreateEmployee( new PersonIdentifier(PersonType.EMPLOYEE, createId("employee")), @@ -56,7 +56,7 @@ public void doStartApp() { } @Override - protected ApplicationConfigurer createConfigurer() { + protected ApplicationConfigurer applicationConfigurer() { var configurer = EventSourcingConfigurer.create(); return testSuiteConfigurer(configurer); } diff --git a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/administration/ImmutableBuilderEntityModelAdministrationAxonServerIT.java b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/administration/ImmutableBuilderEntityModelAdministrationAxonServerIT.java new file mode 100644 index 0000000000..9e55e8eee9 --- /dev/null +++ b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/administration/ImmutableBuilderEntityModelAdministrationAxonServerIT.java @@ -0,0 +1,34 @@ +/* + * Copyright (c) 2010-2026. Axon Framework + * + * Licensed 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.axonframework.integrationtests.testsuite.administration; + +import org.axonframework.integrationtests.testsuite.infrastructure.AxonServerTestInfrastructure; +import org.axonframework.integrationtests.testsuite.infrastructure.TestInfrastructure; + +/** + * Runs {@link ImmutableBuilderEntityModelAdministrationIT} against a real Axon Server instance. + */ +public class ImmutableBuilderEntityModelAdministrationAxonServerIT + extends ImmutableBuilderEntityModelAdministrationIT { + + private static final TestInfrastructure INFRASTRUCTURE = new AxonServerTestInfrastructure(); + + @Override + protected TestInfrastructure testInfrastructure() { + return INFRASTRUCTURE; + } +} diff --git a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/administration/ImmutableBuilderEntityModelAdministrationIT.java b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/administration/ImmutableBuilderEntityModelAdministrationIT.java index bb25246740..0789e4db18 100644 --- a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/administration/ImmutableBuilderEntityModelAdministrationIT.java +++ b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/administration/ImmutableBuilderEntityModelAdministrationIT.java @@ -54,7 +54,7 @@ /** * Runs the administration test suite using the builders of {@link EntityMetamodel} and related classes. */ -public class ImmutableBuilderEntityModelAdministrationIT extends AbstractAdministrationIT { +public abstract class ImmutableBuilderEntityModelAdministrationIT extends AbstractAdministrationIT { EntityMetamodel buildEntityMetamodel(Configuration configuration, EntityMetamodelBuilder builder) { diff --git a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/administration/ImmutableBuilderEntityModelAdministrationInMemoryIT.java b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/administration/ImmutableBuilderEntityModelAdministrationInMemoryIT.java new file mode 100644 index 0000000000..c90604b736 --- /dev/null +++ b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/administration/ImmutableBuilderEntityModelAdministrationInMemoryIT.java @@ -0,0 +1,34 @@ +/* + * Copyright (c) 2010-2026. Axon Framework + * + * Licensed 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.axonframework.integrationtests.testsuite.administration; + +import org.axonframework.integrationtests.testsuite.infrastructure.InMemoryTestInfrastructure; +import org.axonframework.integrationtests.testsuite.infrastructure.TestInfrastructure; + +/** + * Runs {@link ImmutableBuilderEntityModelAdministrationIT} against the in-memory framework defaults. + */ +public class ImmutableBuilderEntityModelAdministrationInMemoryIT + extends ImmutableBuilderEntityModelAdministrationIT { + + private static final TestInfrastructure INFRASTRUCTURE = new InMemoryTestInfrastructure(); + + @Override + protected TestInfrastructure testInfrastructure() { + return INFRASTRUCTURE; + } +} diff --git a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/administration/ImmutableReflectionEntityModelAdministrationAxonServerIT.java b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/administration/ImmutableReflectionEntityModelAdministrationAxonServerIT.java new file mode 100644 index 0000000000..3f629ec898 --- /dev/null +++ b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/administration/ImmutableReflectionEntityModelAdministrationAxonServerIT.java @@ -0,0 +1,34 @@ +/* + * Copyright (c) 2010-2026. Axon Framework + * + * Licensed 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.axonframework.integrationtests.testsuite.administration; + +import org.axonframework.integrationtests.testsuite.infrastructure.AxonServerTestInfrastructure; +import org.axonframework.integrationtests.testsuite.infrastructure.TestInfrastructure; + +/** + * Runs {@link ImmutableReflectionEntityModelAdministrationIT} against a real Axon Server instance. + */ +public class ImmutableReflectionEntityModelAdministrationAxonServerIT + extends ImmutableReflectionEntityModelAdministrationIT { + + private static final TestInfrastructure INFRASTRUCTURE = new AxonServerTestInfrastructure(); + + @Override + protected TestInfrastructure testInfrastructure() { + return INFRASTRUCTURE; + } +} diff --git a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/administration/ImmutableReflectionEntityModelAdministrationIT.java b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/administration/ImmutableReflectionEntityModelAdministrationIT.java index 09e4102584..19729a0ad3 100644 --- a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/administration/ImmutableReflectionEntityModelAdministrationIT.java +++ b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/administration/ImmutableReflectionEntityModelAdministrationIT.java @@ -26,7 +26,7 @@ * Runs the administration test suite using as many reflection components of the {@link EntityMetamodel} and related * classes as possible. As reflection-based components are added, this test may change to use more of them. */ -public class ImmutableReflectionEntityModelAdministrationIT extends AbstractAdministrationIT { +public abstract class ImmutableReflectionEntityModelAdministrationIT extends AbstractAdministrationIT { @Override protected EventSourcingConfigurer testSuiteConfigurer(EventSourcingConfigurer configurer) { diff --git a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/administration/ImmutableReflectionEntityModelAdministrationInMemoryIT.java b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/administration/ImmutableReflectionEntityModelAdministrationInMemoryIT.java new file mode 100644 index 0000000000..dde91a8b26 --- /dev/null +++ b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/administration/ImmutableReflectionEntityModelAdministrationInMemoryIT.java @@ -0,0 +1,34 @@ +/* + * Copyright (c) 2010-2026. Axon Framework + * + * Licensed 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.axonframework.integrationtests.testsuite.administration; + +import org.axonframework.integrationtests.testsuite.infrastructure.InMemoryTestInfrastructure; +import org.axonframework.integrationtests.testsuite.infrastructure.TestInfrastructure; + +/** + * Runs {@link ImmutableReflectionEntityModelAdministrationIT} against the in-memory framework defaults. + */ +public class ImmutableReflectionEntityModelAdministrationInMemoryIT + extends ImmutableReflectionEntityModelAdministrationIT { + + private static final TestInfrastructure INFRASTRUCTURE = new InMemoryTestInfrastructure(); + + @Override + protected TestInfrastructure testInfrastructure() { + return INFRASTRUCTURE; + } +} diff --git a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/administration/MutableBuilderEntityModelAdministrationAxonServerIT.java b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/administration/MutableBuilderEntityModelAdministrationAxonServerIT.java new file mode 100644 index 0000000000..f4bb2ff353 --- /dev/null +++ b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/administration/MutableBuilderEntityModelAdministrationAxonServerIT.java @@ -0,0 +1,34 @@ +/* + * Copyright (c) 2010-2026. Axon Framework + * + * Licensed 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.axonframework.integrationtests.testsuite.administration; + +import org.axonframework.integrationtests.testsuite.infrastructure.AxonServerTestInfrastructure; +import org.axonframework.integrationtests.testsuite.infrastructure.TestInfrastructure; + +/** + * Runs {@link MutableBuilderEntityModelAdministrationIT} against a real Axon Server instance. + */ +public class MutableBuilderEntityModelAdministrationAxonServerIT + extends MutableBuilderEntityModelAdministrationIT { + + private static final TestInfrastructure INFRASTRUCTURE = new AxonServerTestInfrastructure(); + + @Override + protected TestInfrastructure testInfrastructure() { + return INFRASTRUCTURE; + } +} diff --git a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/administration/MutableBuilderEntityModelAdministrationIT.java b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/administration/MutableBuilderEntityModelAdministrationIT.java index c15956f9c6..35170800e7 100644 --- a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/administration/MutableBuilderEntityModelAdministrationIT.java +++ b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/administration/MutableBuilderEntityModelAdministrationIT.java @@ -51,7 +51,7 @@ /** * Runs the administration test suite using the builders of {@link EntityMetamodel} and related classes. */ -public class MutableBuilderEntityModelAdministrationIT extends AbstractAdministrationIT { +public abstract class MutableBuilderEntityModelAdministrationIT extends AbstractAdministrationIT { EntityMetamodel buildEntityMetamodel(Configuration configuration, EntityMetamodelBuilder builder) { diff --git a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/administration/MutableBuilderEntityModelAdministrationInMemoryIT.java b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/administration/MutableBuilderEntityModelAdministrationInMemoryIT.java new file mode 100644 index 0000000000..1eaf8db874 --- /dev/null +++ b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/administration/MutableBuilderEntityModelAdministrationInMemoryIT.java @@ -0,0 +1,34 @@ +/* + * Copyright (c) 2010-2026. Axon Framework + * + * Licensed 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.axonframework.integrationtests.testsuite.administration; + +import org.axonframework.integrationtests.testsuite.infrastructure.InMemoryTestInfrastructure; +import org.axonframework.integrationtests.testsuite.infrastructure.TestInfrastructure; + +/** + * Runs {@link MutableBuilderEntityModelAdministrationIT} against the in-memory framework defaults. + */ +public class MutableBuilderEntityModelAdministrationInMemoryIT + extends MutableBuilderEntityModelAdministrationIT { + + private static final TestInfrastructure INFRASTRUCTURE = new InMemoryTestInfrastructure(); + + @Override + protected TestInfrastructure testInfrastructure() { + return INFRASTRUCTURE; + } +} diff --git a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/administration/MutableReflectionEntityModelAdministrationAxonServerIT.java b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/administration/MutableReflectionEntityModelAdministrationAxonServerIT.java new file mode 100644 index 0000000000..cbd7d53778 --- /dev/null +++ b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/administration/MutableReflectionEntityModelAdministrationAxonServerIT.java @@ -0,0 +1,34 @@ +/* + * Copyright (c) 2010-2026. Axon Framework + * + * Licensed 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.axonframework.integrationtests.testsuite.administration; + +import org.axonframework.integrationtests.testsuite.infrastructure.AxonServerTestInfrastructure; +import org.axonframework.integrationtests.testsuite.infrastructure.TestInfrastructure; + +/** + * Runs {@link MutableReflectionEntityModelAdministrationIT} against a real Axon Server instance. + */ +public class MutableReflectionEntityModelAdministrationAxonServerIT + extends MutableReflectionEntityModelAdministrationIT { + + private static final TestInfrastructure INFRASTRUCTURE = new AxonServerTestInfrastructure(); + + @Override + protected TestInfrastructure testInfrastructure() { + return INFRASTRUCTURE; + } +} diff --git a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/administration/MutableReflectionEntityModelAdministrationIT.java b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/administration/MutableReflectionEntityModelAdministrationIT.java index 5b0f5efdf8..1d1e72d47e 100644 --- a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/administration/MutableReflectionEntityModelAdministrationIT.java +++ b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/administration/MutableReflectionEntityModelAdministrationIT.java @@ -26,7 +26,7 @@ * Runs the administration test suite using as many reflection components of the {@link EntityMetamodel} and related * classes as possible. As reflection-based components are added, this test may change to use more of them. */ -public class MutableReflectionEntityModelAdministrationIT extends AbstractAdministrationIT { +public abstract class MutableReflectionEntityModelAdministrationIT extends AbstractAdministrationIT { @Override protected EventSourcingConfigurer testSuiteConfigurer(EventSourcingConfigurer configurer) { diff --git a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/administration/MutableReflectionEntityModelAdministrationInMemoryIT.java b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/administration/MutableReflectionEntityModelAdministrationInMemoryIT.java new file mode 100644 index 0000000000..708ab1b389 --- /dev/null +++ b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/administration/MutableReflectionEntityModelAdministrationInMemoryIT.java @@ -0,0 +1,34 @@ +/* + * Copyright (c) 2010-2026. Axon Framework + * + * Licensed 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.axonframework.integrationtests.testsuite.administration; + +import org.axonframework.integrationtests.testsuite.infrastructure.InMemoryTestInfrastructure; +import org.axonframework.integrationtests.testsuite.infrastructure.TestInfrastructure; + +/** + * Runs {@link MutableReflectionEntityModelAdministrationIT} against the in-memory framework defaults. + */ +public class MutableReflectionEntityModelAdministrationInMemoryIT + extends MutableReflectionEntityModelAdministrationIT { + + private static final TestInfrastructure INFRASTRUCTURE = new InMemoryTestInfrastructure(); + + @Override + protected TestInfrastructure testInfrastructure() { + return INFRASTRUCTURE; + } +} diff --git a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/administration/SealedReflectionEntityModelAdministrationAxonServerIT.java b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/administration/SealedReflectionEntityModelAdministrationAxonServerIT.java new file mode 100644 index 0000000000..798be8fa62 --- /dev/null +++ b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/administration/SealedReflectionEntityModelAdministrationAxonServerIT.java @@ -0,0 +1,34 @@ +/* + * Copyright (c) 2010-2026. Axon Framework + * + * Licensed 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.axonframework.integrationtests.testsuite.administration; + +import org.axonframework.integrationtests.testsuite.infrastructure.AxonServerTestInfrastructure; +import org.axonframework.integrationtests.testsuite.infrastructure.TestInfrastructure; + +/** + * Runs {@link SealedReflectionEntityModelAdministrationIT} against a real Axon Server instance. + */ +public class SealedReflectionEntityModelAdministrationAxonServerIT + extends SealedReflectionEntityModelAdministrationIT { + + private static final TestInfrastructure INFRASTRUCTURE = new AxonServerTestInfrastructure(); + + @Override + protected TestInfrastructure testInfrastructure() { + return INFRASTRUCTURE; + } +} diff --git a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/administration/SealedReflectionEntityModelAdministrationIT.java b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/administration/SealedReflectionEntityModelAdministrationIT.java index f6ac1a61d7..3cb79c9d3a 100644 --- a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/administration/SealedReflectionEntityModelAdministrationIT.java +++ b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/administration/SealedReflectionEntityModelAdministrationIT.java @@ -26,7 +26,7 @@ * Runs the administration test suite using as many reflection components of the {@link EntityMetamodel} and related * classes as possible. As reflection-based components are added, this test may change to use more of them. */ -public class SealedReflectionEntityModelAdministrationIT extends AbstractAdministrationIT { +public abstract class SealedReflectionEntityModelAdministrationIT extends AbstractAdministrationIT { @Override protected EventSourcingConfigurer testSuiteConfigurer(EventSourcingConfigurer configurer) { diff --git a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/administration/SealedReflectionEntityModelAdministrationInMemoryIT.java b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/administration/SealedReflectionEntityModelAdministrationInMemoryIT.java new file mode 100644 index 0000000000..e9f9987d96 --- /dev/null +++ b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/administration/SealedReflectionEntityModelAdministrationInMemoryIT.java @@ -0,0 +1,34 @@ +/* + * Copyright (c) 2010-2026. Axon Framework + * + * Licensed 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.axonframework.integrationtests.testsuite.administration; + +import org.axonframework.integrationtests.testsuite.infrastructure.InMemoryTestInfrastructure; +import org.axonframework.integrationtests.testsuite.infrastructure.TestInfrastructure; + +/** + * Runs {@link SealedReflectionEntityModelAdministrationIT} against the in-memory framework defaults. + */ +public class SealedReflectionEntityModelAdministrationInMemoryIT + extends SealedReflectionEntityModelAdministrationIT { + + private static final TestInfrastructure INFRASTRUCTURE = new InMemoryTestInfrastructure(); + + @Override + protected TestInfrastructure testInfrastructure() { + return INFRASTRUCTURE; + } +} diff --git a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/course/SealedClassCourseAxonServerIT.java b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/course/SealedClassCourseAxonServerIT.java new file mode 100644 index 0000000000..dc2ed9b7c7 --- /dev/null +++ b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/course/SealedClassCourseAxonServerIT.java @@ -0,0 +1,33 @@ +/* + * Copyright (c) 2010-2026. Axon Framework + * + * Licensed 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.axonframework.integrationtests.testsuite.course; + +import org.axonframework.integrationtests.testsuite.infrastructure.AxonServerTestInfrastructure; +import org.axonframework.integrationtests.testsuite.infrastructure.TestInfrastructure; + +/** + * Runs {@link SealedClassCourseIT} against a real Axon Server instance. + */ +public class SealedClassCourseAxonServerIT extends SealedClassCourseIT { + + private static final TestInfrastructure INFRASTRUCTURE = new AxonServerTestInfrastructure(); + + @Override + protected TestInfrastructure testInfrastructure() { + return INFRASTRUCTURE; + } +} diff --git a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/course/SealedClassCourseIT.java b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/course/SealedClassCourseIT.java index eff07d1b53..1167c68d88 100644 --- a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/course/SealedClassCourseIT.java +++ b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/course/SealedClassCourseIT.java @@ -19,7 +19,7 @@ import org.axonframework.common.configuration.ApplicationConfigurer; import org.axonframework.eventsourcing.configuration.EventSourcedEntityModule; import org.axonframework.eventsourcing.configuration.EventSourcingConfigurer; -import org.axonframework.integrationtests.testsuite.AbstractAxonServerIT; +import org.axonframework.integrationtests.testsuite.AbstractIntegrationTest; import org.axonframework.integrationtests.testsuite.course.commands.CreateCourse; import org.axonframework.integrationtests.testsuite.course.commands.PublishCourse; import org.axonframework.integrationtests.testsuite.course.module.SealedClassCourseCommandHandlers; @@ -32,12 +32,12 @@ import static org.junit.jupiter.api.Assertions.*; -class SealedClassCourseIT extends AbstractAxonServerIT { +public abstract class SealedClassCourseIT extends AbstractIntegrationTest { protected UnitOfWorkFactory unitOfWorkFactory; @Override - protected ApplicationConfigurer createConfigurer() { + protected ApplicationConfigurer applicationConfigurer() { // configuration example see https://github.com/holixon/emn-kotlin/blob/8de05d6f3601df5de3d17e23066b2c7cef836d86/examples/university/src/main/kotlin/faculty/write/renamecoursepolymorph/RenameCoursePolymorphConfiguration.kt final var configurer = EventSourcingConfigurer.create(); final var courseEntity = EventSourcedEntityModule.autodetected(String.class, diff --git a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/course/SealedClassCourseInMemoryIT.java b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/course/SealedClassCourseInMemoryIT.java new file mode 100644 index 0000000000..389f6b507d --- /dev/null +++ b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/course/SealedClassCourseInMemoryIT.java @@ -0,0 +1,33 @@ +/* + * Copyright (c) 2010-2026. Axon Framework + * + * Licensed 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.axonframework.integrationtests.testsuite.course; + +import org.axonframework.integrationtests.testsuite.infrastructure.InMemoryTestInfrastructure; +import org.axonframework.integrationtests.testsuite.infrastructure.TestInfrastructure; + +/** + * Runs {@link SealedClassCourseIT} against the in-memory framework defaults. + */ +public class SealedClassCourseInMemoryIT extends SealedClassCourseIT { + + private static final TestInfrastructure INFRASTRUCTURE = new InMemoryTestInfrastructure(); + + @Override + protected TestInfrastructure testInfrastructure() { + return INFRASTRUCTURE; + } +} diff --git a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/infrastructure/AxonServerTestInfrastructure.java b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/infrastructure/AxonServerTestInfrastructure.java new file mode 100644 index 0000000000..5bd8a03704 --- /dev/null +++ b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/infrastructure/AxonServerTestInfrastructure.java @@ -0,0 +1,97 @@ +/* + * Copyright (c) 2010-2026. Axon Framework + * + * Licensed 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.axonframework.integrationtests.testsuite.infrastructure; + +import org.axonframework.axonserver.connector.AxonServerConfiguration; +import org.axonframework.common.configuration.ComponentRegistry; +import org.axonframework.test.server.AxonServerContainer; +import org.axonframework.test.server.AxonServerContainerUtils; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +import java.io.IOException; + +/** + * {@link TestInfrastructure} implementation that wires tests against a real Axon Server instance managed by + * Testcontainers. + *

+ * The underlying {@link AxonServerContainer} is a {@code static final} field, so it is shared across all instances of + * this class and all leaf test classes that use it. {@link AxonServerContainer#start()} is idempotent — Testcontainers + * makes it a no-op when the container is already running — so calling {@link #start()} from every {@code @BeforeEach} + * is safe and cheap after the first test. + *

+ * Leaf test classes should hold a {@code private static final} instance of this class: + * 

{@code
+ * private static final TestInfrastructure INFRASTRUCTURE = new AxonServerTestInfrastructure();
+ *
+ * @Override
+ * protected TestInfrastructure testInfrastructure() {
+ *     return INFRASTRUCTURE;
+ * }
+ * }
+ * + * @since 5.1.0 + */ +public final class AxonServerTestInfrastructure implements TestInfrastructure { + + private static final Logger LOG = LoggerFactory.getLogger(AxonServerTestInfrastructure.class); + + private static final AxonServerContainer CONTAINER = + new AxonServerContainer("docker.axoniq.io/axoniq/axonserver:latest") + .withAxonServerHostname("localhost") + .withDevMode(true) + .withReuse(true) + .withDcbContext(true); + + @Override + public void start() { + boolean wasRunning = CONTAINER.isRunning(); + CONTAINER.start(); + if (!wasRunning) { + LOG.info("Axon Server UI at http://localhost:{}", CONTAINER.getHttpPort()); + } + } + + @Override + public void configureInfrastructure(ComponentRegistry registry) { + AxonServerConfiguration config = new AxonServerConfiguration(); + config.setServers(CONTAINER.getHost() + ":" + CONTAINER.getGrpcPort()); + registry.registerComponent(AxonServerConfiguration.class, c -> config); + } + + @Override + public void purgeData() { + try { + LOG.info("Purging events from Axon Server."); + AxonServerContainerUtils.purgeEventsFromAxonServer( + CONTAINER.getHost(), + CONTAINER.getHttpPort(), + "default", + AxonServerContainerUtils.DCB_CONTEXT + ); + } catch (IOException e) { + throw new RuntimeException("Failed to purge AxonServer event storage", e); + } + } + + @Override + public void stop() { + // The container is shared across the JVM (static final, withReuse(true)). + // Testcontainers + Ryuk handle cleanup on JVM exit; stopping per test would + // defeat reuse. No-op on purpose. + } +} diff --git a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/infrastructure/InMemoryTestInfrastructure.java b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/infrastructure/InMemoryTestInfrastructure.java new file mode 100644 index 0000000000..531c98b29e --- /dev/null +++ b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/infrastructure/InMemoryTestInfrastructure.java @@ -0,0 +1,83 @@ +/* + * Copyright (c) 2010-2026. Axon Framework + * + * Licensed 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.axonframework.integrationtests.testsuite.infrastructure; + +import org.axonframework.common.configuration.ComponentRegistry; + +/** + * {@link TestInfrastructure} implementation that uses the framework's default in-memory components. + *

+ * No containers are started. The only configuration step is disabling the AxonServer enhancer so that classpath + * scanning does not replace the in-memory defaults ({@code SimpleCommandBus}, {@code SimpleQueryBus}, + * {@code InMemoryEventStorageEngine}) with distributed AxonServer equivalents. + *

+ * Data "purging" is a no-op: each test shuts down and recreates the + * {@link org.axonframework.common.configuration.AxonConfiguration} via + * {@link org.axonframework.integrationtests.testsuite.AbstractIntegrationTest#startApp()}, so the in-memory stores + * are always fresh at the start of every test. + *

+ * Leaf test classes should hold a {@code private static final} instance of this class: + * 

{@code
+ * private static final TestInfrastructure INFRASTRUCTURE = new InMemoryTestInfrastructure();
+ *
+ * @Override
+ * protected TestInfrastructure testInfrastructure() {
+ *     return INFRASTRUCTURE;
+ * }
+ * }
+ * + * @since 5.1.0 + */ +public final class InMemoryTestInfrastructure implements TestInfrastructure { + + /** + * FQCN string used to disable the AxonServer configuration enhancer without introducing a compile-time dependency + * on the {@code axon-server-connector} module. The {@link ComponentRegistry#disableEnhancer(String)} overload + * treats "enhancer not found on classpath" and "enhancer found and disabled" identically, so this is safe even in + * environments where the connector JAR is absent. + *

+ */ + private static final String AXONIQ_SERVER_ENHANCER_FQCN = + "io.axoniq.framework.axonserver.connector.configuration.AxonServerConfigurationEnhancer"; + private static final String AXON_SERVER_ENHANCER_FQCN = // TODO #4412 - remove as a part of this task + "org.axonframework.axonserver.connector.AxonServerConfigurationEnhancer"; + + @Override + public void start() { + // No containers to start. + } + + @Override + public void configureInfrastructure(ComponentRegistry registry) { + // Prevent the AxonServer enhancer from replacing the in-memory defaults. + // EventSourcingConfigurationDefaults already provides InMemoryEventStorageEngine; + // MessagingConfigurationDefaults provides SimpleCommandBus / SimpleQueryBus. + registry.disableEnhancer(AXON_SERVER_ENHANCER_FQCN); + registry.disableEnhancer(AXONIQ_SERVER_ENHANCER_FQCN); + } + + @Override + public void purgeData() { + // No-op: the configuration is recreated from scratch in every startApp() call, + // so in-memory stores are always empty at the beginning of each test. + } + + @Override + public void stop() { + // Nothing to release — no containers, no pools, no external resources. + } +} diff --git a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/infrastructure/TestInfrastructure.java b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/infrastructure/TestInfrastructure.java new file mode 100644 index 0000000000..1371e3cc32 --- /dev/null +++ b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/infrastructure/TestInfrastructure.java @@ -0,0 +1,68 @@ +/* + * Copyright (c) 2010-2026. Axon Framework + * + * Licensed 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.axonframework.integrationtests.testsuite.infrastructure; + +import org.axonframework.common.annotation.Internal; +import org.axonframework.common.configuration.ComponentRegistry; + +/** + * Strategy interface that encapsulates the lifecycle and configuration of a specific test infrastructure backend (e.g. + * AxonServer via Testcontainers, pure in-memory, JDBC, etc.). + *

+ * An implementation is provided by each concrete leaf test class via + * {@link org.axonframework.integrationtests.testsuite.AbstractIntegrationTest#testInfrastructure()}. Leaf classes + * typically return a {@code private static final} singleton, so {@link #start()} and {@link #stop()} are guaranteed to + * receive the same object across test methods. + * + * @author Mateusz Nowak + * @since 5.1.0 + */ +@Internal +public interface TestInfrastructure { + + /** + * Start the infrastructure (e.g. launch a Testcontainer). Must be idempotent — calling {@code start()} on an + * already-running infrastructure must be a safe no-op. + */ + void start(); + + /** + * Register infrastructure-specific components or disable unwanted enhancers in the given {@code registry}. Called + * once per test, just before the {@link org.axonframework.common.configuration.AxonConfiguration} is started. + * + * @param registry the registry to configure + */ + void configureInfrastructure(ComponentRegistry registry); + + /** + * Purge persisted data so the next test starts with a clean slate. Opt-in — only tests that require a clean + * initial state need to call {@link org.axonframework.integrationtests.testsuite.AbstractIntegrationTest#purgeData()}. + *

+ * For in-memory backends this is typically a no-op because the configuration is recreated per test anyway. + */ + void purgeData(); + + /** + * Release resources acquired during {@link #start()}. Called from the base class's {@code @AfterEach} after the + * {@link org.axonframework.common.configuration.AxonConfiguration} has been shut down. + *

+ * For shared/reused containers (e.g. {@code withReuse(true)} Testcontainers), this is typically a no-op — + * Testcontainers + Ryuk handle JVM-exit cleanup. The hook exists so future backends (e.g. Postgres with per-suite + * schema isolation) have a defined place to release resources. + */ + void stop(); +} diff --git a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/AbstractStudentIT.java b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/AbstractStudentIT.java index 36533b5afd..1f989ed25a 100644 --- a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/AbstractStudentIT.java +++ b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/AbstractStudentIT.java @@ -22,7 +22,7 @@ import org.axonframework.eventsourcing.EventSourcedEntityFactory; import org.axonframework.eventsourcing.configuration.EventSourcedEntityModule; import org.axonframework.eventsourcing.configuration.EventSourcingConfigurer; -import org.axonframework.integrationtests.testsuite.AbstractAxonServerIT; +import org.axonframework.integrationtests.testsuite.AbstractIntegrationTest; import org.axonframework.integrationtests.testsuite.student.events.StudentEnrolledEvent; import org.axonframework.integrationtests.testsuite.student.state.Course; import org.axonframework.integrationtests.testsuite.student.state.Student; @@ -55,7 +55,7 @@ * @author Mitchell Herrijgers * @author Steven van Beelen */ -public abstract class AbstractStudentIT extends AbstractAxonServerIT { +public abstract class AbstractStudentIT extends AbstractIntegrationTest { protected static final GenericCommandResultMessage SUCCESSFUL_COMMAND_RESULT = new GenericCommandResultMessage(new MessageType("empty"), "successful"); @@ -87,7 +87,7 @@ protected void prepareModule() { } @Override - protected ApplicationConfigurer createConfigurer() { + protected ApplicationConfigurer applicationConfigurer() { var configurer = EventSourcingConfigurer.create() .componentRegistry(cr -> cr.registerModule(studentEntity)) .componentRegistry(cr -> cr.registerModule(courseEntity)); diff --git a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/CommandHandlingInterceptorsAxonServerIT.java b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/CommandHandlingInterceptorsAxonServerIT.java new file mode 100644 index 0000000000..57a5c19986 --- /dev/null +++ b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/CommandHandlingInterceptorsAxonServerIT.java @@ -0,0 +1,33 @@ +/* + * Copyright (c) 2010-2026. Axon Framework + * + * Licensed 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.axonframework.integrationtests.testsuite.student; + +import org.axonframework.integrationtests.testsuite.infrastructure.AxonServerTestInfrastructure; +import org.axonframework.integrationtests.testsuite.infrastructure.TestInfrastructure; + +/** + * Runs {@link CommandHandlingInterceptorsIT} against a real Axon Server instance. + */ +public class CommandHandlingInterceptorsAxonServerIT extends CommandHandlingInterceptorsIT { + + private static final TestInfrastructure INFRASTRUCTURE = new AxonServerTestInfrastructure(); + + @Override + protected TestInfrastructure testInfrastructure() { + return INFRASTRUCTURE; + } +} diff --git a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/CommandHandlingInterceptorsIT.java b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/CommandHandlingInterceptorsIT.java index d409c6cc70..0b475be6ec 100644 --- a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/CommandHandlingInterceptorsIT.java +++ b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/CommandHandlingInterceptorsIT.java @@ -46,7 +46,7 @@ * * @author Mateusz Nowak */ -class CommandHandlingInterceptorsIT extends AbstractCommandHandlingStudentIT { +public abstract class CommandHandlingInterceptorsIT extends AbstractCommandHandlingStudentIT { private final String student1 = createId("student-1"); diff --git a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/CommandHandlingInterceptorsInMemoryIT.java b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/CommandHandlingInterceptorsInMemoryIT.java new file mode 100644 index 0000000000..a9dc6040ee --- /dev/null +++ b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/CommandHandlingInterceptorsInMemoryIT.java @@ -0,0 +1,33 @@ +/* + * Copyright (c) 2010-2026. Axon Framework + * + * Licensed 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.axonframework.integrationtests.testsuite.student; + +import org.axonframework.integrationtests.testsuite.infrastructure.InMemoryTestInfrastructure; +import org.axonframework.integrationtests.testsuite.infrastructure.TestInfrastructure; + +/** + * Runs {@link CommandHandlingInterceptorsIT} against the in-memory framework defaults. + */ +public class CommandHandlingInterceptorsInMemoryIT extends CommandHandlingInterceptorsIT { + + private static final TestInfrastructure INFRASTRUCTURE = new InMemoryTestInfrastructure(); + + @Override + protected TestInfrastructure testInfrastructure() { + return INFRASTRUCTURE; + } +} diff --git a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/CommandPayloadConversionIT.java b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/CommandPayloadConversionIT.java index 014541aaaa..c271eec53e 100644 --- a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/CommandPayloadConversionIT.java +++ b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/CommandPayloadConversionIT.java @@ -16,6 +16,8 @@ package org.axonframework.integrationtests.testsuite.student; +import org.axonframework.integrationtests.testsuite.infrastructure.AxonServerTestInfrastructure; +import org.axonframework.integrationtests.testsuite.infrastructure.TestInfrastructure; import org.axonframework.integrationtests.testsuite.student.commands.EnrollStudentToCourseCommand; import org.axonframework.messaging.commandhandling.CommandMessage; import org.axonframework.messaging.commandhandling.CommandResultMessage; @@ -35,6 +37,15 @@ */ class CommandPayloadConversionIT extends AbstractCommandHandlingStudentIT { + // AxonServer-only: payload conversion is a distributed-bus concern. + // SimpleCommandBus passes the payload through without serialization, so there is no in-memory equivalent. + private static final TestInfrastructure INFRASTRUCTURE = new AxonServerTestInfrastructure(); + + @Override + protected TestInfrastructure testInfrastructure() { + return INFRASTRUCTURE; + } + @Test void commandAndResultSupportInlinePayloadConversion() throws InterruptedException, ExecutionException { diff --git a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/CommandSequencingAxonServerIT.java b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/CommandSequencingAxonServerIT.java new file mode 100644 index 0000000000..acfa91e99f --- /dev/null +++ b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/CommandSequencingAxonServerIT.java @@ -0,0 +1,33 @@ +/* + * Copyright (c) 2010-2026. Axon Framework + * + * Licensed 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.axonframework.integrationtests.testsuite.student; + +import org.axonframework.integrationtests.testsuite.infrastructure.AxonServerTestInfrastructure; +import org.axonframework.integrationtests.testsuite.infrastructure.TestInfrastructure; + +/** + * Runs {@link CommandSequencingIT} against a real Axon Server instance. + */ +public class CommandSequencingAxonServerIT extends CommandSequencingIT { + + private static final TestInfrastructure INFRASTRUCTURE = new AxonServerTestInfrastructure(); + + @Override + protected TestInfrastructure testInfrastructure() { + return INFRASTRUCTURE; + } +} diff --git a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/CommandSequencingIT.java b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/CommandSequencingIT.java index be598f7f78..eb9ad9a8ac 100644 --- a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/CommandSequencingIT.java +++ b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/CommandSequencingIT.java @@ -53,7 +53,7 @@ * * @author Jakob Hatzl */ -class CommandSequencingIT extends AbstractCommandHandlingStudentIT { +public abstract class CommandSequencingIT extends AbstractCommandHandlingStudentIT { public static final String ROUTING_KEY_METADATA_KEY = "CommandSequencingIT#routingKey"; diff --git a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/CommandSequencingInMemoryIT.java b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/CommandSequencingInMemoryIT.java new file mode 100644 index 0000000000..1f89a8511c --- /dev/null +++ b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/CommandSequencingInMemoryIT.java @@ -0,0 +1,33 @@ +/* + * Copyright (c) 2010-2026. Axon Framework + * + * Licensed 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.axonframework.integrationtests.testsuite.student; + +import org.axonframework.integrationtests.testsuite.infrastructure.InMemoryTestInfrastructure; +import org.axonframework.integrationtests.testsuite.infrastructure.TestInfrastructure; + +/** + * Runs {@link CommandSequencingIT} against the in-memory framework defaults. + */ +public class CommandSequencingInMemoryIT extends CommandSequencingIT { + + private static final TestInfrastructure INFRASTRUCTURE = new InMemoryTestInfrastructure(); + + @Override + protected TestInfrastructure testInfrastructure() { + return INFRASTRUCTURE; + } +} diff --git a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/CompoundEntityIdentifierCommandHandlingComponentAxonServerIT.java b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/CompoundEntityIdentifierCommandHandlingComponentAxonServerIT.java new file mode 100644 index 0000000000..1ebeaaaa87 --- /dev/null +++ b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/CompoundEntityIdentifierCommandHandlingComponentAxonServerIT.java @@ -0,0 +1,34 @@ +/* + * Copyright (c) 2010-2026. Axon Framework + * + * Licensed 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.axonframework.integrationtests.testsuite.student; + +import org.axonframework.integrationtests.testsuite.infrastructure.AxonServerTestInfrastructure; +import org.axonframework.integrationtests.testsuite.infrastructure.TestInfrastructure; + +/** + * Runs {@link CompoundEntityIdentifierCommandHandlingComponentIT} against a real Axon Server instance. + */ +public class CompoundEntityIdentifierCommandHandlingComponentAxonServerIT + extends CompoundEntityIdentifierCommandHandlingComponentIT { + + private static final TestInfrastructure INFRASTRUCTURE = new AxonServerTestInfrastructure(); + + @Override + protected TestInfrastructure testInfrastructure() { + return INFRASTRUCTURE; + } +} diff --git a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/CompoundEntityIdentifierCommandHandlingComponentIT.java b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/CompoundEntityIdentifierCommandHandlingComponentIT.java index 7e78693eab..e840cfb960 100644 --- a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/CompoundEntityIdentifierCommandHandlingComponentIT.java +++ b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/CompoundEntityIdentifierCommandHandlingComponentIT.java @@ -45,7 +45,7 @@ * * @author Mitchell Herrijgers */ -class CompoundEntityIdentifierCommandHandlingComponentIT extends AbstractCommandHandlingStudentIT { +public abstract class CompoundEntityIdentifierCommandHandlingComponentIT extends AbstractCommandHandlingStudentIT { private final String student1 = createId("student-1"); private final String student2 = createId("student-2"); private final String student3 = createId("student-3"); @@ -130,12 +130,10 @@ private void verifyMentorLogicForComponent() { // But not a second time assertThatThrownBy(() -> sendCommand(new AssignMentorCommand(student1, student3))) - .isInstanceOf(CommandExecutionException.class) .hasMessageContaining("Mentee already has a mentor"); // And a third student can't become the mentee of the second, because the second is already a mentor assertThatThrownBy(() -> sendCommand(new AssignMentorCommand(student3, student2))) - .isInstanceOf(CommandExecutionException.class) .hasMessageContaining("Mentor already assigned to a mentee"); // But the mentee can become a mentor for a third student diff --git a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/CompoundEntityIdentifierCommandHandlingComponentInMemoryIT.java b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/CompoundEntityIdentifierCommandHandlingComponentInMemoryIT.java new file mode 100644 index 0000000000..39faeace24 --- /dev/null +++ b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/CompoundEntityIdentifierCommandHandlingComponentInMemoryIT.java @@ -0,0 +1,34 @@ +/* + * Copyright (c) 2010-2026. Axon Framework + * + * Licensed 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.axonframework.integrationtests.testsuite.student; + +import org.axonframework.integrationtests.testsuite.infrastructure.InMemoryTestInfrastructure; +import org.axonframework.integrationtests.testsuite.infrastructure.TestInfrastructure; + +/** + * Runs {@link CompoundEntityIdentifierCommandHandlingComponentIT} against the in-memory framework defaults. + */ +public class CompoundEntityIdentifierCommandHandlingComponentInMemoryIT + extends CompoundEntityIdentifierCommandHandlingComponentIT { + + private static final TestInfrastructure INFRASTRUCTURE = new InMemoryTestInfrastructure(); + + @Override + protected TestInfrastructure testInfrastructure() { + return INFRASTRUCTURE; + } +} diff --git a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/EventProcessingAnnotatedEventSourcedPooledStreamingAxonServerIT.java b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/EventProcessingAnnotatedEventSourcedPooledStreamingAxonServerIT.java new file mode 100644 index 0000000000..c34291a091 --- /dev/null +++ b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/EventProcessingAnnotatedEventSourcedPooledStreamingAxonServerIT.java @@ -0,0 +1,34 @@ +/* + * Copyright (c) 2010-2026. Axon Framework + * + * Licensed 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.axonframework.integrationtests.testsuite.student; + +import org.axonframework.integrationtests.testsuite.infrastructure.AxonServerTestInfrastructure; +import org.axonframework.integrationtests.testsuite.infrastructure.TestInfrastructure; + +/** + * Runs {@link EventProcessingAnnotatedEventSourcedPooledStreamingIT} against a real Axon Server instance. + */ +public class EventProcessingAnnotatedEventSourcedPooledStreamingAxonServerIT + extends EventProcessingAnnotatedEventSourcedPooledStreamingIT { + + private static final TestInfrastructure INFRASTRUCTURE = new AxonServerTestInfrastructure(); + + @Override + protected TestInfrastructure testInfrastructure() { + return INFRASTRUCTURE; + } +} diff --git a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/EventProcessingAnnotatedEventSourcedPooledStreamingIT.java b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/EventProcessingAnnotatedEventSourcedPooledStreamingIT.java index 8df8a99f0b..77d44c76cc 100644 --- a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/EventProcessingAnnotatedEventSourcedPooledStreamingIT.java +++ b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/EventProcessingAnnotatedEventSourcedPooledStreamingIT.java @@ -57,7 +57,7 @@ * @author Mateusz Nowak * @since 5.0.0 */ -public class EventProcessingAnnotatedEventSourcedPooledStreamingIT extends AbstractStudentIT { +public abstract class EventProcessingAnnotatedEventSourcedPooledStreamingIT extends AbstractStudentIT { @Test void whenStudentEnrolled3CoursesThenSendNotificationTest() { diff --git a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/EventProcessingAnnotatedEventSourcedPooledStreamingInMemoryIT.java b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/EventProcessingAnnotatedEventSourcedPooledStreamingInMemoryIT.java new file mode 100644 index 0000000000..a5874c49c6 --- /dev/null +++ b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/EventProcessingAnnotatedEventSourcedPooledStreamingInMemoryIT.java @@ -0,0 +1,34 @@ +/* + * Copyright (c) 2010-2026. Axon Framework + * + * Licensed 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.axonframework.integrationtests.testsuite.student; + +import org.axonframework.integrationtests.testsuite.infrastructure.InMemoryTestInfrastructure; +import org.axonframework.integrationtests.testsuite.infrastructure.TestInfrastructure; + +/** + * Runs {@link EventProcessingAnnotatedEventSourcedPooledStreamingIT} against the in-memory framework defaults. + */ +public class EventProcessingAnnotatedEventSourcedPooledStreamingInMemoryIT + extends EventProcessingAnnotatedEventSourcedPooledStreamingIT { + + private static final TestInfrastructure INFRASTRUCTURE = new InMemoryTestInfrastructure(); + + @Override + protected TestInfrastructure testInfrastructure() { + return INFRASTRUCTURE; + } +} diff --git a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/EventProcessingAnnotatedStateBasedPooledStreamingAxonServerIT.java b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/EventProcessingAnnotatedStateBasedPooledStreamingAxonServerIT.java new file mode 100644 index 0000000000..67bfe9186b --- /dev/null +++ b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/EventProcessingAnnotatedStateBasedPooledStreamingAxonServerIT.java @@ -0,0 +1,34 @@ +/* + * Copyright (c) 2010-2026. Axon Framework + * + * Licensed 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.axonframework.integrationtests.testsuite.student; + +import org.axonframework.integrationtests.testsuite.infrastructure.AxonServerTestInfrastructure; +import org.axonframework.integrationtests.testsuite.infrastructure.TestInfrastructure; + +/** + * Runs {@link EventProcessingAnnotatedStateBasedPooledStreamingIT} against a real Axon Server instance. + */ +public class EventProcessingAnnotatedStateBasedPooledStreamingAxonServerIT + extends EventProcessingAnnotatedStateBasedPooledStreamingIT { + + private static final TestInfrastructure INFRASTRUCTURE = new AxonServerTestInfrastructure(); + + @Override + protected TestInfrastructure testInfrastructure() { + return INFRASTRUCTURE; + } +} diff --git a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/EventProcessingAnnotatedStateBasedPooledStreamingIT.java b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/EventProcessingAnnotatedStateBasedPooledStreamingIT.java index 17bb2079d9..d168c34d4a 100644 --- a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/EventProcessingAnnotatedStateBasedPooledStreamingIT.java +++ b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/EventProcessingAnnotatedStateBasedPooledStreamingIT.java @@ -52,7 +52,7 @@ * @author Mateusz Nowak * @since 5.0.0 */ -public class EventProcessingAnnotatedStateBasedPooledStreamingIT extends AbstractStudentIT { +public abstract class EventProcessingAnnotatedStateBasedPooledStreamingIT extends AbstractStudentIT { @Test void whenStudentEnrolledThenUpdateReadModel() { diff --git a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/EventProcessingAnnotatedStateBasedPooledStreamingInMemoryIT.java b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/EventProcessingAnnotatedStateBasedPooledStreamingInMemoryIT.java new file mode 100644 index 0000000000..b10aad5977 --- /dev/null +++ b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/EventProcessingAnnotatedStateBasedPooledStreamingInMemoryIT.java @@ -0,0 +1,34 @@ +/* + * Copyright (c) 2010-2026. Axon Framework + * + * Licensed 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.axonframework.integrationtests.testsuite.student; + +import org.axonframework.integrationtests.testsuite.infrastructure.InMemoryTestInfrastructure; +import org.axonframework.integrationtests.testsuite.infrastructure.TestInfrastructure; + +/** + * Runs {@link EventProcessingAnnotatedStateBasedPooledStreamingIT} against the in-memory framework defaults. + */ +public class EventProcessingAnnotatedStateBasedPooledStreamingInMemoryIT + extends EventProcessingAnnotatedStateBasedPooledStreamingIT { + + private static final TestInfrastructure INFRASTRUCTURE = new InMemoryTestInfrastructure(); + + @Override + protected TestInfrastructure testInfrastructure() { + return INFRASTRUCTURE; + } +} diff --git a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/EventProcessingDeclarativeEventSourcedPooledStreamingAxonServerIT.java b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/EventProcessingDeclarativeEventSourcedPooledStreamingAxonServerIT.java new file mode 100644 index 0000000000..406abeaa76 --- /dev/null +++ b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/EventProcessingDeclarativeEventSourcedPooledStreamingAxonServerIT.java @@ -0,0 +1,34 @@ +/* + * Copyright (c) 2010-2026. Axon Framework + * + * Licensed 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.axonframework.integrationtests.testsuite.student; + +import org.axonframework.integrationtests.testsuite.infrastructure.AxonServerTestInfrastructure; +import org.axonframework.integrationtests.testsuite.infrastructure.TestInfrastructure; + +/** + * Runs {@link EventProcessingDeclarativeEventSourcedPooledStreamingIT} against a real Axon Server instance. + */ +public class EventProcessingDeclarativeEventSourcedPooledStreamingAxonServerIT + extends EventProcessingDeclarativeEventSourcedPooledStreamingIT { + + private static final TestInfrastructure INFRASTRUCTURE = new AxonServerTestInfrastructure(); + + @Override + protected TestInfrastructure testInfrastructure() { + return INFRASTRUCTURE; + } +} diff --git a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/EventProcessingDeclarativeEventSourcedPooledStreamingIT.java b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/EventProcessingDeclarativeEventSourcedPooledStreamingIT.java index 297d374c4c..6ff4529e90 100644 --- a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/EventProcessingDeclarativeEventSourcedPooledStreamingIT.java +++ b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/EventProcessingDeclarativeEventSourcedPooledStreamingIT.java @@ -59,7 +59,7 @@ * @author Mateusz Nowak * @since 5.0.0 */ -public class EventProcessingDeclarativeEventSourcedPooledStreamingIT extends AbstractStudentIT { +public abstract class EventProcessingDeclarativeEventSourcedPooledStreamingIT extends AbstractStudentIT { @Test void whenStudentEnrolled3CoursesThenSendNotificationTest() { diff --git a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/EventProcessingDeclarativeEventSourcedPooledStreamingInMemoryIT.java b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/EventProcessingDeclarativeEventSourcedPooledStreamingInMemoryIT.java new file mode 100644 index 0000000000..50968d42ee --- /dev/null +++ b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/EventProcessingDeclarativeEventSourcedPooledStreamingInMemoryIT.java @@ -0,0 +1,34 @@ +/* + * Copyright (c) 2010-2026. Axon Framework + * + * Licensed 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.axonframework.integrationtests.testsuite.student; + +import org.axonframework.integrationtests.testsuite.infrastructure.InMemoryTestInfrastructure; +import org.axonframework.integrationtests.testsuite.infrastructure.TestInfrastructure; + +/** + * Runs {@link EventProcessingDeclarativeEventSourcedPooledStreamingIT} against the in-memory framework defaults. + */ +public class EventProcessingDeclarativeEventSourcedPooledStreamingInMemoryIT + extends EventProcessingDeclarativeEventSourcedPooledStreamingIT { + + private static final TestInfrastructure INFRASTRUCTURE = new InMemoryTestInfrastructure(); + + @Override + protected TestInfrastructure testInfrastructure() { + return INFRASTRUCTURE; + } +} diff --git a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/MonitoringPooledEventProcessingReportAxonServerIT.java b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/MonitoringPooledEventProcessingReportAxonServerIT.java new file mode 100644 index 0000000000..e70e24b39e --- /dev/null +++ b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/MonitoringPooledEventProcessingReportAxonServerIT.java @@ -0,0 +1,34 @@ +/* + * Copyright (c) 2010-2026. Axon Framework + * + * Licensed 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.axonframework.integrationtests.testsuite.student; + +import org.axonframework.integrationtests.testsuite.infrastructure.AxonServerTestInfrastructure; +import org.axonframework.integrationtests.testsuite.infrastructure.TestInfrastructure; + +/** + * Runs {@link MonitoringPooledEventProcessingReportIT} against a real Axon Server instance. + */ +public class MonitoringPooledEventProcessingReportAxonServerIT + extends MonitoringPooledEventProcessingReportIT { + + private static final TestInfrastructure INFRASTRUCTURE = new AxonServerTestInfrastructure(); + + @Override + protected TestInfrastructure testInfrastructure() { + return INFRASTRUCTURE; + } +} diff --git a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/MonitoringPooledEventProcessingReportIT.java b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/MonitoringPooledEventProcessingReportIT.java index 880e67f733..6b7a6757c2 100644 --- a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/MonitoringPooledEventProcessingReportIT.java +++ b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/MonitoringPooledEventProcessingReportIT.java @@ -38,7 +38,7 @@ * This tests uses a {@link RecordingMessageMonitor} to verify that successfully processed events and ignored events are * reported correctly. */ -public class MonitoringPooledEventProcessingReportIT extends AbstractStudentIT { +public abstract class MonitoringPooledEventProcessingReportIT extends AbstractStudentIT { private static final String NAME = MonitoringPooledEventProcessingReportIT.class.getSimpleName(); @@ -107,7 +107,7 @@ void reportsSuccessForKnownEvent() { @Override protected EventSourcingConfigurer testSuiteConfigurer(EventSourcingConfigurer configurer) { // purge events to restart with an empty eventstore and avoid processing historic events - purgeEventStorage(); + purgeData(); // a noop setup that allows verification of ignored event configurer.messaging(mc -> mc diff --git a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/MonitoringPooledEventProcessingReportInMemoryIT.java b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/MonitoringPooledEventProcessingReportInMemoryIT.java new file mode 100644 index 0000000000..bec1663ecb --- /dev/null +++ b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/MonitoringPooledEventProcessingReportInMemoryIT.java @@ -0,0 +1,34 @@ +/* + * Copyright (c) 2010-2026. Axon Framework + * + * Licensed 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.axonframework.integrationtests.testsuite.student; + +import org.axonframework.integrationtests.testsuite.infrastructure.InMemoryTestInfrastructure; +import org.axonframework.integrationtests.testsuite.infrastructure.TestInfrastructure; + +/** + * Runs {@link MonitoringPooledEventProcessingReportIT} against the in-memory framework defaults. + */ +public class MonitoringPooledEventProcessingReportInMemoryIT + extends MonitoringPooledEventProcessingReportIT { + + private static final TestInfrastructure INFRASTRUCTURE = new InMemoryTestInfrastructure(); + + @Override + protected TestInfrastructure testInfrastructure() { + return INFRASTRUCTURE; + } +} diff --git a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/MultiEntityCommandHandlingComponentAxonServerIT.java b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/MultiEntityCommandHandlingComponentAxonServerIT.java new file mode 100644 index 0000000000..263613b24b --- /dev/null +++ b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/MultiEntityCommandHandlingComponentAxonServerIT.java @@ -0,0 +1,34 @@ +/* + * Copyright (c) 2010-2026. Axon Framework + * + * Licensed 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.axonframework.integrationtests.testsuite.student; + +import org.axonframework.integrationtests.testsuite.infrastructure.AxonServerTestInfrastructure; +import org.axonframework.integrationtests.testsuite.infrastructure.TestInfrastructure; + +/** + * Runs {@link MultiEntityCommandHandlingComponentIT} against a real Axon Server instance. + */ +public class MultiEntityCommandHandlingComponentAxonServerIT + extends MultiEntityCommandHandlingComponentIT { + + private static final TestInfrastructure INFRASTRUCTURE = new AxonServerTestInfrastructure(); + + @Override + protected TestInfrastructure testInfrastructure() { + return INFRASTRUCTURE; + } +} diff --git a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/MultiEntityCommandHandlingComponentIT.java b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/MultiEntityCommandHandlingComponentIT.java index 9bc345c2c0..8d57b555d3 100644 --- a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/MultiEntityCommandHandlingComponentIT.java +++ b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/MultiEntityCommandHandlingComponentIT.java @@ -49,7 +49,7 @@ * * @author Mitchell Herrijgers */ -class MultiEntityCommandHandlingComponentIT extends AbstractCommandHandlingStudentIT { +public abstract class MultiEntityCommandHandlingComponentIT extends AbstractCommandHandlingStudentIT { private final String student1 = createId("student-1"); private final String student2 = createId("student-2"); private final String student3 = createId("student-3"); @@ -116,7 +116,6 @@ void canCombineStatesInLambdaCommandHandlerViaStateManagerParameter() { // But five can not enroll for the first course assertThatThrownBy(() -> enrollStudentToCourse(student5, course1)) - .isInstanceOf(CommandExecutionException.class) .hasMessageContaining("Course already has 3 students"); } @@ -132,7 +131,6 @@ void canHandleCommandThatTargetsMultipleOfTheSameModelInSameAnnotatedCommandHand // But not a second time assertThatThrownBy(() -> sendCommand(new AssignMentorCommand(student1, student3))) - .isInstanceOf(CommandExecutionException.class) .hasMessageContaining("Mentor already assigned to a mentee"); } diff --git a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/MultiEntityCommandHandlingComponentInMemoryIT.java b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/MultiEntityCommandHandlingComponentInMemoryIT.java new file mode 100644 index 0000000000..27db5bf622 --- /dev/null +++ b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/MultiEntityCommandHandlingComponentInMemoryIT.java @@ -0,0 +1,34 @@ +/* + * Copyright (c) 2010-2026. Axon Framework + * + * Licensed 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.axonframework.integrationtests.testsuite.student; + +import org.axonframework.integrationtests.testsuite.infrastructure.InMemoryTestInfrastructure; +import org.axonframework.integrationtests.testsuite.infrastructure.TestInfrastructure; + +/** + * Runs {@link MultiEntityCommandHandlingComponentIT} against the in-memory framework defaults. + */ +public class MultiEntityCommandHandlingComponentInMemoryIT + extends MultiEntityCommandHandlingComponentIT { + + private static final TestInfrastructure INFRASTRUCTURE = new InMemoryTestInfrastructure(); + + @Override + protected TestInfrastructure testInfrastructure() { + return INFRASTRUCTURE; + } +} diff --git a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/ReplayStatusChangedHandlerAxonServerIT.java b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/ReplayStatusChangedHandlerAxonServerIT.java new file mode 100644 index 0000000000..fcbc4a724b --- /dev/null +++ b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/ReplayStatusChangedHandlerAxonServerIT.java @@ -0,0 +1,33 @@ +/* + * Copyright (c) 2010-2026. Axon Framework + * + * Licensed 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.axonframework.integrationtests.testsuite.student; + +import org.axonframework.integrationtests.testsuite.infrastructure.AxonServerTestInfrastructure; +import org.axonframework.integrationtests.testsuite.infrastructure.TestInfrastructure; + +/** + * Runs {@link ReplayStatusChangedHandlerIT} against a real Axon Server instance. + */ +public class ReplayStatusChangedHandlerAxonServerIT extends ReplayStatusChangedHandlerIT { + + private static final TestInfrastructure INFRASTRUCTURE = new AxonServerTestInfrastructure(); + + @Override + protected TestInfrastructure testInfrastructure() { + return INFRASTRUCTURE; + } +} diff --git a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/ReplayStatusChangedHandlerIT.java b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/ReplayStatusChangedHandlerIT.java index ad7f6e2921..e7bfd23c5d 100644 --- a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/ReplayStatusChangedHandlerIT.java +++ b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/ReplayStatusChangedHandlerIT.java @@ -55,7 +55,7 @@ * @author Steven van Beelen * @since 5.1.0 */ -class ReplayStatusChangedHandlerIT extends AbstractStudentIT { +public abstract class ReplayStatusChangedHandlerIT extends AbstractStudentIT { private static final String PSEP_NAME = "replayStatusChangeHandler"; @@ -70,7 +70,7 @@ void setUp() { resetHandlerInvoked = new AtomicBoolean(false); replayStatusReference = new AtomicReference<>(null); statusChangedInvoked = new CountDownLatch(0); - purgeEventStorage(); + purgeData(); } @Test diff --git a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/ReplayStatusChangedHandlerInMemoryIT.java b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/ReplayStatusChangedHandlerInMemoryIT.java new file mode 100644 index 0000000000..188acfd0c3 --- /dev/null +++ b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/ReplayStatusChangedHandlerInMemoryIT.java @@ -0,0 +1,33 @@ +/* + * Copyright (c) 2010-2026. Axon Framework + * + * Licensed 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.axonframework.integrationtests.testsuite.student; + +import org.axonframework.integrationtests.testsuite.infrastructure.InMemoryTestInfrastructure; +import org.axonframework.integrationtests.testsuite.infrastructure.TestInfrastructure; + +/** + * Runs {@link ReplayStatusChangedHandlerIT} against the in-memory framework defaults. + */ +public class ReplayStatusChangedHandlerInMemoryIT extends ReplayStatusChangedHandlerIT { + + private static final TestInfrastructure INFRASTRUCTURE = new InMemoryTestInfrastructure(); + + @Override + protected TestInfrastructure testInfrastructure() { + return INFRASTRUCTURE; + } +} diff --git a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/SingleEntityCommandHandlingComponentAxonServerIT.java b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/SingleEntityCommandHandlingComponentAxonServerIT.java new file mode 100644 index 0000000000..e0bde4ce01 --- /dev/null +++ b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/SingleEntityCommandHandlingComponentAxonServerIT.java @@ -0,0 +1,34 @@ +/* + * Copyright (c) 2010-2026. Axon Framework + * + * Licensed 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.axonframework.integrationtests.testsuite.student; + +import org.axonframework.integrationtests.testsuite.infrastructure.AxonServerTestInfrastructure; +import org.axonframework.integrationtests.testsuite.infrastructure.TestInfrastructure; + +/** + * Runs {@link SingleEntityCommandHandlingComponentIT} against a real Axon Server instance. + */ +public class SingleEntityCommandHandlingComponentAxonServerIT + extends SingleEntityCommandHandlingComponentIT { + + private static final TestInfrastructure INFRASTRUCTURE = new AxonServerTestInfrastructure(); + + @Override + protected TestInfrastructure testInfrastructure() { + return INFRASTRUCTURE; + } +} diff --git a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/SingleEntityCommandHandlingComponentIT.java b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/SingleEntityCommandHandlingComponentIT.java index cecc9040b2..eb69ecfafc 100644 --- a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/SingleEntityCommandHandlingComponentIT.java +++ b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/SingleEntityCommandHandlingComponentIT.java @@ -36,7 +36,7 @@ * * @author Mitchell Herrijgers */ -class SingleEntityCommandHandlingComponentIT extends AbstractCommandHandlingStudentIT { +public abstract class SingleEntityCommandHandlingComponentIT extends AbstractCommandHandlingStudentIT { private final String student1 = createId("student-1"); private final String student2 = createId("student-2"); diff --git a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/SingleEntityCommandHandlingComponentInMemoryIT.java b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/SingleEntityCommandHandlingComponentInMemoryIT.java new file mode 100644 index 0000000000..e0f34425f2 --- /dev/null +++ b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/SingleEntityCommandHandlingComponentInMemoryIT.java @@ -0,0 +1,34 @@ +/* + * Copyright (c) 2010-2026. Axon Framework + * + * Licensed 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.axonframework.integrationtests.testsuite.student; + +import org.axonframework.integrationtests.testsuite.infrastructure.InMemoryTestInfrastructure; +import org.axonframework.integrationtests.testsuite.infrastructure.TestInfrastructure; + +/** + * Runs {@link SingleEntityCommandHandlingComponentIT} against the in-memory framework defaults. + */ +public class SingleEntityCommandHandlingComponentInMemoryIT + extends SingleEntityCommandHandlingComponentIT { + + private static final TestInfrastructure INFRASTRUCTURE = new InMemoryTestInfrastructure(); + + @Override + protected TestInfrastructure testInfrastructure() { + return INFRASTRUCTURE; + } +} diff --git a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/SubscribableEventSourceWithEventAppenderAxonServerIT.java b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/SubscribableEventSourceWithEventAppenderAxonServerIT.java new file mode 100644 index 0000000000..464c63d5ab --- /dev/null +++ b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/SubscribableEventSourceWithEventAppenderAxonServerIT.java @@ -0,0 +1,34 @@ +/* + * Copyright (c) 2010-2026. Axon Framework + * + * Licensed 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.axonframework.integrationtests.testsuite.student; + +import org.axonframework.integrationtests.testsuite.infrastructure.AxonServerTestInfrastructure; +import org.axonframework.integrationtests.testsuite.infrastructure.TestInfrastructure; + +/** + * Runs {@link SubscribableEventSourceWithEventAppenderTest} against a real Axon Server instance. + */ +public class SubscribableEventSourceWithEventAppenderAxonServerIT + extends SubscribableEventSourceWithEventAppenderTest { + + private static final TestInfrastructure INFRASTRUCTURE = new AxonServerTestInfrastructure(); + + @Override + protected TestInfrastructure testInfrastructure() { + return INFRASTRUCTURE; + } +} diff --git a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/SubscribableEventSourceWithEventAppenderInMemoryIT.java b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/SubscribableEventSourceWithEventAppenderInMemoryIT.java new file mode 100644 index 0000000000..c767b3782d --- /dev/null +++ b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/SubscribableEventSourceWithEventAppenderInMemoryIT.java @@ -0,0 +1,34 @@ +/* + * Copyright (c) 2010-2026. Axon Framework + * + * Licensed 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.axonframework.integrationtests.testsuite.student; + +import org.axonframework.integrationtests.testsuite.infrastructure.InMemoryTestInfrastructure; +import org.axonframework.integrationtests.testsuite.infrastructure.TestInfrastructure; + +/** + * Runs {@link SubscribableEventSourceWithEventAppenderTest} against the in-memory framework defaults. + */ +public class SubscribableEventSourceWithEventAppenderInMemoryIT + extends SubscribableEventSourceWithEventAppenderTest { + + private static final TestInfrastructure INFRASTRUCTURE = new InMemoryTestInfrastructure(); + + @Override + protected TestInfrastructure testInfrastructure() { + return INFRASTRUCTURE; + } +} diff --git a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/SubscribableEventSourceWithEventAppenderTest.java b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/SubscribableEventSourceWithEventAppenderTest.java index 0eac139986..1f1e7a12b3 100644 --- a/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/SubscribableEventSourceWithEventAppenderTest.java +++ b/integrationtests/src/test/java/org/axonframework/integrationtests/testsuite/student/SubscribableEventSourceWithEventAppenderTest.java @@ -43,7 +43,7 @@ * @author Mateusz Nowak * @since 5.0.0 */ -class SubscribableEventSourceWithEventAppenderTest extends AbstractStudentIT { +public abstract class SubscribableEventSourceWithEventAppenderTest extends AbstractStudentIT { @Test void whenEventPublishedViaEventAppenderThenSubscriberReceivesEvent() {