src/Provider/AwsProvider.php
public function create()
    {
        $this->createQueue();

        if ($this->options['push_notifications']) {
            // Create the SNS Topic
            $this->createTopic();

            // Add the SQS Queue as a Subscriber to the SNS Topic
            $this->subscribeToTopic(
                $this->topicArn,
                'sqs',
                $this->sqs->getQueueArn($this->queueUrl)
            );

            // Add configured Subscribers to the SNS Topic
            foreach ($this->options['subscribers'] as $subscriber) {
                $this->subscribeToTopic(
                    $this->topicArn,
                    $subscriber['protocol'],
                    $subscriber['endpoint']
                );
            }
        }

        return true;
    }
public function create()
    {
        $this->createQueue();

        if ($this->options['push_notifications']) {
            // Create the SNS Topic
            $this->createTopic();

            // Add the SQS Queue as a Subscriber to the SNS Topic
            $this->subscribeToTopic(
                $this->topicArn,
                'sqs',
                $this->sqs->getQueueArn($this->queueUrl)
            );

            // Add configured Subscribers to the SNS Topic
            foreach ($this->options['subscribers'] as $subscriber) {
                $this->subscribeToTopic(
                    $this->topicArn,
                    $subscriber['protocol'],
                    $subscriber['endpoint']
                );
            }
        }

        return true;
    }
public function create ( ) { $ this -> createQueue ( ) ; if ( $ this -> options [ 'push_notifications' ] ) { // Create the SNS Topic $ this -> createTopic ( ) ; // Add the SQS Queue as a Subscriber to the SNS Topic $ this -> subscribeToTopic ( $ this -> topicArn , 'sqs' , $ this -> sqs -> getQueueArn ( $ this -> queueUrl ) ) ; // Add configured Subscribers to the SNS Topic foreach ( $ this -> options [ 'subscribers' ] as $ subscriber ) { $ this -> subscribeToTopic ( $ this -> topicArn , $ subscriber [ 'protocol' ] , $ subscriber [ 'endpoint' ] ) ; } } return true ; }
Builds the configured queues

If a Queue name is passed and configured, this method will build only that
Queue.

All Create methods are idempotent, if the resource exists, the current ARN
will be returned

@return bool
Builds the configured queues