code: def process_bulk_queue(self, es_bulk_kwargs=None):
          
          with current_celery_app.pool.acquire(block=True) as conn:
              consumer = Consumer(
                  connection=conn,
                  queue=self.mq_queue.name,
                  exchange=self.mq_exchange.name,
                  routing_key=self.mq_routing_key,
              )
  
              req_timeout = current_app.config['INDEXER_BULK_REQUEST_TIMEOUT']
  
              es_bulk_kwargs = es_bulk_kwargs or {}
              count = bulk(
                  self.client,
                  self._actionsiter(consumer.iterqueue()),
                  stats_only=True,
                  request_timeout=req_timeout,
                  **es_bulk_kwargs
              )
  
              consumer.close()
  
          return count
docs: Process bulk indexing queue.
  
          :param dict es_bulk_kwargs: Passed to
              :func:`elasticsearch:elasticsearch.helpers.bulk`.