'Deliver fanout message.'

def _put_fanout(self, exchange, message, routing_key, **kwargs):

    with self.conn_or_acquire() as client:
        client.publish(self._get_publish_topic(exchange, routing_key), dumps(message))
