[FIX] add transactional annotation

lotteon2 · Dec 29, 2023 · 887201d · 887201d
1 parent e684bc7
commit 887201d
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git a/src/main/java/com/dailyon/snsservice/kafka/MemberEventListener.java b/src/main/java/com/dailyon/snsservice/kafka/MemberEventListener.java
@@ -11,7 +11,6 @@
 import org.springframework.kafka.annotation.KafkaListener;
 import org.springframework.kafka.support.Acknowledgment;
 import org.springframework.stereotype.Component;
-import org.springframework.transaction.annotation.Transactional;
 
 @Slf4j
 @Component
@@ -21,7 +20,6 @@ public class MemberEventListener {
   private final MemberService memberService;
   private final ObjectMapper objectMapper;
 
-  @Transactional
   @KafkaListener(topics = KafkaTopic.CREATE_MEMBER_FOR_SNS)
   public void createMember(String message, Acknowledgment ack) {
     MemberCreateDTO memberCreateDTO;
@@ -38,7 +36,6 @@ public void createMember(String message, Acknowledgment ack) {
     }
   }
 
-  @Transactional
   @KafkaListener(topics = KafkaTopic.UPDATE_MEMBER_FOR_SNS)
   public void updateMember(String message, Acknowledgment ack) {
     MemberUpdateDTO memberUpdateDTO;

diff --git a/src/main/java/com/dailyon/snsservice/service/member/MemberService.java b/src/main/java/com/dailyon/snsservice/service/member/MemberService.java
@@ -21,6 +21,7 @@ public OOTDMemberProfileResponse getOOTDMemberProfile(Long ootdMemberId, Long me
     return memberRepository.findOOTDMemberProfile(ootdMemberId, memberId);
   }
 
+  @Transactional
   public void createMember(MemberCreateDTO memberCreateDTO) {
     Member member =
         Member.createMember(
@@ -31,6 +32,7 @@ public void createMember(MemberCreateDTO memberCreateDTO) {
     memberRepository.save(member);
   }
 
+  @Transactional
   public void updateMember(MemberUpdateDTO memberUpdateDTO) {
     Member member = memberReader.read(memberUpdateDTO.getId());
     member.updateMember(memberUpdateDTO.getNickname(), memberUpdateDTO.getProfileImgUrl());