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

def _on_connection_unblocked(self, method_frame):

    LOGGER.info('Received    %s    from    broker', method_frame)
    if (self._blocked_conn_timer is None):
        LOGGER.warning('_blocked_conn_timer    was    not    active    when    _on_connection_unblocked    called')
    else:
        self.remove_timeout(self._blocked_conn_timer)
        self._blocked_conn_timer = None
