Skip to content

Commit 42edb58

Browse files
committed
snsqs fix typo
1 parent 6c11421 commit 42edb58

File tree

4 files changed

+7
-7
lines changed

4 files changed

+7
-7
lines changed

SnsQsConnectionFactory.php

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -71,9 +71,9 @@ public function __construct($config = 'snsqs:')
7171
*/
7272
public function createContext(): Context
7373
{
74-
return new SnsQsContext(function() {
74+
return new SnsQsContext(function () {
7575
return (new SnsConnectionFactory($this->snsConfig))->createContext();
76-
}, function() {
76+
}, function () {
7777
return (new SqsConnectionFactory($this->sqsConfig))->createContext();
7878
});
7979
}
@@ -96,7 +96,7 @@ private function parseOptions(array $options): void
9696
{
9797
// set default options
9898
foreach ($options as $key => $value) {
99-
if (false === in_array(substr($key, 0, 4), ['sns_', 'sqs_'])) {
99+
if (false === in_array(substr($key, 0, 4), ['sns_', 'sqs_'], true)) {
100100
$this->snsConfig[$key] = $value;
101101
$this->sqsConfig[$key] = $value;
102102
}

SnsQsConsumer.php

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -86,10 +86,10 @@ private function convertMessage(SqsMessage $sqsMessage): SnsQsMessage
8686

8787
$body = $sqsMessage->getBody();
8888

89-
if (isset($body[0]) && $body[0] === '{') {
89+
if (isset($body[0]) && '{' === $body[0]) {
9090
$data = json_decode($sqsMessage->getBody(), true);
9191

92-
if (isset($data['TopicArn']) && isset($data['Type']) && $data['Type'] === 'Notification') {
92+
if (isset($data['TopicArn']) && isset($data['Type']) && 'Notification' === $data['Type']) {
9393
// SNS message conversion
9494
if (isset($data['Message'])) {
9595
$message->setBody((string) $data['Message']);

SnsQsProducer.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -43,7 +43,7 @@ public function __construct(SnsContext $snsContext, SqsContext $sqsContext)
4343
}
4444

4545
/**
46-
* @param SnsQsTopic $destination
46+
* @param SnsQsTopic $destination
4747
* @param SnsQsMessage $message
4848
*/
4949
public function send(Destination $destination, Message $message): void

Tests/Spec/SnsQsSendToAndReceiveNoWaitFromQueueTest.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,7 @@
1010
* @group functional
1111
* @retry 5
1212
*/
13-
class SqsQsSendToAndReceiveNoWaitFromQueueTest extends SendToAndReceiveNoWaitFromQueueSpec
13+
class SnsQsSendToAndReceiveNoWaitFromQueueTest extends SendToAndReceiveNoWaitFromQueueSpec
1414
{
1515
use RetryTrait;
1616
use SnsQsFactoryTrait;

0 commit comments

Comments
 (0)