Re: [PR] Added the java4.x client cluster filter pull test content [rocketmq-e2e]

[via GitHub]

Zintoki commented on PR #51:
URL: https://github.com/apache/rocketmq-e2e/pull/51#issuecomment-1767985441

   OK
   
   
   
   ---Original---
   From: ***@***.***>
   Date: Wed, Oct 18, 2023 16:41 PM
   To: ***@***.***>;
   Cc: "XiaoWei ***@***.******@***.***>;
   Subject: Re: [apache/rocketmq-e2e] Added the java4.x client cluster 
filterpull test content (PR #51)
   
   
   
   
    
   @cryptoya approved this pull request.
    
    
   In 
java/e2e-v4/src/test/java/org/apache/rocketmq/server/abnormal/PushConsumerRetryTest.java:
    > +                } + +            }); +            
pushConsumer.start(); +        } catch (MQClientException e) { +            
Assertions.fail(e.getMessage()); +        } + +        
Assertions.assertNotNull(producer, "Get Producer Failed"); +        for (int i 
= 0; i < SEND_NUM; i++) { +            Message message = 
MessageFactory.buildNormalMessage(topic, tag, String.valueOf(i)); +            
producer.send(message); +        } +        Assertions.assertEquals(SEND_NUM, 
producer.getEnqueueMessages().getDataSize(), "send message failed"); + +        
TestUtils.waitForMinutes(2);  
   建议缩短等待时间，改成测试最大重试次数为0
    
   —
   Reply to this email directly, view it on GitHub, or unsubscribe.
   You are receiving this because you authored the thread.Message ID: 
***@***.***&gt;


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscr...@rocketmq.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org