This is an automated email from the ASF dual-hosted git repository.
jerrypeng 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 493023a fix context publish signature (#3669)
493023a is described below
commit 493023a53ae12ea584e1724facc70d53da4f5a16
Author: Boyang Jerry Peng <jerry.boyang.p...@gmail.com>
AuthorDate: Fri Feb 22 10:34:11 2019 -0800
fix context publish signature (#3669)
---
pulsar-client-cpp/python/pulsar/functions/context.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/pulsar-client-cpp/python/pulsar/functions/context.py
b/pulsar-client-cpp/python/pulsar/functions/context.py
index 26e8606..bad6f35 100644
--- a/pulsar-client-cpp/python/pulsar/functions/context.py
+++ b/pulsar-client-cpp/python/pulsar/functions/context.py
@@ -124,7 +124,7 @@ class Context(object):
pass
@abstractmethod
- def publish(self, topic_name, message,
serde_class_name="serde.IdentitySerDe", properties=None, compression_type=None):
+ def publish(self, topic_name, message,
serde_class_name="serde.IdentitySerDe", properties=None, compression_type=None,
callback=None):
"""Publishes message to topic_name by first serializing the message using
serde_class_name serde
The message will have properties specified if any"""
pass
