Skip to content

Commit

Permalink
Fixed namespace
Browse files Browse the repository at this point in the history
  • Loading branch information
MiloTischler committed Feb 14, 2024
1 parent 74bcd7a commit c645b8a
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions src/Connector.php
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
<?php

namespace App\Connectors;
namespace DigitalClaim\AzureQueue;

use Illuminate\Queue\Connectors\ConnectorInterface;
use MicrosoftAzure\Storage\Queue\QueueRestProxy;
Expand All @@ -13,14 +13,14 @@ class Connector implements ConnectorInterface
*/
public function connect(array $config): AzureQueue
{
$connectionString = 'DefaultEndpointsProtocol='.$config['protocol'].';AccountName='.$config['accountname'].';AccountKey='.$config['key'];
$connectionString = 'DefaultEndpointsProtocol=' . $config['protocol'] . ';AccountName=' . $config['accountname'] . ';AccountKey=' . $config['key'];

if (isset($config['endpoint']) && $config['endpoint'] !== '') {
$connectionString .= ';EndpointSuffix='.$config['endpoint'];
$connectionString .= ';EndpointSuffix=' . $config['endpoint'];
}

if (isset($config['queue_endpoint']) && $config['queue_endpoint'] !== '') {
$connectionString .= ';QueueEndpoint='.$config['queue_endpoint'];
$connectionString .= ';QueueEndpoint=' . $config['queue_endpoint'];
}

$queueRestProxy = QueueRestProxy::createQueueService($connectionString);
Expand Down

0 comments on commit c645b8a

Please sign in to comment.