인프런 커뮤니티 질문&답변

안녕하세요, 좋은 강의 감사합니다.

제공해 주신 코드를 분석해 보고있는데요,

구현한 헥사고날 아키텍쳐에 대한 다이어그램이나 설명이 있으면 이해하기 쉬울것 같은데 혹시 작성하신 게 있으실까요?

예를들어서, 이런 부분의 코드는 어디서 메시지를 가져오는지 intellij 로 검색해봐도 나오질 않아서요.

package com.example.paymentservice2.payment.adapter.`in`.stream

@Configuration
@StreamAdapter
class LedgerEventMessageHandler (
  private val paymentCompleteUseCase: PaymentCompleteUseCase
) {

  @Bean
  fun ledger(): Function<Flux<Message<LedgerEventMessage>>, Mono<Void>> {
    return Function { flux ->
      flux.flatMap { message ->
        paymentCompleteUseCase.completePayment(message.payload)
          .then(Mono.defer { message.headers.get(KafkaHeaders.ACKNOWLEDGMENT, ReceiverOffset::class.java)!!.commit() })
      }.then()
    }
  }
}

그리고, adapter 내부의 in, out 폴더와 application 내부의 in, out 폴더의 차이점은 뭔가요??

P.S 수준 높은 코드라서 매우 좋습니다. 다른 강의도 이정도 수준이면 수강할 것 같습니다. 타강사님들의 강의는 쉬운것들이 많아서 경쟁력이 있으신것 같아요.