Skip to content

Commit 049d943

Browse files
committed
fix
Change-Id: Ie2faff9942027a510c4550a9f2bf2df8c6283137
1 parent 335be05 commit 049d943

1 file changed

Lines changed: 7 additions & 7 deletions

File tree

broker/src/main/java/org/apache/rocketmq/broker/pop/orderly/QueueLevelConsumerManager.java

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -191,9 +191,9 @@ public void start() {
191191
/**
192192
* mark message is consumed finished. return the consumer offset
193193
*
194-
* @param topic topic
195-
* @param group group
196-
* @param queueId queue id of message
194+
* @param topic topic
195+
* @param group group
196+
* @param queueId queue id of message
197197
* @param queueOffset queue offset of message
198198
* @return -1 : illegal, -2 : no need commit, >= 0 : commit
199199
*/
@@ -251,10 +251,10 @@ public long commitAndNext(String topic, String group, int queueId, long queueOff
251251
/**
252252
* update next visible time of this message
253253
*
254-
* @param topic topic
255-
* @param group group
256-
* @param queueId queue id of message
257-
* @param queueOffset queue offset of message
254+
* @param topic topic
255+
* @param group group
256+
* @param queueId queue id of message
257+
* @param queueOffset queue offset of message
258258
* @param nextVisibleTime nex visible time
259259
*/
260260
@Override

0 commit comments

Comments
 (0)