'Declare exchange if not already declared during this session.'

def maybe_declare(self, entity, retry=False, **retry_policy):

    if entity:
        return maybe_declare(entity, self.channel, retry, **retry_policy)
