Polish

wonwoo · Nov 3, 2019 · b437485 · b437485
1 parent 76f643e
commit b437485
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/remote/src/main/kotlin/ml/wonwoo/remote/HistoryEventListener.kt b/remote/src/main/kotlin/ml/wonwoo/remote/HistoryEventListener.kt
@@ -5,18 +5,18 @@ import ml.wonwoo.remote.product.HistoryRepository
 import ml.wonwoo.remote.product.ProductType
 import org.springframework.context.event.EventListener
 import org.springframework.stereotype.Component
+import reactor.core.publisher.Mono
 import java.time.LocalDateTime
 
 @Component
 class HistoryEventListener(private val historyRepository: HistoryRepository) {
 
 
     @EventListener
-    fun onApplicationEvent(historyEvent: HistoryEvent) {
+    fun onApplicationEvent(historyEvent: HistoryEvent): Mono<Void> {
 
-        historyRepository.save(historyEvent.toEvent())
+        return historyRepository.save(historyEvent.toEvent()).then()
 
-            .subscribe()
     }
 
 }

diff --git a/remote/src/main/kotlin/ml/wonwoo/remote/web/BookController.kt b/remote/src/main/kotlin/ml/wonwoo/remote/web/BookController.kt
@@ -22,7 +22,7 @@ class BookController(private val bookRepository: BookRepository,
 
             .map { it.dto() }
             .doOnComplete {
-                applicationEventPublisher.publishEvent(HistoryEvent(name = name, productType = ProductType.MOVIE))
+                applicationEventPublisher.publishEvent(HistoryEvent(name = name, productType = ProductType.BOOK))
             }
     }
 }