[
https://issues.apache.org/jira/browse/ROCKETMQ-220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16040436#comment-16040436
]
ASF GitHub Bot commented on ROCKETMQ-220:
-----------------------------------------
Github user lizhanhui commented on a diff in the pull request:
https://github.com/apache/incubator-rocketmq/pull/114#discussion_r120556852
--- Diff:
test/src/main/java/org/apache/rocketmq/test/listener/AbstractListener.java ---
@@ -95,6 +95,28 @@ public void stopRecv() {
return sendMsgs;
}
+ public long waitForMessageConsume(int size,
+ int timeoutMills) {
+
+ long curTime = System.currentTimeMillis();
+ while (true) {
+ if (msgBodys.getDataSize() >= size) {
+ break;
+ }
+ if (System.currentTimeMillis() - curTime >= timeoutMills) {
+ logger.error(String.format("timeout but [%s] not recv
all send messages!",
--- End diff --
but [%s] not recv all send messages! --> but [%] did not receive all
messages sent!
> Add IT test for Filter By SQL 92
> --------------------------------
>
> Key: ROCKETMQ-220
> URL: https://issues.apache.org/jira/browse/ROCKETMQ-220
> Project: Apache RocketMQ
> Issue Type: Improvement
> Reporter: dongeforever
> Assignee: dongeforever
> Fix For: 4.1.0-incubating
>
>
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
