freyo / laravel-queue-cmq

src/Queue/Driver/Subscription.php

<?php

namespace Freyo\LaravelQueueCMQ\Queue\Driver;

class Subscription
{
    private $topic_name;
    private $subscription_name;
    private $cmq_client;
    private $encoding;

    public function __construct($topic_name, $subscription_name, CMQClient $cmq_client, $encoding = false)
    {
        $this->topic_name = $topic_name;
        $this->subscription_name = $subscription_name;
        $this->cmq_client = $cmq_client;
        $this->encoding = $encoding;
    }

    public function set_encoding($encoding)
    {
        $this->encoding = $encoding;
    }

    /*
     * create subscription
     * @type subscription_meta :SubscriptionMeta
     */
    public function create($subscription_meta)
    {
        $params = [
            'topicName'           => $this->topic_name,
            'subscriptionName'    => $this->subscription_name,
            'notifyStrategy'      => $subscription_meta->NotifyStrategy,
            'notifyContentFormat' => $subscription_meta->NotifyContentFormat,
        ];
        if ($subscription_meta->Endpoint != '') {
            $params['endpoint'] = $subscription_meta->Endpoint;
        }
        if ($subscription_meta->Protocol != '') {
            $params['protocol'] = $subscription_meta->Protocol;
        }

        if (is_array($subscription_meta->bindingKey) && !empty($subscription_meta->bindingKey)) {
            $n = 1;
            foreach ($subscription_meta->bindingKey as $tag) {
                $key = 'bindingKey.'.$n;
                $params[$key] = $tag;
                $n += 1;
            }
        }

        if (is_array($subscription_meta->FilterTag) && !empty($subscription_meta->FilterTag)) {
            $n = 1;
            foreach ($subscription_meta->FilterTag as $tag) {
                $key = 'filterTag.'.$n;
                $params[$key] = $tag;
                $n += 1;
            }
        }
        $this->cmq_client->create_subscription($params);
    }

    /*
     * delete subscription
     */
    public function delete()
    {
        $params = [
            'topicName'        => $this->topic_name,
            'subscriptionName' => $this->subscription_name,
        ];

        $this->cmq_client->delete_subscription($params);
    }

    /*
     * clear subscription tags
     */
    public function clearFilterTags()
    {
        $params = [
            'topicName'        => $this->topic_name,
            'subscriptionName' => $this->subscription_name,
        ];

        $this->cmq_client->clear_filterTags($params);
    }

    /*
     * get attributes
     *
     * @return subscription_meta :SubscriptionMeta

The type Freyo\LaravelQueueCMQ\Queue\Driver\subscription_meta was not found. Maybe you did not declare it correctly or list all dependencies?

     */
    public function get_attributes()
    {
        $params = [
            'topicName'        => $this->topic_name,
            'subscriptionName' => $this->subscription_name,
        ];

        $resp = $this->cmq_client->get_subscription_attributes($params);

        $subscription_meta = new SubscriptionMeta();
        $this->__resp2meta($subscription_meta, $resp);

        return $subscription_meta;

The expression return $subscription_meta returns the type Freyo\LaravelQueueCMQ\Queue\Driver\SubscriptionMeta which is incompatible with the documented return type Freyo\LaravelQueueCMQ\Queue\Driver\subscription_meta.

    }

    /*
     * set attributes
     * @type subscription_meta : SubscriptionMeta
     *
     */

    protected function __resp2meta($subscription_meta, $resp)
    {
        if (isset($resp['endpoint'])) {
            $subscription_meta->Endpoint = $resp['endpoint'];
        }
        if (isset($resp['protocol'])) {
            $subscription_meta->Protocol = $resp['protocol'];
        }
        if (isset($resp['notifyStrategy'])) {
            $subscription_meta->NotifyStrategy = $resp['notifyStrategy'];
        }
        if (isset($resp['notifyContentFormat'])) {
            $subscription_meta->NotifyContentFormat = $resp['notifyContentFormat'];
        }

        if (isset($resp['bindingKey'])) {
            foreach ($resp['bindingKey'] as $tag) {
                array_push($subscription_meta->bindingKey, $tag);
            }
        }

        if (isset($resp['filterTags'])) {
            foreach ($resp['filterTags'] as $tag) {
                array_push($subscription_meta->FilterTag, $tag);
            }
        }
    }

    public function set_attributes($subscription_meta)
    {
        $params = [
            'topicName'        => $this->topic_name,
            'subscriptionName' => $this->subscription_name,
        ];
        if ($subscription_meta->NotifyStrategy != '') {
            $params['notifyStrategy'] = $subscription_meta->NotifyStrategy;
        }

        if ($subscription_meta->NotifyContentFormat != '') {
            $params['notifyContentFormat'] = $subscription_meta->NotifyContentFormat;
        }

        if ($subscription_meta->Endpoint != '') {
            $params['endpoint'] = $subscription_meta->Endpoint;
        }
        if ($subscription_meta->Protocol != '') {
            $params['protocol'] = $subscription_meta->Protocol;
        }

        if (is_array($subscription_meta->bindingKey) && !empty($subscription_meta->bindingKey)) {
            $n = 1;
            foreach ($subscription_meta->bindingKey as $tag) {
                $key = 'bindingKey.'.$n;
                $params[$key] = $tag;
                $n += 1;
            }
        }

        if (is_array($subscription_meta->FilterTag) && !empty($subscription_meta->FilterTag)) {
            $n = 1;
            foreach ($subscription_meta->FilterTag as $tag) {
                $key = 'filterTag.'.$n;
                $params[$key] = $tag;
                $n += 1;
            }
        }

        $this->cmq_client->set_subscription_attributes($params);
    }
}