commit 78a22d361a05e58eb9cee3407ca17538f8e49b6e
author messense <messense@icloud.com> Wed Aug 28 10:19:06 2019 +0800
committer messense <messense@icloud.com> Thu Oct 17 15:43:39 2019 +0800
tree d5f0e87a720c70a0ebfdcb616fda08ac7ab5bb44
parent 42ccb445f00a275c18d35603124824bed941a497

Refine message decode to utf-8

rocketmq/client.py

diff --git a/rocketmq/client.py b/rocketmq/client.py
index 873e0cb..f1db810 100644
--- a/rocketmq/client.py
+++ b/rocketmq/client.py
@@ -21,8 +21,10 @@
 PY2 = sys.version_info[0] == 2
 if PY2:
     text_type = unicode
+    binary_type = str
 else:
     text_type = str
+    binary_type = bytes
 
 SendResult = namedtuple('SendResult', ['status', 'msg_id', 'offset'])
 
@@ -69,7 +71,7 @@
 
 
 def maybe_decode(val):
-    if val:
+    if isinstance(val, binary_type):
         return val.decode('utf-8')
 
 

rocketmq/exceptions.py

diff --git a/rocketmq/exceptions.py b/rocketmq/exceptions.py
index 8ea4906..5beb83f 100644
--- a/rocketmq/exceptions.py
+++ b/rocketmq/exceptions.py
@@ -19,7 +19,7 @@
         return
     exc_cls = _EXCEPTION_MAP.get(status_code, RocketMQException)
     msg = dll.GetLatestErrorMessage()
-    if msg:
+    if msg is not None:
         msg = msg.decode('utf-8')
         msg = re.sub('<.*?(rocketmq-client-cpp/)(.*)>', '\\1\\2', msg)
         if msg.startswith('msg: '):