[ISSUE #96] Fix the memory leak in Message (#98)
Message created by cpp library not released in class Message
diff --git a/rocketmq/client.py b/rocketmq/client.py
index 106e321..88ae128 100644
--- a/rocketmq/client.py
+++ b/rocketmq/client.py
@@ -71,6 +71,9 @@
class Message(object):
def __init__(self, topic):
self._handle = dll.CreateMessage(_to_bytes(topic))
+
+ def __del__(self):
+ dll.DestroyMessage(self._handle)
def set_keys(self, keys):
ffi_check(dll.SetMessageKeys(self._handle, _to_bytes(keys)))
