From dd81e2e59371cb8adc5428ba9d1e7f3742767df2 Mon Sep 17 00:00:00 2001 From: kimscott Date: Thu, 19 Dec 2019 11:03:38 +0900 Subject: [PATCH] =?UTF-8?q?policy=20=EC=BD=94=EB=93=9C=20=EA=B0=84?= =?UTF-8?q?=EA=B2=B0=ED=99=94?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/example/template/OrderService.java | 20 +++++++++++-------- 1 file changed, 12 insertions(+), 8 deletions(-) diff --git a/src/main/java/com/example/template/OrderService.java b/src/main/java/com/example/template/OrderService.java index 7532859..41a32ec 100644 --- a/src/main/java/com/example/template/OrderService.java +++ b/src/main/java/com/example/template/OrderService.java @@ -27,14 +27,18 @@ public class OrderService { @StreamListener(KafkaProcessor.INPUT) public void onProductChanged(@Payload ProductChanged productChanged) { - if( productChanged.isMe()){ - System.out.println("##### listener : " + productChanged.toJson()); - Product product = new Product(); - product.setId(productChanged.getProductId()); - product.setStock(productChanged.getProductStock()); - product.setName(productChanged.getProductName()); - product.setPrice(productChanged.getProductPrice()); - productRepository.save(product); + try { + if (productChanged.isMe()) { + System.out.println("##### listener : " + productChanged.toJson()); + Product product = new Product(); + product.setId(productChanged.getProductId()); + product.setStock(productChanged.getProductStock()); + product.setName(productChanged.getProductName()); + product.setPrice(productChanged.getProductPrice()); + productRepository.save(product); + } + }catch (Exception e){ + e.printStackTrace(); } } }