'Deprecated method to get the task publisher (now called producer).
Should be replaced with :class:`kombu.Producer`:
.. code-block:: python
with app.connection_for_write() as conn:
with app.amqp.Producer(conn) as prod:
my_task.apply_async(producer=prod)
or even better is to use the :class:`@amqp.producer_pool`:
.. code-block:: python
with app.producer_or_acquire() as prod:
my_task.apply_async(producer=prod)'

def get_publisher(self, connection=None, exchange=None, exchange_type=None, **options):

    exchange = (self.exchange if (exchange is None) else exchange)
    if (exchange_type is None):
        exchange_type = self.exchange_type
    connection = (connection or self.establish_connection())
    return self._get_app().amqp.Producer(connection, exchange=(exchange and Exchange(exchange, exchange_type)), routing_key=self.routing_key, auto_declare=False, **options)
