change regi

This commit is contained in:
kimscott
2020-03-09 10:51:57 +09:00
parent c3d8a4ebd6
commit 536480450f
2 changed files with 5 additions and 4 deletions

View File

@@ -102,4 +102,4 @@ options:
env:
# # location/name of GKE cluster (used by all kubectl commands)
- CLOUDSDK_COMPUTE_ZONE=asia-northeast1-a
- CLOUDSDK_CONTAINER_CLUSTER=standard-cluster-1
- CLOUDSDK_CONTAINER_CLUSTER=cluster-1

View File

@@ -5,6 +5,7 @@ import com.fasterxml.jackson.databind.DeserializationFeature;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.messaging.handler.annotation.Headers;
import org.springframework.messaging.handler.annotation.Payload;
import org.springframework.stereotype.Service;
@@ -15,9 +16,6 @@ import java.util.Optional;
@Service
public class ProductService {
@Autowired
ProductRepository productRepository;
@StreamListener(KafkaProcessor.INPUT)
public void onOrderPlaced(@Payload String message) {
System.out.println("##### listener : " + message);
@@ -57,6 +55,9 @@ public class ProductService {
}
}
@Autowired
ProductRepository productRepository;
/**
* 상품 조회
*/