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()
...
The text was updated successfully, but these errors were encountered:
basic_publish
'sbody
parameter, e.g.:pika-stubs/pika-stubs/adapters/blocking_connection.pyi
Lines 171 to 178 in 361dc1a
or
pika-stubs/pika-stubs/channel.pyi
Lines 110 to 117 in 361dc1a
allows a
str
argument, per pika code:The text was updated successfully, but these errors were encountered: