rocketmq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From vongosl...@apache.org
Subject [rocketmq] branch develop updated: Add @Override for RMQOrderListener.java (#1939)
Date Tue, 26 May 2020 03:20:51 GMT
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 <63688663+tuobuxie@users.noreply.github.com>
AuthorDate: Tue May 26 11:20:43 2020 +0800

    Add @Override for RMQOrderListener.java (#1939)
    
    Co-authored-by: lishaofeng <lishaofeng@xgd.com>
---
 .../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 != "") {


Mime
View raw message