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:02:37 +09:00
parent 63bf0137bc
commit 41889ebaa8
1 changed files with 9 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -26,27 +26,15 @@ public class OrderService {
*/
@StreamListener(KafkaProcessor.INPUT)
public void onProductChanged(@Payload String message) {
System.out.println("##### listener : " + message);
ObjectMapper objectMapper = new ObjectMapper();
objectMapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
ProductChanged productChanged = null;
try {
productChanged = objectMapper.readValue(message, ProductChanged.class);
if( productChanged.isMe()){
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){
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);
}
}
}