From 7b105a14954f7b6b54699de221ebbc5517d86d3c Mon Sep 17 00:00:00 2001
From: Soby Chacko <schacko@pivotal.io>
Date: Tue, 29 Oct 2019 10:25:18 -0400
Subject: [PATCH] Polishing

---
 .../kafka/ReactiveProcessorApplication.java   | 25 ++++++-------------
 .../kafka/ReactiveProcessorApplication.java   | 25 ++++++-------------
 2 files changed, 14 insertions(+), 36 deletions(-)

diff --git a/processor-samples/reactive-processor-kafka/src/main/java/reactive/kafka/ReactiveProcessorApplication.java b/processor-samples/reactive-processor-kafka/src/main/java/reactive/kafka/ReactiveProcessorApplication.java
index 70916a8..9145b03 100644
--- a/processor-samples/reactive-processor-kafka/src/main/java/reactive/kafka/ReactiveProcessorApplication.java
+++ b/processor-samples/reactive-processor-kafka/src/main/java/reactive/kafka/ReactiveProcessorApplication.java
@@ -1,29 +1,18 @@
 package reactive.kafka;
 
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
-import org.springframework.boot.SpringApplication;
-import org.springframework.boot.autoconfigure.SpringBootApplication;
-import org.springframework.cloud.stream.annotation.EnableBinding;
-import org.springframework.cloud.stream.annotation.Input;
-import org.springframework.cloud.stream.annotation.Output;
-import org.springframework.cloud.stream.annotation.StreamListener;
-import org.springframework.cloud.stream.messaging.Processor;
-import org.springframework.context.annotation.Bean;
-import org.springframework.integration.annotation.InboundChannelAdapter;
-import org.springframework.integration.annotation.Poller;
-import org.springframework.integration.core.MessageSource;
-import org.springframework.messaging.MessageChannel;
-import org.springframework.messaging.SubscribableChannel;
-import org.springframework.messaging.support.GenericMessage;
-import reactor.core.publisher.Flux;
-
 import java.time.Duration;
 import java.util.concurrent.atomic.AtomicBoolean;
 import java.util.function.Consumer;
 import java.util.function.Function;
 import java.util.function.Supplier;
 
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.context.annotation.Bean;
+import reactor.core.publisher.Flux;
+
 @SpringBootApplication
 public class ReactiveProcessorApplication {
 
diff --git a/processor-samples/reactive-processor-rabbit/src/main/java/reactive/kafka/ReactiveProcessorApplication.java b/processor-samples/reactive-processor-rabbit/src/main/java/reactive/kafka/ReactiveProcessorApplication.java
index 70916a8..9145b03 100644
--- a/processor-samples/reactive-processor-rabbit/src/main/java/reactive/kafka/ReactiveProcessorApplication.java
+++ b/processor-samples/reactive-processor-rabbit/src/main/java/reactive/kafka/ReactiveProcessorApplication.java
@@ -1,29 +1,18 @@
 package reactive.kafka;
 
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
-import org.springframework.boot.SpringApplication;
-import org.springframework.boot.autoconfigure.SpringBootApplication;
-import org.springframework.cloud.stream.annotation.EnableBinding;
-import org.springframework.cloud.stream.annotation.Input;
-import org.springframework.cloud.stream.annotation.Output;
-import org.springframework.cloud.stream.annotation.StreamListener;
-import org.springframework.cloud.stream.messaging.Processor;
-import org.springframework.context.annotation.Bean;
-import org.springframework.integration.annotation.InboundChannelAdapter;
-import org.springframework.integration.annotation.Poller;
-import org.springframework.integration.core.MessageSource;
-import org.springframework.messaging.MessageChannel;
-import org.springframework.messaging.SubscribableChannel;
-import org.springframework.messaging.support.GenericMessage;
-import reactor.core.publisher.Flux;
-
 import java.time.Duration;
 import java.util.concurrent.atomic.AtomicBoolean;
 import java.util.function.Consumer;
 import java.util.function.Function;
 import java.util.function.Supplier;
 
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.context.annotation.Bean;
+import reactor.core.publisher.Flux;
+
 @SpringBootApplication
 public class ReactiveProcessorApplication {