Commit 5034fe71 authored by John Lam's avatar John Lam

update kafkalistener

parent 59e261bd
package com.nisum.ascend.inventory.service; package com.nisum.ascend.inventory.service;
import com.fasterxml.jackson.databind.ObjectMapper; import com.fasterxml.jackson.databind.ObjectMapper;
import com.nisum.ascend.inventory.dto.Item; import com.nisum.ascend.inventory.dto.Item;
import com.nisum.ascend.inventory.dto.WareHouseOrder; import com.nisum.ascend.inventory.dto.WareHouseOrder;
...@@ -33,7 +32,6 @@ public class KafkaListenerService { ...@@ -33,7 +32,6 @@ public class KafkaListenerService {
.subscribe(); .subscribe();
} }
private void onWarehouseOrderStatusReceived(String warehouseOrderString) { private void onWarehouseOrderStatusReceived(String warehouseOrderString) {
try { try {
System.out.print(warehouseOrderString); System.out.print(warehouseOrderString);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment