This is an automated email from the ASF dual-hosted git repository.
mmerli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new 25958ba Python Client: fix `Consumer.unsubscribe` (#3093)
25958ba is described below
commit 25958bac6f2d286d075bab327f719169edd8cde4
Author: François Laignel <[email protected]>
AuthorDate: Fri Nov 30 01:42:32 2018 +0100
Python Client: fix `Consumer.unsubscribe` (#3093)
* Python Client: fix `Consumer.unsubscribe`
Fix a typo in `self._consumer.unsubscribe`
* Python Client: test `Consumer.unsubscribe`
---
pulsar-client-cpp/python/pulsar/__init__.py | 2 +-
pulsar-client-cpp/python/pulsar_test.py | 1 +
2 files changed, 2 insertions(+), 1 deletion(-)
diff --git a/pulsar-client-cpp/python/pulsar/__init__.py
b/pulsar-client-cpp/python/pulsar/__init__.py
index 8004fa6..f8646b2 100644
--- a/pulsar-client-cpp/python/pulsar/__init__.py
+++ b/pulsar-client-cpp/python/pulsar/__init__.py
@@ -811,7 +811,7 @@ class Consumer:
This consumer object cannot be reused.
"""
- return self._consumer.unsubcribe()
+ return self._consumer.unsubscribe()
def receive(self, timeout_millis=None):
"""
diff --git a/pulsar-client-cpp/python/pulsar_test.py
b/pulsar-client-cpp/python/pulsar_test.py
index 158c79c..a78505c 100755
--- a/pulsar-client-cpp/python/pulsar_test.py
+++ b/pulsar-client-cpp/python/pulsar_test.py
@@ -135,6 +135,7 @@ class PulsarTest(TestCase):
except:
pass # Exception is expected
+ consumer.unsubscribe()
client.close()
def test_tls_auth(self):
