This is an automated email from the ASF dual-hosted git repository.
vongosling 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 67b8a2a Add @Override for RMQOrderListener.java (#1939)
67b8a2a is described below
commit 67b8a2aa83a7a120e286bf7c34854cc4addfa532
Author: Shaofeng Li <[email protected]>
AuthorDate: Tue May 26 11:20:43 2020 +0800
Add @Override for RMQOrderListener.java (#1939)
Co-authored-by: lishaofeng <[email protected]>
---
.../org/apache/rocketmq/test/listener/rmq/order/RMQOrderListener.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git
a/test/src/main/java/org/apache/rocketmq/test/listener/rmq/order/RMQOrderListener.java
b/test/src/main/java/org/apache/rocketmq/test/listener/rmq/order/RMQOrderListener.java
index 85c6177..f483866 100644
---
a/test/src/main/java/org/apache/rocketmq/test/listener/rmq/order/RMQOrderListener.java
+++
b/test/src/main/java/org/apache/rocketmq/test/listener/rmq/order/RMQOrderListener.java
@@ -64,8 +64,9 @@ public class RMQOrderListener extends AbstractListener
implements MessageListene
return String.format("%s_%s", queueId, brokerIp);
}
+ @Override
public ConsumeOrderlyStatus consumeMessage(List<MessageExt> msgs,
- ConsumeOrderlyContext context) {
+ ConsumeOrderlyContext context) {
for (MessageExt msg : msgs) {
if (isDebug) {
if (listenerName != null && listenerName != "") {