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 <[email protected]>
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;
}