Revert "[RIP-37] Add new APIs for consumer (apache#4019)"

This reverts commit df5e885.
aaron-ai · Jun 20, 2022 · 603a9b9 · 603a9b9
1 parent cd24a24
commit 603a9b9
Show file tree

Hide file tree

Showing 9 changed files with 0 additions and 595 deletions.
diff --git a/apis/src/main/java/org/apache/rocketmq/apis/ClientServiceProvider.java b/apis/src/main/java/org/apache/rocketmq/apis/ClientServiceProvider.java
@@ -19,9 +19,6 @@
 
 import java.util.Iterator;
 import java.util.ServiceLoader;
-
-import org.apache.rocketmq.apis.consumer.PushConsumerBuilder;
-import org.apache.rocketmq.apis.consumer.SimpleConsumerBuilder;
 import org.apache.rocketmq.apis.message.MessageBuilder;
 import org.apache.rocketmq.apis.producer.ProducerBuilder;
 
@@ -46,20 +43,6 @@ static ClientServiceProvider loadService() {
  */
  ProducerBuilder newProducerBuilder();
 
- /**
- * Get the simple consumer builder by current provider.
- *
- * @return the simple consumer builder instance.
- */
- SimpleConsumerBuilder newSimpleConsumerBuilder();
-
- /**
- * Get the push consumer builder by current provider.
- *
- * @return the push consumer builder instance.
- */
- PushConsumerBuilder newPushConsumerBuilder();
-
  /**
  * Get the message builder by current provider.
  *

diff --git a/apis/src/main/java/org/apache/rocketmq/apis/consumer/ConsumeResult.java b/apis/src/main/java/org/apache/rocketmq/apis/consumer/ConsumeResult.java
diff --git a/apis/src/main/java/org/apache/rocketmq/apis/consumer/FilterExpression.java b/apis/src/main/java/org/apache/rocketmq/apis/consumer/FilterExpression.java
diff --git a/apis/src/main/java/org/apache/rocketmq/apis/consumer/FilterExpressionType.java b/apis/src/main/java/org/apache/rocketmq/apis/consumer/FilterExpressionType.java
diff --git a/apis/src/main/java/org/apache/rocketmq/apis/consumer/MessageListener.java b/apis/src/main/java/org/apache/rocketmq/apis/consumer/MessageListener.java
diff --git a/apis/src/main/java/org/apache/rocketmq/apis/consumer/PushConsumer.java b/apis/src/main/java/org/apache/rocketmq/apis/consumer/PushConsumer.java
diff --git a/apis/src/main/java/org/apache/rocketmq/apis/consumer/PushConsumerBuilder.java b/apis/src/main/java/org/apache/rocketmq/apis/consumer/PushConsumerBuilder.java