Add @Override for RMQOrderListener.java (#1939)

Co-authored-by: N lishaofeng <lishaofeng@xgd.com>

Add @Override for RMQOrderListener.java (#1939)
Co-authored-by: N lishaofeng <lishaofeng@xgd.com>
67b8a2aa · Shaofeng Li · GitHub · f12cc81e · 67b8a2aa
隐藏空白更改
内联并排

Showing with 2 addition and 1 deletion

test/src/main/java/org/apache/rocketmq/test/listener/rmq/order/RMQOrderListener.java ...he/rocketmq/test/listener/rmq/order/RMQOrderListener.java +2 -1

未找到文件。
--- 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 != "") {