'Default behavior when the connecting connection can not connect.
:raises: exceptions.AMQPConnectionError'

def _on_connection_error(self, _connection_unused, error_message=None):

    raise exceptions.AMQPConnectionError((error_message or self.params.connection_attempts))
