tidal / WampWatch

     * @param $sessionId

     * @throws \RuntimeException if the topic is unknown.

     */

    public function completeSubscription($topicName, $requestId = 1, $sessionId = 1)

    {

        if (!isset($this->subscriptions[$topicName])) {

            throw new \RuntimeException("No subscription to topic '$topicName' initiated.");

        }

        /* @var $futureResult Deferred */

        $futureResult = $this->subscriptions[$topicName];

        $result = new SubscribedMessage($requestId, $sessionId);

        $futureResult->resolve($result);

    }

    /**

     * @param int    $publicationId

     * @throws \RuntimeException if the topic is unknown.

     */

    public function confirmPublication($topicName, $requestId = 1, $publicationId = 1)

    {

        if (!isset($this->publications[$topicName])) {

            throw new \RuntimeException("No publication to topic '$topicName' initiated.");

        }

        $futureResult = $this->publications[$topicName];

        $result = new PublishedMessage($requestId, $publicationId);

        $futureResult->resolve($result);

    }

    /**