[rocketmq] branch develop updated: delete PullConsumer.Test (#5139)

[lizhanhui]

This is an automated email from the ASF dual-hosted git repository.

lizhanhui pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new 4d0de5d18 delete PullConsumer.Test (#5139)
4d0de5d18 is described below

commit 4d0de5d1826221b8d765da8379a6571acd436a38
Author: aievl <65518067+azhsme...@users.noreply.github.com>
AuthorDate: Tue Sep 20 23:11:56 2022 +0800

    delete PullConsumer.Test (#5139)
    
    Co-authored-by: zhaozhenhang <zhaozhenh...@kuaishou.com>
---
 .../rocketmq/example/simple/PullConsumerTest.java  | 48 ----------------------
 1 file changed, 48 deletions(-)

diff --git 
a/example/src/main/java/org/apache/rocketmq/example/simple/PullConsumerTest.java
 
b/example/src/main/java/org/apache/rocketmq/example/simple/PullConsumerTest.java
deleted file mode 100644
index f12595a90..000000000
--- 
a/example/src/main/java/org/apache/rocketmq/example/simple/PullConsumerTest.java
+++ /dev/null
@@ -1,48 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.rocketmq.example.simple;
-
-import org.apache.rocketmq.client.consumer.DefaultMQPullConsumer;
-import org.apache.rocketmq.client.consumer.PullResult;
-import org.apache.rocketmq.client.exception.MQClientException;
-import org.apache.rocketmq.common.message.MessageQueue;
-
-public class PullConsumerTest {
-    public static void main(String[] args) throws MQClientException {
-        DefaultMQPullConsumer consumer = new 
DefaultMQPullConsumer("please_rename_unique_group_name_5");
-        consumer.setNamesrvAddr("127.0.0.1:9876");
-        consumer.start();
-
-        try {
-            MessageQueue mq = new MessageQueue();
-            mq.setQueueId(0);
-            mq.setTopic("TopicTest3");
-            mq.setBrokerName("vivedeMacBook-Pro.local");
-
-            long offset = 26;
-
-            long beginTime = System.currentTimeMillis();
-            PullResult pullResult = consumer.pullBlockIfNotFound(mq, null, 
offset, 32);
-            System.out.printf("%s%n", System.currentTimeMillis() - beginTime);
-            System.out.printf("%s%n", pullResult);
-        } catch (Exception e) {
-            e.printStackTrace();
-        }
-
-        consumer.shutdown();
-    }
-}