-
Notifications
You must be signed in to change notification settings - Fork 2
Open
Description
basic_publish's body parameter, e.g.:
pika-stubs/pika-stubs/adapters/blocking_connection.pyi
Lines 171 to 178 in 361dc1a
| def basic_publish( | |
| self, | |
| exchange: str, | |
| routing_key: str, | |
| body: bytes, | |
| properties: Optional[spec.BasicProperties] = ..., | |
| mandatory: bool = ..., | |
| ) -> None: ... |
or
pika-stubs/pika-stubs/channel.pyi
Lines 110 to 117 in 361dc1a
| def basic_publish( | |
| self, | |
| exchange: str, | |
| routing_key: str, | |
| body: bytes, | |
| properties: Optional[spec.BasicProperties] = ..., | |
| mandatory: bool = ..., | |
| ) -> None: ... |
allows a str argument, per pika code:
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()
...
Reactions are currently unavailable
Metadata
Metadata
Assignees
Labels
No labels