You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by aa...@apache.org on 2022/07/29 11:36:57 UTC
[rocketmq-clients] branch master updated: Fix typo (#99)
This is an automated email from the ASF dual-hosted git repository.
aaronai pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git
The following commit(s) were added to refs/heads/master by this push:
new 9996d49 Fix typo (#99)
9996d49 is described below
commit 9996d49c167d5f4dcf487ef466a06f930a789013
Author: Aaron Ai <ya...@gmail.com>
AuthorDate: Fri Jul 29 19:36:53 2022 +0800
Fix typo (#99)
---
.../org/apache/rocketmq/client/java/impl/producer/ProducerImpl.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/java/client/src/main/java/org/apache/rocketmq/client/java/impl/producer/ProducerImpl.java b/java/client/src/main/java/org/apache/rocketmq/client/java/impl/producer/ProducerImpl.java
index 18662cc..04158ff 100644
--- a/java/client/src/main/java/org/apache/rocketmq/client/java/impl/producer/ProducerImpl.java
+++ b/java/client/src/main/java/org/apache/rocketmq/client/java/impl/producer/ProducerImpl.java
@@ -440,7 +440,7 @@ class ProducerImpl extends ClientImpl implements Producer {
if (producerSettings.isValidateMessageType() && !acceptMessageTypes.contains(messageType)) {
final IllegalArgumentException e = new IllegalArgumentException("Current message type not match with "
+ "topic accept message types, topic=" + topic + ", actualMessageType=" + messageType + ", "
- + "acceptMessageTypes={}" + acceptMessageTypes);
+ + "acceptMessageTypes=" + acceptMessageTypes);
future.setException(e);
return;
}