Merge pull request #6 from duhenglucky/reduce_check
Reduce too strict check in ONS Client create process
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 @@
} 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 {