opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-09-19 10:54:54 +08:00
Code Issues Packages Projects Releases Wiki Activity

[ISSUE #5647]Polish PullMessageService some methods parameter name (#5650)

Browse Source
This commit is contained in:
mxsm
2022-12-06 08:43:20 +08:00
committed by GitHub
parent b56706423f
commit 0ac09dee70
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
client/src/main/java/org/apache/rocketmq/client/impl/consumer/PullMessageService.java
+4 -4
View File
@@ -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);
}