public function handleReceived(Event $event, Queue $queue)
    {
        $connection = $event->getConnection();
        $timers = $this->getTimers();
        if ($timers->contains($connection)) {
            $timers->offsetGet($connection)->cancel();
        } else {
            $this->getLogger()->debug('Attaching activity listener for connection');
        }

        $timer = $this->getLoop()->addTimer($this->wait, array($this, 'callbackPhoneHome'));
        $timer->setData($connection);
        $timers->attach($connection, $timer);
    }