spring/spring-boot
1
0
Fork 0
mirror of https://github.com/spring-projects/spring-boot.git synced 2026-09-17 12:09:16 +00:00
Code Issues Projects Releases Wiki Activity

Simplify Artemis AMQP 1.0 integration test

Browse Source 
See gh-51081

Signed-off-by: Eddú Meléndez <eddu.melendez@gmail.com>
This commit is contained in:
Eddú Meléndez
2026-07-21 08:27:22 +02:00
committed by Stéphane Nicoll
parent d22b8e44ad
commit 4293de5eee
1 changed files with 8 additions and 25 deletions
Download Patch File Download Diff File Expand all files Collapse all files
module/spring-boot-amqp/src/dockerTest/java/org/springframework/boot/amqp/testcontainers/ArtemisAmqpContainerConnectionDetailsFactoryIntegrationTests.java
+8 -25
View File
@@ -20,7 +20,7 @@ import java.util.UUID;
import java.util.concurrent.TimeUnit;
import org.junit.jupiter.api.Test;
import org.testcontainers.containers.Container.ExecResult;
import org.testcontainers.activemq.ArtemisContainer;
import org.testcontainers.junit.jupiter.Container;
import org.testcontainers.junit.jupiter.Testcontainers;
@@ -41,14 +41,18 @@ import static org.assertj.core.api.Assertions.assertThat;
* Tests for {@link ArtemisAmqpContainerConnectionDetailsFactory}.
*
* @author Stephane Nicoll
* @author Eddú Meléndez
*/
@SpringJUnitConfig
@Testcontainers(disabledWithoutDocker = true)
class ArtemisAmqpContainerConnectionDetailsFactoryIntegrationTests {
private static final String QUEUE_NAME = UUID.randomUUID().toString();
@Container
@ServiceConnection
static final ArtemisLegacyContainer container = TestImage.container(ArtemisLegacyContainer.class);
static final ArtemisContainer container = TestImage.container(ArtemisLegacyContainer.class)
.withEnv("EXTRA_ARGS", "--queues %s:anycast".formatted(QUEUE_NAME));
@Autowired(required = false)
private AmqpConnectionDetails connectionDetails;
@@ -59,32 +63,11 @@ class ArtemisAmqpContainerConnectionDetailsFactoryIntegrationTests {
@Test
void connectionCanBeMadeToArtemisContainer() throws Exception {
assertThat(this.connectionDetails).isNotNull();
String address = createRandomQueue();
this.amqpClient.to(address).body("test message").send();
Object message = this.amqpClient.from(address).receiveAndConvert().get(4, TimeUnit.MINUTES);
this.amqpClient.to(QUEUE_NAME).body("test message").send();
Object message = this.amqpClient.from(QUEUE_NAME).receiveAndConvert().get(4, TimeUnit.MINUTES);
assertThat(message).isEqualTo("test message");
}
private String createRandomQueue() {
String name = UUID.randomUUID().toString();
createQueue(name);
return name;
}
private void createQueue(String name) {
try {
ExecResult execResult = container.execInContainer("/var/lib/artemis-instance/bin/artemis", "queue",
"create", "--name=" + name, "--auto-create-address", "--anycast", "--silent",
"--user=" + container.getUser(), "--password=" + container.getPassword());
if (execResult.getExitCode() != 0) {
throw new IllegalStateException("Failed to create queue: " + execResult);
}
}
catch (Exception ex) {
throw new IllegalStateException("Failed to create queue " + name, ex);
}
}
@Configuration(proxyBeanMethods = false)
@ImportAutoConfiguration(AmqpAutoConfiguration.class)
static class TestConfiguration {