Add local development support

testcontainers · Jul 10, 2023 · f5fb018 · f5fb018
1 parent 1cf05fc
commit f5fb018
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 15 deletions.
diff --git a/src/main/java/com/testcontainers/demo/MessageController.java b/src/main/java/com/testcontainers/demo/MessageController.java
@@ -1,8 +1,6 @@
 package com.testcontainers.demo;
 
-import java.io.ByteArrayInputStream;
 import java.io.IOException;
-import java.nio.charset.StandardCharsets;
 import java.util.Map;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.PathVariable;
@@ -24,12 +22,8 @@ public class MessageController {
 
     @PostMapping("/api/messages")
     public Map<String, String> create(@RequestBody Message message) {
-        messageSender.publish(properties.bucket(), message);
-        String key = message.uuid().toString();
-        String content = message.content();
-        ByteArrayInputStream is = new ByteArrayInputStream(content.getBytes(StandardCharsets.UTF_8));
-        storageService.upload(properties.bucket(), key, is);
-        return Map.of("uuid", key);
+        messageSender.publish(properties.queue(), message);
+        return Map.of("uuid", message.uuid().toString());
     }
 
     @GetMapping("/api/messages/{uuid}")

diff --git a/src/test/java/com/testcontainers/demo/MessageListenerTest.java b/src/test/java/com/testcontainers/demo/MessageListenerTest.java
@@ -62,7 +62,7 @@ static void beforeAll() throws IOException, InterruptedException {
     @Test
     void shouldHandleMessageSuccessfully() {
         Message message = new Message(UUID.randomUUID(), "Hello World");
-        publisher.publish(QUEUE_NAME, message);
+        publisher.publish(properties.queue(), message);
 
         await().pollInterval(Duration.ofSeconds(2))
                 .atMost(Duration.ofSeconds(10))

diff --git a/src/test/java/com/testcontainers/demo/TestApplication.java b/src/test/java/com/testcontainers/demo/TestApplication.java
@@ -5,20 +5,17 @@
 
 import java.util.UUID;
 import org.springframework.boot.SpringApplication;
-import org.springframework.boot.test.context.TestConfiguration;
 import org.testcontainers.containers.localstack.LocalStackContainer;
-import org.testcontainers.junit.jupiter.Testcontainers;
 import org.testcontainers.utility.DockerImageName;
 
-@TestConfiguration(proxyBeanMethods = false)
-@Testcontainers
 public class TestApplication {
 
     public static void main(String[] args) {
-        SpringApplication.from(Application::main).with(TestApplication.class).run(args);
+        setup();
+        SpringApplication.from(Application::main).run(args);
     }
 
-    static {
+    static void setup() {
         try {
             var container = new LocalStackContainer(DockerImageName.parse("localstack/localstack:2.0"));
             container.start();