Method basic_publish

pika/channel.py:462–486

Publish to the channel with the given exchange, routing key and body. For more information on basic_publish and what the parameters do, see: https://www.rabbitmq.com/amqp-0-9-1-reference.html#basic.publish :param str exchange: The exchange to publish to :param str r

(self,
                      exchange: str,
                      routing_key: str,
                      body: bytes,
                      properties: Optional[spec.BasicProperties] = None,
                      mandatory: bool = False)

            spec.Basic.Nack(delivery_tag, multiple, requeue))

    def basic_publish(self,
                      exchange: str,
                      routing_key: str,
                      body: bytes,
                      properties: Optional[spec.BasicProperties] = None,
                      mandatory: bool = False) -> None:
        """Publish to the channel with the given exchange, routing key and body.
        For more information on basic_publish and what the parameters do, see:

        https://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()
        body = as_bytes(body)
        properties = properties or spec.BasicProperties()
        self._send_method(
            spec.Basic.Publish(exchange=exchange,
                               routing_key=routing_key,
                               mandatory=mandatory), (properties, body))

    def basic_qos(self,
                  prefetch_size: int = 0,