Skip to content

Commit 571ad81

Browse files
committed
Document the requirement for the send_async method
See apache#184 It should be documented that the callback should not throw any exception when passed to `send_async`.
1 parent daabc67 commit 571ad81

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

pulsar/__init__.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1237,6 +1237,8 @@ def send_async(self, content, callback,
12371237
--------
12381238
12391239
The ``callback`` will be invoked once the message has been acknowledged by the broker.
1240+
Users are responsible to handle the exception inside the callback. If any exception was
1241+
thrown from the callback, the process would terminate immediately.
12401242
12411243
.. code-block:: python
12421244

0 commit comments

Comments
 (0)