commit 9a38c4314abbc290396c75de28054898214c3d3f
author sicklife <tubkninght@gmail.com> Wed Jul 29 22:12:57 2020 +0800
committer James Yin <ywhjames@hotmail.com> Wed Jul 29 23:12:05 2020 +0800
tree ede3593c3c957a9969bb9e462eb29ff1734ca86a
parent 7e9ffd91c3f94a9e2ab3971ced6fb329a0c7e6ec

add set_instance_name function for producer

rocketmq/client.py

diff --git a/rocketmq/client.py b/rocketmq/client.py
index 7d2ce0c..106e321 100644
--- a/rocketmq/client.py
+++ b/rocketmq/client.py
@@ -230,6 +230,9 @@
     def set_group(self, group_name):
         ffi_check(dll.SetProducerGroupName(self._handle, _to_bytes(group_name)))
 
+    def set_instance_name(self, name):
+        ffi_check(dll.SetProducerInstanceName(self._handle, _to_bytes(name)))
+
     def set_name_server_address(self, addr):
         ffi_check(dll.SetProducerNameServerAddress(self._handle, _to_bytes(addr)))