[incubator-tubemq] branch master updated: [TUBEMQ-406] modify test_consumer.py so it works for both Python 2 and 3 (#306)

[dockerzhang]

This is an automated email from the ASF dual-hosted git repository.

dockerzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-tubemq.git


The following commit(s) were added to refs/heads/master by this push:
     new 54c03fd  [TUBEMQ-406] modify test_consumer.py so it works for both 
Python 2 and 3 (#306)
54c03fd is described below

commit 54c03fd2284cdba063d33c206631fa5f37f6d277
Author: chao huang <mister.huangc...@gmail.com>
AuthorDate: Tue Nov 3 20:45:28 2020 -0800

    [TUBEMQ-406] modify test_consumer.py so it works for both Python 2 and 3 
(#306)
---
 .../src/python/example/consumer/test_consumer.py         | 16 +++++++++-------
 1 file changed, 9 insertions(+), 7 deletions(-)

diff --git 
a/tubemq-client-twins/tubemq-client-python/src/python/example/consumer/test_consumer.py
 
b/tubemq-client-twins/tubemq-client-python/src/python/example/consumer/test_consumer.py
index ce10958..2789f71 100644
--- 
a/tubemq-client-twins/tubemq-client-python/src/python/example/consumer/test_consumer.py
+++ 
b/tubemq-client-twins/tubemq-client-python/src/python/example/consumer/test_consumer.py
@@ -17,6 +17,8 @@
 # under the License.
 #
 
+from __future__ import print_function
+
 import tubemq_client
 import tubemq_config
 import tubemq_errcode
@@ -38,24 +40,24 @@ consumer_config.setRpcReadTimeoutMs(20000)
 # set master addr
 result = consumer_config.setMasterAddrInfo(err_info, master_addr)
 if not result:
-    print "Set Master AddrInfo failure:", err_info
+    print("Set Master AddrInfo failure:", err_info)
     exit(1)
 
 # set master addr
 result = consumer_config.setGroupConsumeTarget(err_info, group_name, 
topic_list)
 if not result:
-    print "Set GroupConsume Target failure:", err_info
+    print("Set GroupConsume Target failure:", err_info)
     exit(1)
 
 # StartTubeMQService
 result = tubemq_client.startTubeMQService(err_info, conf_file)
 if not result:
-    print "StartTubeMQService failure:", err_info
+    print("StartTubeMQService failure:", err_info)
     exit(1)
 
 result = py_consumer.start(err_info, consumer_config)
 if not result:
-    print "Initial consumer failure, error is:", err_info
+    print("Initial consumer failure, error is:", err_info)
     exit(1)
 
 gentRet = tubemq_return.ConsumerResult()
@@ -65,7 +67,7 @@ while True:
     result = py_consumer.getMessage(gentRet)
     if result:
         msgs = gentRet.getMessageList()
-        print "GetMessage success, msssage count =", len(msgs)
+        print("GetMessage success, msssage count =", len(msgs))
         result = py_consumer.confirm(gentRet.getConfirmContext(), True, 
confirm_result)
     else:
         # 2.2.1 if failure, check error code
@@ -76,7 +78,7 @@ while True:
                 or not gentRet.getErrCode() == 
tubemq_errcode.Result.kErrNoPartAssigned \
                 or not gentRet.getErrCode() == 
tubemq_errcode.Result.kErrAllPartInUse \
                 or not gentRet.getErrCode() == 
tubemq_errcode.Result.kErrAllPartWaiting:
-            print 'GetMessage failure, err_code=%d, err_msg is:%s', 
gentRet.getErrCode(), gentRet.getErrMessage()
+            print('GetMessage failure, err_code=%d, err_msg is:%s', 
gentRet.getErrCode(), gentRet.getErrMessage())
 
     # used for test, consume 10 minutes only
     stop_time = time.time()
@@ -87,5 +89,5 @@ while True:
 result = py_consumer.shutDown()
 result = tubemq_client.stopTubeMQService(err_info)
 if not result:
-    print "StopTubeMQService failure, reason is:" + err_info
+    print("StopTubeMQService failure, reason is:" + err_info)
     exit(1)