public function queue($eventName, $payload = array())
    {
        $me = $this;

        $this->subscribe($eventName . self::QUEUE_NAME, function () use ($me, $eventName, $payload) {
            return $me->dispatch($eventName, $payload);
        });
    }