rocketmq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From duhengfore...@apache.org
Subject [rocketmq-ons] 24/43: Update ProducerImpl.java
Date Fri, 06 Dec 2019 04:22:46 GMT
This is an automated email from the ASF dual-hosted git repository.

duhengforever pushed a commit to branch OpenMessaging
in repository https://gitbox.apache.org/repos/asf/rocketmq-ons.git

commit c315d148f6458786a6edbe87834b9f7353856236
Author: davidpdw <402879834@qq.com>
AuthorDate: Wed Jul 17 11:50:20 2019 +0800

    Update ProducerImpl.java
    
    spelling mistake
---
 .../java/org/apache/rocketmq/ons/api/impl/rocketmq/ProducerImpl.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/ons-core/ons-client/src/main/java/org/apache/rocketmq/ons/api/impl/rocketmq/ProducerImpl.java
b/ons-core/ons-client/src/main/java/org/apache/rocketmq/ons/api/impl/rocketmq/ProducerImpl.java
index cfbe212..08f104d 100644
--- a/ons-core/ons-client/src/main/java/org/apache/rocketmq/ons/api/impl/rocketmq/ProducerImpl.java
+++ b/ons-core/ons-client/src/main/java/org/apache/rocketmq/ons/api/impl/rocketmq/ProducerImpl.java
@@ -231,7 +231,7 @@ public class ProducerImpl extends ONSClientAbstract implements Producer
{
                 } else if (e.getCause() instanceof MQBrokerException) {
                     MQBrokerException excep = (MQBrokerException) e.getCause();
                     return new ONSClientException(FAQ.errorMessage(
-                        String.format("Receive a broker exception, Topi=%s, msgId=%s, %s",
topic, msgId, excep.getErrorMessage()),
+                        String.format("Receive a broker exception, Topic=%s, msgId=%s, %s",
topic, msgId, excep.getErrorMessage()),
                         FAQ.BROKER_RESPONSE_EXCEPTION));
                 }
             } else {


Mime
View raw message