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 c826373598 [ISSUE #8798] Fix typo (#8799)
c826373598 is described below
commit c8263735986837e7636bb7faf8f3cd40d01d3113
Author: luozongle01 <[email protected]>
AuthorDate: Thu Oct 10 09:52:45 2024 +0800
[ISSUE #8798] Fix typo (#8799)
---
.../org/apache/rocketmq/broker/processor/PeekMessageProcessor.java | 4 ++--
.../org/apache/rocketmq/broker/processor/ReplyMessageProcessor.java | 6 +++---
.../main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java | 4 ++--
.../org/apache/rocketmq/test/client/rmq/RMQBroadCastConsumer.java | 4 ++--
.../apache/rocketmq/test/clientinterface/AbstractMQConsumer.java | 4 ++--
5 files changed, 11 insertions(+), 11 deletions(-)
diff --git
a/broker/src/main/java/org/apache/rocketmq/broker/processor/PeekMessageProcessor.java
b/broker/src/main/java/org/apache/rocketmq/broker/processor/PeekMessageProcessor.java
index 55552003d8..2c0a1cd54a 100644
---
a/broker/src/main/java/org/apache/rocketmq/broker/processor/PeekMessageProcessor.java
+++
b/broker/src/main/java/org/apache/rocketmq/broker/processor/PeekMessageProcessor.java
@@ -258,8 +258,8 @@ public class PeekMessageProcessor implements
NettyRequestProcessor {
BrokerMetricsManager.throughputOutTotal.add(getMessageResult.getBufferTotalSize(),
attributes);
}
- for (SelectMappedBufferResult mapedBuffer :
getMessageTmpResult.getMessageMapedList()) {
- getMessageResult.addMessage(mapedBuffer);
+ for (SelectMappedBufferResult mappedBuffer :
getMessageTmpResult.getMessageMapedList()) {
+ getMessageResult.addMessage(mappedBuffer);
}
}
return restNum;
diff --git
a/broker/src/main/java/org/apache/rocketmq/broker/processor/ReplyMessageProcessor.java
b/broker/src/main/java/org/apache/rocketmq/broker/processor/ReplyMessageProcessor.java
index d3bb048f75..a70b48debe 100644
---
a/broker/src/main/java/org/apache/rocketmq/broker/processor/ReplyMessageProcessor.java
+++
b/broker/src/main/java/org/apache/rocketmq/broker/processor/ReplyMessageProcessor.java
@@ -115,10 +115,10 @@ public class ReplyMessageProcessor extends
AbstractSendMessageProcessor {
response.addExtField(MessageConst.PROPERTY_TRACE_SWITCH,
String.valueOf(this.brokerController.getBrokerConfig().isTraceOn()));
log.debug("receive SendReplyMessage request command, {}", request);
- final long startTimstamp =
this.brokerController.getBrokerConfig().getStartAcceptSendRequestTimeStamp();
- if (this.brokerController.getMessageStore().now() < startTimstamp) {
+ final long startTimestamp =
this.brokerController.getBrokerConfig().getStartAcceptSendRequestTimeStamp();
+ if (this.brokerController.getMessageStore().now() < startTimestamp) {
response.setCode(ResponseCode.SYSTEM_ERROR);
- response.setRemark(String.format("broker unable to service, until
%s", UtilAll.timeMillisToHumanString2(startTimstamp)));
+ response.setRemark(String.format("broker unable to service, until
%s", UtilAll.timeMillisToHumanString2(startTimestamp)));
return response;
}
diff --git
a/client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java
b/client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java
index 0a45f09623..0e5571eb13 100644
--- a/client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java
+++ b/client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java
@@ -1619,10 +1619,10 @@ public class MQClientAPIImpl implements
NameServerUpdateCallback, StartAndShutdo
final QueryMessageRequestHeader requestHeader,
final long timeoutMillis,
final InvokeCallback invokeCallback,
- final Boolean isUnqiueKey
+ final Boolean isUniqueKey
) throws RemotingException, MQBrokerException, InterruptedException {
RemotingCommand request =
RemotingCommand.createRequestCommand(RequestCode.QUERY_MESSAGE, requestHeader);
- request.addExtField(MixAll.UNIQUE_MSG_QUERY_FLAG,
isUnqiueKey.toString());
+ request.addExtField(MixAll.UNIQUE_MSG_QUERY_FLAG,
isUniqueKey.toString());
this.remotingClient.invokeAsync(MixAll.brokerVIPChannel(this.clientConfig.isVipChannelEnabled(),
addr), request, timeoutMillis,
invokeCallback);
}
diff --git
a/test/src/main/java/org/apache/rocketmq/test/client/rmq/RMQBroadCastConsumer.java
b/test/src/main/java/org/apache/rocketmq/test/client/rmq/RMQBroadCastConsumer.java
index 2a59619744..7ac5ec3978 100644
---
a/test/src/main/java/org/apache/rocketmq/test/client/rmq/RMQBroadCastConsumer.java
+++
b/test/src/main/java/org/apache/rocketmq/test/client/rmq/RMQBroadCastConsumer.java
@@ -26,8 +26,8 @@ public class RMQBroadCastConsumer extends RMQNormalConsumer {
private static Logger logger =
LoggerFactory.getLogger(RMQBroadCastConsumer.class);
public RMQBroadCastConsumer(String nsAddr, String topic, String
subExpression,
- String consumerGroup, AbstractListener listner) {
- super(nsAddr, topic, subExpression, consumerGroup, listner);
+ String consumerGroup, AbstractListener listener) {
+ super(nsAddr, topic, subExpression, consumerGroup, listener);
}
@Override
diff --git
a/test/src/main/java/org/apache/rocketmq/test/clientinterface/AbstractMQConsumer.java
b/test/src/main/java/org/apache/rocketmq/test/clientinterface/AbstractMQConsumer.java
index 5681ecc841..22193bb4ba 100644
---
a/test/src/main/java/org/apache/rocketmq/test/clientinterface/AbstractMQConsumer.java
+++
b/test/src/main/java/org/apache/rocketmq/test/clientinterface/AbstractMQConsumer.java
@@ -69,8 +69,8 @@ public abstract class AbstractMQConsumer implements
MQConsumer {
return listener;
}
- public void setListener(AbstractListener listner) {
- this.listener = listner;
+ public void setListener(AbstractListener listener) {
+ this.listener = listener;
}
public String getNsAddr() {
