'Handle Connection.Blocked notification from RabbitMQ broker
:param pika.frame.Method method_frame: method frame having `method`
member of type `pika.spec.Connection.Blocked`'

def _on_connection_blocked(self, method_frame):

    LOGGER.warning('Received    %s    from    broker', method_frame)
    if (self._blocked_conn_timer is not None):
        LOGGER.warning('_blocked_conn_timer    %s    already    set    when    _on_connection_blocked    is    called', self._blocked_conn_timer)
    else:
        self._blocked_conn_timer = self.add_timeout(self.params.blocked_connection_timeout, self._on_blocked_connection_timeout)
