mindol1004/ddd-orders
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

policy 코드 간결화

Browse Source
This commit is contained in:
kimscott
2019-12-19 11:03:38 +09:00
parent 41889ebaa8
commit dd81e2e593
1 changed files with 12 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
src/main/java/com/example/template/OrderService.java
View File

@@ -27,14 +27,18 @@ public class OrderService {
@StreamListener(KafkaProcessor.INPUT) @StreamListener(KafkaProcessor.INPUT)
public void onProductChanged(@Payload ProductChanged productChanged) { public void onProductChanged(@Payload ProductChanged productChanged) {
if( productChanged.isMe()){ try {
System.out.println("##### listener : " + productChanged.toJson()); if (productChanged.isMe()) {
Product product = new Product(); System.out.println("##### listener : " + productChanged.toJson());
product.setId(productChanged.getProductId()); Product product = new Product();
product.setStock(productChanged.getProductStock()); product.setId(productChanged.getProductId());
product.setName(productChanged.getProductName()); product.setStock(productChanged.getProductStock());
product.setPrice(productChanged.getProductPrice()); product.setName(productChanged.getProductName());
productRepository.save(product); product.setPrice(productChanged.getProductPrice());
productRepository.save(product);
}
}catch (Exception e){
e.printStackTrace();
} }
} }
} }