tidal / WampWatch

     *

     * @throws UnknownTopicException if the topic is unknown

     */

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

    {

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

            throw new UnknownTopicException($topicName);

        }

        /* @var $futureResult Deferred */

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

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

        $futureResult->resolve($result);

    }

    public function hasSubscription($topicName)

    {

     *

     * @throws UnknownTopicException if the topic is unknown

     */

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

    {

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

            throw new UnknownTopicException($topicName);

        }

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

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

        $futureResult->resolve($result);

    }

    public function failPublication($topicName, $error, $requestId = 1)

    {