From 923b057c185c20855714951a169a03d8af066bbe Mon Sep 17 00:00:00 2001 From: Ilayaperumal Gopinathan Date: Mon, 25 Mar 2019 23:20:46 +0530 Subject: [PATCH] Fix package and bean names --- .../cloud/dataflow/samples/source/{http => }/HttpIngest.java | 2 +- .../dataflow/samples/sink/UserClicksPerRegionLogger.java | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) rename kafka-samples/http-ingest/src/main/java/org/springframework/cloud/dataflow/samples/source/{http => }/HttpIngest.java (95%) diff --git a/kafka-samples/http-ingest/src/main/java/org/springframework/cloud/dataflow/samples/source/http/HttpIngest.java b/kafka-samples/http-ingest/src/main/java/org/springframework/cloud/dataflow/samples/source/HttpIngest.java similarity index 95% rename from kafka-samples/http-ingest/src/main/java/org/springframework/cloud/dataflow/samples/source/http/HttpIngest.java rename to kafka-samples/http-ingest/src/main/java/org/springframework/cloud/dataflow/samples/source/HttpIngest.java index 017f3a1..d86816c 100644 --- a/kafka-samples/http-ingest/src/main/java/org/springframework/cloud/dataflow/samples/source/http/HttpIngest.java +++ b/kafka-samples/http-ingest/src/main/java/org/springframework/cloud/dataflow/samples/source/HttpIngest.java @@ -14,7 +14,7 @@ * limitations under the License. */ -package org.springframework.cloud.dataflow.samples.source.http; +package org.springframework.cloud.dataflow.samples.source; import java.util.function.Function; diff --git a/kafka-samples/kstreams-log-user-clicks-per-region/src/main/java/org/springframework/cloud/dataflow/samples/sink/UserClicksPerRegionLogger.java b/kafka-samples/kstreams-log-user-clicks-per-region/src/main/java/org/springframework/cloud/dataflow/samples/sink/UserClicksPerRegionLogger.java index 1f189c2..d19cb2c 100644 --- a/kafka-samples/kstreams-log-user-clicks-per-region/src/main/java/org/springframework/cloud/dataflow/samples/sink/UserClicksPerRegionLogger.java +++ b/kafka-samples/kstreams-log-user-clicks-per-region/src/main/java/org/springframework/cloud/dataflow/samples/sink/UserClicksPerRegionLogger.java @@ -14,7 +14,7 @@ * limitations under the License. */ -package org.springframework.cloud.stream.app.log; +package org.springframework.cloud.dataflow.samples.sink; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; @@ -32,7 +32,7 @@ public class UserClicksPerRegionLogger { @Bean @ServiceActivator(inputChannel = Sink.INPUT) - public LoggingHandler userClicksPerRegionLogger() { + public LoggingHandler logger() { LoggingHandler loggingHandler = new LoggingHandler(LoggingHandler.Level.INFO) { @Override