Fixed typos.

lnas01 · Dec 14, 2016 · bd69f93 · bd69f93
1 parent dd817ec
commit bd69f93
Showing 1 changed file with 6 additions and 7 deletions.
diff --git a/...client/src/main/java/com/alibaba/rocketmq/client/impl/producer/DefaultMQProducerImpl.java b/...client/src/main/java/com/alibaba/rocketmq/client/impl/producer/DefaultMQProducerImpl.java
@@ -283,7 +283,7 @@ private void processTransactionState(//
                         break;
                     case UNKNOW:
                         thisHeader.setCommitOrRollback(MessageSysFlag.TransactionNotType);
-                        log.warn("when broker check, client donot know this transaction state, {}", thisHeader);
+                        log.warn("when broker check, client does not know this transaction state, {}", thisHeader);
                         break;
                     default:
                         break;
@@ -496,7 +496,6 @@ private SendResult sendDefaultImpl(//
                         this.updateFaultItem(mq.getBrokerName(), endTimestamp - beginTimestampPrev, false);
                         log.warn(String.format("sendKernelImpl exception, throw exception, InvokeID: %s, RT: %sms, Broker: %s", invokeID, endTimestamp - beginTimestampPrev, mq), e);
                         log.warn(msg.toString());
-                        exception = e;
 
                         log.warn("sendKernelImpl exception", e);
                         log.warn(msg.toString());
@@ -784,7 +783,7 @@ public void sendOneway(Message msg) throws MQClientException, RemotingException,
         try {
             this.sendDefaultImpl(msg, CommunicationMode.ONEWAY, null, this.defaultMQProducer.getSendMsgTimeout());
         } catch (MQBrokerException e) {
-            throw new MQClientException("unknow exception", e);
+            throw new MQClientException("unknown exception", e);
         }
     }
 
@@ -828,7 +827,7 @@ public void send(Message msg, MessageQueue mq, SendCallback sendCallback, long t
         try {
             this.sendKernelImpl(msg, mq, CommunicationMode.ASYNC, sendCallback, null, timeout);
         } catch (MQBrokerException e) {
-            throw new MQClientException("unknow exception", e);
+            throw new MQClientException("unknown exception", e);
         }
     }
 
@@ -842,7 +841,7 @@ public void sendOneway(Message msg, MessageQueue mq) throws MQClientException, R
         try {
             this.sendKernelImpl(msg, mq, CommunicationMode.ONEWAY, null, null, this.defaultMQProducer.getSendMsgTimeout());
         } catch (MQBrokerException e) {
-            throw new MQClientException("unknow exception", e);
+            throw new MQClientException("unknown exception", e);
         }
     }
 
@@ -875,7 +874,7 @@ private SendResult sendSelectImpl(//
             try {
                 mq = selector.select(topicPublishInfo.getMessageQueueList(), msg, arg);
             } catch (Throwable e) {
-                throw new MQClientException("select message queue throwed exception.", e);
+                throw new MQClientException("select message queue throws exception.", e);
             }
 
             if (mq != null) {
@@ -913,7 +912,7 @@ public void sendOneway(Message msg, MessageQueueSelector selector, Object arg)
         try {
             this.sendSelectImpl(msg, selector, arg, CommunicationMode.ONEWAY, null, this.defaultMQProducer.getSendMsgTimeout());
         } catch (MQBrokerException e) {
-            throw new MQClientException("unknow exception", e);
+            throw new MQClientException("unknown exception", e);
         }
     }