You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by ji...@apache.org on 2022/12/06 00:43:46 UTC
[rocketmq] branch develop updated: [ISSUE #5647]Polish PullMessageService some methods parameter name (#5650)
This is an automated email from the ASF dual-hosted git repository.
jinrongtong 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 0ac09dee7 [ISSUE #5647]Polish PullMessageService some methods parameter name (#5650)
0ac09dee7 is described below
commit 0ac09dee70801a31675f65cd981394aca1d8ce0b
Author: mxsm <lj...@gmail.com>
AuthorDate: Tue Dec 6 08:43:20 2022 +0800
[ISSUE #5647]Polish PullMessageService some methods parameter name (#5650)
---
.../apache/rocketmq/client/impl/consumer/PullMessageService.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/PullMessageService.java b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/PullMessageService.java
index d64c88d2e..d4801c335 100644
--- a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/PullMessageService.java
+++ b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/PullMessageService.java
@@ -66,12 +66,12 @@ public class PullMessageService extends ServiceThread {
}
}
- public void executePopPullRequestLater(final PopRequest pullRequest, final long timeDelay) {
+ public void executePopPullRequestLater(final PopRequest popRequest, final long timeDelay) {
if (!isStopped()) {
this.scheduledExecutorService.schedule(new Runnable() {
@Override
public void run() {
- PullMessageService.this.executePopPullRequestImmediately(pullRequest);
+ PullMessageService.this.executePopPullRequestImmediately(popRequest);
}
}, timeDelay, TimeUnit.MILLISECONDS);
} else {
@@ -79,9 +79,9 @@ public class PullMessageService extends ServiceThread {
}
}
- public void executePopPullRequestImmediately(final PopRequest pullRequest) {
+ public void executePopPullRequestImmediately(final PopRequest popRequest) {
try {
- this.messageRequestQueue.put(pullRequest);
+ this.messageRequestQueue.put(popRequest);
} catch (InterruptedException e) {
logger.error("executePullRequestImmediately pullRequestQueue.put", e);
}