From 5002de07b6238c74cdb2891fa265fdfa5761f5cc Mon Sep 17 00:00:00 2001
From: "@Rome" <sunth0101@126.com>
Date: Thu, 23 Jul 2020 16:57:10 +0800
Subject: [PATCH] [ISSUE #2192] Typo fix in DefaultMQProducerImpl.java

fix typo
---
 .../rocketmq/client/impl/producer/DefaultMQProducerImpl.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java b/client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java
index 43dffd38..2f9146d9 100644
--- a/client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java
+++ b/client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java
@@ -1115,7 +1115,7 @@ public class DefaultMQProducerImpl implements MQProducerInner {
 
                 mq = mQClientFactory.getClientConfig().queueWithNamespace(selector.select(messageQueueList, userMessage, arg));
             } catch (Throwable e) {
-                throw new MQClientException("select message queue throwed exception.", e);
+                throw new MQClientException("select message queue threw exception.", e);
             }
 
             long costTime = System.currentTimeMillis() - beginStartTime;
-- 
GitLab