'QueueOwnerAWSAccountId' =>
$this->configuration
['account'
],
])->
isSuccess()) { return;
} if (null !==
$this->configuration
['account'
]) { throw new InvalidArgumentException(sprintf('The Amazon SQS queue "%s" does not exist (or you don\'t have permissions on it), and can\'t be created when an account is provided.',
$this->configuration
['queue_name'
]));
} $parameters =
['QueueName' =>
$this->configuration
['queue_name'
]];
if (self::
isFifoQueue($this->configuration
['queue_name'
])) { $parameters['Attributes'
] =
[ 'FifoQueue' => 'true',
];
} $this->client->
createQueue($parameters);
$exists =
$this->client->
queueExists(['QueueName' =>
$this->configuration
['queue_name'
]]);
// Blocking call to wait for the queue to be created
$exists->
wait();
if (!
$exists->
isSuccess()) { throw new TransportException(sprintf('Failed to create the Amazon SQS queue "%s".',
$this->configuration
['queue_name'
]));
}