@defer.inlineCallbacks
    def test_event_retry(self):
        """Testing if the factory reconnects"""
        d = self.failIfNotCalledBeforeTimeout(protocols.AmqpFactory,
                                              'retry')
        f = protocols.AmqpFactory()
        c = reactor.connectTCP("localhost", 5672, f)
        f.protocol.transport.loseConnection()
        f.stopTrying()
        yield d