Method producer_or_acquire

celery/app/base.py:1091–1103

Context used to acquire a producer from the pool. For use within a :keyword:`with` statement to get a producer from the pool if one is not already provided Arguments: producer (kombu.Producer): If not provided, a producer will be acquired from th

(self, producer=None)

    default_connection = connection_or_acquire  class="cm"># XXX compat

    def producer_or_acquire(self, producer=None):
        class="st">"""Context used to acquire a producer from the pool.

        For use within a :keyword:`with` statement to get a producer
        from the pool if one is not already provided

        Arguments:
            producer (kombu.Producer): If not provided, a producer
                will be acquired from the producer pool.
        class="st">"""
        return FallbackContext(
            producer, self.producer_pool.acquire, block=True,
        )

    default_producer = producer_or_acquire  class="cm"># XXX compat