fix: Pub 네이밍 수정

YAPP-Github · Sep 26, 2024 · 8c84b0b · 8c84b0b
1 parent d97f5ab
commit 8c84b0b
Show file tree

Hide file tree

Showing 4 changed files with 23 additions and 23 deletions.
diff --git a/app/infrastructure/message-queue/src/main/java/org/example/adapter/ArtistCreateAdapter.java b/app/infrastructure/message-queue/src/main/java/org/example/adapter/ArtistCreateAdapter.java
@@ -2,7 +2,7 @@
 
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
-import org.example.adapter.request.ArtistCreateInfraRequest;
+import org.example.message.ArtistWithGenreCreateInfraMessage;
 import org.example.port.ArtistCreatePort;
 import org.example.port.dto.request.ArtistCreatePortRequest;
 import org.springframework.data.redis.core.RedisTemplate;
@@ -17,10 +17,10 @@ public class ArtistCreateAdapter implements ArtistCreatePort {
 
     @Override
     public void createArtist(String topic, ArtistCreatePortRequest request) {
-        var infraMessage = ArtistCreateInfraRequest.from(request);
+        var infraMessage = ArtistWithGenreCreateInfraMessage.from(request);
 
         template.convertAndSend(topic, infraMessage);
         log.info("Message published successfully to topic: {}", topic);
-        log.info("Message Contents ( ArtistCreateInfraRequest : {})", infraMessage);
+        log.info("Message Contents ( ArtistWithGenreCreateInfraMessage : {})", infraMessage);
     }
 }
diff --git a/...ure/message-queue/src/main/java/org/example/adapter/request/ArtistCreateInfraRequest.java b/...ure/message-queue/src/main/java/org/example/adapter/request/ArtistCreateInfraRequest.java
diff --git a/...ter/request/ArtistDomainInfraRequest.java → ...essage/ArtistGenreDomainInfraMessage.java b/...ter/request/ArtistDomainInfraRequest.java → ...essage/ArtistGenreDomainInfraMessage.java
@@ -1,12 +1,12 @@
-package org.example.adapter.request;
+package org.example.message;
 
 import java.util.List;
 import java.util.UUID;
 import lombok.Builder;
 import org.example.port.dto.request.ArtistDomainPortRequest;
 
 @Builder
-public record ArtistDomainInfraRequest(
+public record ArtistGenreDomainInfraMessage(
 
     UUID id,
     String name,
@@ -15,8 +15,8 @@ public record ArtistDomainInfraRequest(
     List<String> genres
 ) {
 
-    public static ArtistDomainInfraRequest from(ArtistDomainPortRequest request) {
-        return ArtistDomainInfraRequest.builder()
+    public static ArtistGenreDomainInfraMessage from(ArtistDomainPortRequest request) {
+        return ArtistGenreDomainInfraMessage.builder()
             .id(request.id())
             .name(request.name())
             .image(request.image())

diff --git a/...re/message-queue/src/main/java/org/example/message/ArtistWithGenreCreateInfraMessage.java b/...re/message-queue/src/main/java/org/example/message/ArtistWithGenreCreateInfraMessage.java
@@ -0,0 +1,16 @@
+package org.example.message;
+
+import java.util.List;
+import org.example.port.dto.request.ArtistCreatePortRequest;
+
+public record ArtistWithGenreCreateInfraMessage(
+    List<ArtistGenreDomainInfraMessage> request
+) {
+
+    public static ArtistWithGenreCreateInfraMessage from(ArtistCreatePortRequest request) {
+        return new ArtistWithGenreCreateInfraMessage(
+            request.artists().stream().map(ArtistGenreDomainInfraMessage::from).toList()
+        );
+    }
+
+}