From fd0f9fc4fdb8f3863c731ba4a9905cafd919432c Mon Sep 17 00:00:00 2001 From: user15 Date: Tue, 16 Jun 2020 07:21:21 +0900 Subject: [PATCH] Modified to PolicyHandler --- .../{OrderService.java => PolicyHandler.java} | 11 +---------- 1 file changed, 1 insertion(+), 10 deletions(-) rename src/main/java/com/example/template/{OrderService.java => PolicyHandler.java} (74%) diff --git a/src/main/java/com/example/template/OrderService.java b/src/main/java/com/example/template/PolicyHandler.java similarity index 74% rename from src/main/java/com/example/template/OrderService.java rename to src/main/java/com/example/template/PolicyHandler.java index 41a32ec..aa4dc7f 100644 --- a/src/main/java/com/example/template/OrderService.java +++ b/src/main/java/com/example/template/PolicyHandler.java @@ -1,22 +1,13 @@ package com.example.template; import com.example.template.config.kafka.KafkaProcessor; -import com.fasterxml.jackson.databind.DeserializationFeature; -import com.fasterxml.jackson.databind.ObjectMapper; -import org.apache.kafka.clients.consumer.ConsumerRecord; -import org.apache.kafka.clients.producer.ProducerRecord; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.cloud.stream.annotation.StreamListener; -import org.springframework.kafka.annotation.KafkaListener; -import org.springframework.kafka.core.KafkaTemplate; import org.springframework.messaging.handler.annotation.Payload; import org.springframework.stereotype.Service; -import java.io.IOException; -import java.util.Optional; - @Service -public class OrderService { +public class PolicyHandler { @Autowired private ProductRepository productRepository;