You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
def basic_publish(self,
exchange,
routing_key,
body,
properties=None,
mandatory=False):
"""Publish to the channel with the given exchange, routing key and body.
For more information on basic_publish and what the parameters do, see:
http://www.rabbitmq.com/amqp-0-9-1-reference.html#basic.publish
:param str exchange: The exchange to publish to
:param str routing_key: The routing key to bind on
:param bytes body: The message body
:param pika.spec.BasicProperties properties: Basic.properties
:param bool mandatory: The mandatory flag
"""
self._raise_if_not_open()
if isinstance(body, unicode_type):
body = body.encode('utf-8')
properties = properties or spec.BasicProperties()
...
basic_publish
'sbody
parameter, e.g.:https://github.com/qubidt/pika-stubs/blob/a0e7b336e6b2f9a9bcde347725b9348871096080/pika-stubs/adapters/blocking_connection.pyi#L184-L191
or
https://github.com/qubidt/pika-stubs/blob/a0e7b336e6b2f9a9bcde347725b9348871096080/pika-stubs/channel.pyi#L110-L117
allows a
str
argument, per pika code:Copied from hahow/pika-stubs/issues/8
The text was updated successfully, but these errors were encountered: