From c1eb444ff2a64a477e09584efb073985b02aff7f Mon Sep 17 00:00:00 2001
From: Warren Zhu <zhonzh@microsoft.com>
Date: Fri, 25 May 2018 10:41:50 +0800
Subject: [PATCH] Remove unnecessary Subscriber type parameter

---
 .../main/java/eventhub/integration/inbound/Subscriber.java   | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git a/spring-cloud-azure-eventhub/src/main/java/eventhub/integration/inbound/Subscriber.java b/spring-cloud-azure-eventhub/src/main/java/eventhub/integration/inbound/Subscriber.java
index 13f11c3c..c34d298d 100644
--- a/spring-cloud-azure-eventhub/src/main/java/eventhub/integration/inbound/Subscriber.java
+++ b/spring-cloud-azure-eventhub/src/main/java/eventhub/integration/inbound/Subscriber.java
@@ -13,16 +13,15 @@ import java.util.function.Consumer;
  * {@link Checkpointer} callback to checkpoint the messages successfully processed
  *
  * @param <T> message type parameter
- * @param <I> {@link Iterable} of message type parameter
  *
  * @author Warren Zhu
  */
-public interface Subscriber<T, I extends Iterable<T>> {
+public interface Subscriber<T> {
 
     /**
      * Start receiving message, then process using provided {@link Consumer}
      */
-    void subscribe(Consumer<I> consumer);
+    void subscribe(Consumer<Iterable<T>> consumer);
 
     /**
      * Stop receiving message