File tree 4 files changed +15
-32
lines changed
4 files changed +15
-32
lines changed Original file line number Diff line number Diff line change 2
2
3
3
namespace Enqueue \Sqs \Tests \Spec ;
4
4
5
- use Enqueue \Sqs \ SqsConnectionFactory ;
5
+ use Enqueue \Test \ SqsExtension ;
6
6
use Interop \Queue \Spec \PsrProducerSpec ;
7
7
8
8
/**
9
9
* @group functional
10
10
*/
11
11
class SqsProducerTest extends PsrProducerSpec
12
12
{
13
+ use SqsExtension;
14
+
13
15
/**
14
16
* {@inheritdoc}
15
17
*/
16
18
protected function createProducer ()
17
19
{
18
- $ factory = new SqsConnectionFactory ([
19
- 'key ' => getenv ('AWS__SQS__KEY ' ),
20
- 'secret ' => getenv ('AWS__SQS__SECRET ' ),
21
- 'region ' => getenv ('AWS__SQS__REGION ' ),
22
- ]);
23
-
24
- return $ factory ->createContext ()->createProducer ();
20
+ return $ this ->buildSqsContext ()->createProducer ();
25
21
}
26
22
}
Original file line number Diff line number Diff line change 2
2
3
3
namespace Enqueue \Sqs \Tests \Spec ;
4
4
5
- use Enqueue \Sqs \SqsConnectionFactory ;
6
5
use Enqueue \Sqs \SqsContext ;
7
6
use Enqueue \Sqs \SqsDestination ;
8
7
use Enqueue \Test \RetryTrait ;
8
+ use Enqueue \Test \SqsExtension ;
9
9
use Interop \Queue \PsrContext ;
10
10
use Interop \Queue \Spec \SendAndReceiveDelayedMessageFromQueueSpec ;
11
11
16
16
class SqsSendAndReceiveDelayedMessageFromQueueTest extends SendAndReceiveDelayedMessageFromQueueSpec
17
17
{
18
18
use RetryTrait;
19
+ use SqsExtension;
19
20
20
21
/**
21
22
* @var SqsContext
@@ -41,13 +42,7 @@ protected function tearDown()
41
42
*/
42
43
protected function createContext ()
43
44
{
44
- $ factory = new SqsConnectionFactory ([
45
- 'key ' => getenv ('AWS__SQS__KEY ' ),
46
- 'secret ' => getenv ('AWS__SQS__SECRET ' ),
47
- 'region ' => getenv ('AWS__SQS__REGION ' ),
48
- ]);
49
-
50
- return $ this ->context = $ factory ->createContext ();
45
+ return $ this ->context = $ this ->buildSqsContext ();
51
46
}
52
47
53
48
/**
Original file line number Diff line number Diff line change 2
2
3
3
namespace Enqueue \Sqs \Tests \Spec ;
4
4
5
- use Enqueue \Sqs \SqsConnectionFactory ;
6
5
use Enqueue \Sqs \SqsContext ;
7
6
use Enqueue \Sqs \SqsDestination ;
7
+ use Enqueue \Test \SqsExtension ;
8
8
use Interop \Queue \PsrContext ;
9
9
use Interop \Queue \Spec \SendToAndReceiveFromQueueSpec ;
10
10
13
13
*/
14
14
class SqsSendToAndReceiveFromQueueTest extends SendToAndReceiveFromQueueSpec
15
15
{
16
+ use SqsExtension;
17
+
16
18
/**
17
19
* @var SqsContext
18
20
*/
@@ -37,13 +39,7 @@ protected function tearDown()
37
39
*/
38
40
protected function createContext ()
39
41
{
40
- $ factory = new SqsConnectionFactory ([
41
- 'key ' => getenv ('AWS__SQS__KEY ' ),
42
- 'secret ' => getenv ('AWS__SQS__SECRET ' ),
43
- 'region ' => getenv ('AWS__SQS__REGION ' ),
44
- ]);
45
-
46
- return $ this ->context = $ factory ->createContext ();
42
+ return $ this ->context = $ this ->buildSqsContext ();
47
43
}
48
44
49
45
/**
Original file line number Diff line number Diff line change 2
2
3
3
namespace Enqueue \Sqs \Tests \Spec ;
4
4
5
- use Enqueue \Sqs \SqsConnectionFactory ;
6
5
use Enqueue \Sqs \SqsContext ;
7
6
use Enqueue \Sqs \SqsDestination ;
7
+ use Enqueue \Test \SqsExtension ;
8
8
use Interop \Queue \PsrContext ;
9
9
use Interop \Queue \Spec \SendToAndReceiveFromTopicSpec ;
10
10
13
13
*/
14
14
class SqsSendToAndReceiveFromTopicTest extends SendToAndReceiveFromTopicSpec
15
15
{
16
+ use SqsExtension;
17
+
16
18
/**
17
19
* @var SqsContext
18
20
*/
@@ -37,13 +39,7 @@ protected function tearDown()
37
39
*/
38
40
protected function createContext ()
39
41
{
40
- $ factory = new SqsConnectionFactory ([
41
- 'key ' => getenv ('AWS__SQS__KEY ' ),
42
- 'secret ' => getenv ('AWS__SQS__SECRET ' ),
43
- 'region ' => getenv ('AWS__SQS__REGION ' ),
44
- ]);
45
-
46
- return $ this ->context = $ factory ->createContext ();
42
+ return $ this ->context = $ this ->buildSqsContext ();
47
43
}
48
44
49
45
/**
You can’t perform that action at this time.
0 commit comments