|
14 | 14 | use Enqueue\Pheanstalk\PheanstalkConnectionFactory; |
15 | 15 | use Enqueue\RdKafka\RdKafkaConnectionFactory; |
16 | 16 | use Enqueue\Redis\RedisConnectionFactory; |
| 17 | +use Enqueue\Sns\SnsConnectionFactory; |
17 | 18 | use Enqueue\SnsQs\SnsQsConnectionFactory; |
18 | 19 | use Enqueue\Sqs\SqsConnectionFactory; |
19 | 20 | use Enqueue\Stomp\StompConnectionFactory; |
@@ -42,7 +43,7 @@ public static function getAvailableConnections(): array |
42 | 43 |
|
43 | 44 | $availableMap = []; |
44 | 45 | foreach ($map as $connectionClass => $item) { |
45 | | - if (class_exists($connectionClass)) { |
| 46 | + if (\class_exists($connectionClass)) { |
46 | 47 | $availableMap[$connectionClass] = $item; |
47 | 48 | } |
48 | 49 | } |
@@ -156,6 +157,10 @@ public static function getKnownConnections(): array |
156 | 157 | 'schemes' => ['sqs'], |
157 | 158 | 'supportedSchemeExtensions' => [], |
158 | 159 | 'package' => 'enqueue/sqs', ]; |
| 160 | + $map[SnsConnectionFactory::class] = [ |
| 161 | + 'schemes' => ['sns'], |
| 162 | + 'supportedSchemeExtensions' => [], |
| 163 | + 'package' => 'enqueue/sns', ]; |
159 | 164 | $map[SnsQsConnectionFactory::class] = [ |
160 | 165 | 'schemes' => ['snsqs'], |
161 | 166 | 'supportedSchemeExtensions' => [], |
@@ -183,9 +188,9 @@ public static function getKnownConnections(): array |
183 | 188 |
|
184 | 189 | public static function addConnection(string $connectionFactoryClass, array $schemes, array $extensions, string $package): void |
185 | 190 | { |
186 | | - if (class_exists($connectionFactoryClass)) { |
| 191 | + if (\class_exists($connectionFactoryClass)) { |
187 | 192 | if (false == (new \ReflectionClass($connectionFactoryClass))->implementsInterface(ConnectionFactory::class)) { |
188 | | - throw new \InvalidArgumentException(sprintf('The connection factory class "%s" must implement "%s" interface.', $connectionFactoryClass, ConnectionFactory::class)); |
| 193 | + throw new \InvalidArgumentException(\sprintf('The connection factory class "%s" must implement "%s" interface.', $connectionFactoryClass, ConnectionFactory::class)); |
189 | 194 | } |
190 | 195 | } |
191 | 196 |
|
|
0 commit comments