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