@@ -64,7 +64,7 @@ |
||
| 64 | 64 | * |
| 65 | 65 | * @see examples/sqs folder |
| 66 | 66 | * |
| 67 | - * @param AMQPChannel $client |
|
| 67 | + * @param SqsClient $client |
|
| 68 | 68 | * @param string $queueName |
| 69 | 69 | * @param array $queueAttributes |
| 70 | 70 | */ |
@@ -2,11 +2,10 @@ |
||
| 2 | 2 | |
| 3 | 3 | namespace Tomaj\Hermes\Driver; |
| 4 | 4 | |
| 5 | +use Aws\Sqs\SqsClient; |
|
| 5 | 6 | use Closure; |
| 6 | -use Exception; |
|
| 7 | 7 | use Tomaj\Hermes\MessageInterface; |
| 8 | 8 | use Tomaj\Hermes\MessageSerializer; |
| 9 | -use Aws\Sqs\SqsClient; |
|
| 10 | 9 | |
| 11 | 10 | class AmazonSqsDriver implements DriverInterface |
| 12 | 11 | { |
@@ -5,7 +5,7 @@ |
||
| 5 | 5 | use Tomaj\Hermes\Message; |
| 6 | 6 | use PhpAmqpLib\Connection\AMQPStreamConnection; |
| 7 | 7 | |
| 8 | -require_once __DIR__ . '/../../vendor/autoload.php'; |
|
| 8 | +require_once __DIR__.'/../../vendor/autoload.php'; |
|
| 9 | 9 | |
| 10 | 10 | |
| 11 | 11 | $queueName = 'hermes_queue'; |
@@ -8,7 +8,7 @@ |
||
| 8 | 8 | require_once __DIR__ . '/../../vendor/autoload.php'; |
| 9 | 9 | |
| 10 | 10 | $client = SqsClient::factory([ |
| 11 | - 'version' => 'latest', |
|
| 11 | + 'version' => 'latest', |
|
| 12 | 12 | 'region' => 'eu-west-1', |
| 13 | 13 | 'key' => '*key*', |
| 14 | 14 | 'secret' => '*secret*', |
@@ -8,7 +8,7 @@ |
||
| 8 | 8 | require_once __DIR__ . '/../../vendor/autoload.php'; |
| 9 | 9 | |
| 10 | 10 | $client = SqsClient::factory([ |
| 11 | - 'version' => 'latest', |
|
| 11 | + 'version' => 'latest', |
|
| 12 | 12 | 'region' => 'eu-west-1', |
| 13 | 13 | 'key' => '*key*', |
| 14 | 14 | 'secret' => '*secret*', |
@@ -5,7 +5,7 @@ |
||
| 5 | 5 | use Tomaj\Hermes\Message; |
| 6 | 6 | use PhpAmqpLib\Connection\AMQPStreamConnection; |
| 7 | 7 | |
| 8 | -require_once __DIR__ . '/../../vendor/autoload.php'; |
|
| 8 | +require_once __DIR__.'/../../vendor/autoload.php'; |
|
| 9 | 9 | |
| 10 | 10 | |
| 11 | 11 | $queueName = 'hermes_queue'; |