Skip to content

Commit 393e391

Browse files
makasimmakasim
committed
fix enqueue bundle tests.
1 parent fbdf411 commit 393e391

22 files changed

Lines changed: 78 additions & 75 deletions

‎pkg/enqueue-bundle/Tests/Functional/Client/ConsumeMessagesCommandTest.php‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,7 @@ class ConsumeMessagesCommandTest extends WebTestCase
1212
{
1313
public function testCouldBeGetFromContainerAsService()
1414
{
15-
$command = $this->container->get(ConsumeMessagesCommand::class);
15+
$command = static::$container->get(ConsumeMessagesCommand::class);
1616

1717
$this->assertInstanceOf(ConsumeMessagesCommand::class, $command);
1818
}

‎pkg/enqueue-bundle/Tests/Functional/Client/DriverTest.php‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,7 @@ class DriverTest extends WebTestCase
1212
{
1313
public function testCouldBeGetFromContainerAsService()
1414
{
15-
$driver = $this->container->get('enqueue.client.driver');
15+
$driver = static::$container->get('enqueue.client.driver');
1616

1717
$this->assertInstanceOf(DriverInterface::class, $driver);
1818
}

‎pkg/enqueue-bundle/Tests/Functional/Client/ProduceMessageCommandTest.php‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,7 @@ class ProduceMessageCommandTest extends WebTestCase
1212
{
1313
public function testCouldBeGetFromContainerAsService()
1414
{
15-
$command = $this->container->get(ProduceMessageCommand::class);
15+
$command = static::$container->get(ProduceMessageCommand::class);
1616

1717
$this->assertInstanceOf(ProduceMessageCommand::class, $command);
1818
}

‎pkg/enqueue-bundle/Tests/Functional/Client/ProducerTest.php‎

Lines changed: 11 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -20,35 +20,35 @@ public function setUp()
2020
{
2121
parent::setUp();
2222

23-
$this->container->get(Producer::class)->clearTraces();
23+
static::$container->get(Producer::class)->clearTraces();
2424
}
2525

2626
public function tearDown()
2727
{
2828
parent::tearDown();
2929

30-
$this->container->get(Producer::class)->clearTraces();
30+
static::$container->get(Producer::class)->clearTraces();
3131
}
3232

3333
public function testCouldBeGetFromContainerAsService()
3434
{
35-
$messageProducer = $this->container->get(Producer::class);
35+
$messageProducer = static::$container->get(Producer::class);
3636

3737
$this->assertInstanceOf(ProducerInterface::class, $messageProducer);
3838
}
3939

4040
public function testCouldBeGetFromContainerAsShortenAlias()
4141
{
42-
$messageProducer = $this->container->get(Producer::class);
43-
$aliasMessageProducer = $this->container->get('enqueue.producer');
42+
$messageProducer = static::$container->get(Producer::class);
43+
$aliasMessageProducer = static::$container->get('enqueue.producer');
4444

4545
$this->assertSame($messageProducer, $aliasMessageProducer);
4646
}
4747

4848
public function testShouldSendEvent()
4949
{
5050
/** @var ProducerInterface $producer */
51-
$producer = $this->container->get(Producer::class);
51+
$producer = static::$container->get(Producer::class);
5252

5353
$producer->sendEvent('theTopic', 'theMessage');
5454

@@ -61,7 +61,7 @@ public function testShouldSendEvent()
6161
public function testShouldSendCommandWithoutNeedForReply()
6262
{
6363
/** @var ProducerInterface $producer */
64-
$producer = $this->container->get(Producer::class);
64+
$producer = static::$container->get(Producer::class);
6565

6666
$result = $producer->sendCommand('theCommand', 'theMessage', false);
6767

@@ -76,7 +76,7 @@ public function testShouldSendCommandWithoutNeedForReply()
7676
public function testShouldSendMessageInstanceAsCommandWithoutNeedForReply()
7777
{
7878
/** @var ProducerInterface $producer */
79-
$producer = $this->container->get(Producer::class);
79+
$producer = static::$container->get(Producer::class);
8080

8181
$message = new Message('theMessage');
8282

@@ -99,7 +99,7 @@ public function testShouldSendMessageInstanceAsCommandWithoutNeedForReply()
9999
public function testShouldSendExclusiveCommandWithNeedForReply()
100100
{
101101
/** @var ProducerInterface $producer */
102-
$producer = $this->container->get(Producer::class);
102+
$producer = static::$container->get(Producer::class);
103103

104104
$message = new Message('theMessage');
105105

@@ -122,7 +122,7 @@ public function testShouldSendExclusiveCommandWithNeedForReply()
122122
public function testShouldSendMessageInstanceCommandWithNeedForReply()
123123
{
124124
/** @var ProducerInterface $producer */
125-
$producer = $this->container->get(Producer::class);
125+
$producer = static::$container->get(Producer::class);
126126

127127
$message = new Message('theMessage');
128128

@@ -147,6 +147,6 @@ public function testShouldSendMessageInstanceCommandWithNeedForReply()
147147
*/
148148
private function getTraceableProducer()
149149
{
150-
return $this->container->get(Producer::class);
150+
return static::$container->get(Producer::class);
151151
}
152152
}

‎pkg/enqueue-bundle/Tests/Functional/Client/SpoolProducerTest.php‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,7 @@ class SpoolProducerTest extends WebTestCase
1212
{
1313
public function testCouldBeGetFromContainerAsService()
1414
{
15-
$producer = $this->container->get(SpoolProducer::class);
15+
$producer = static::$container->get(SpoolProducer::class);
1616

1717
$this->assertInstanceOf(SpoolProducer::class, $producer);
1818
}
@@ -22,8 +22,8 @@ public function testCouldBeGetFromContainerAsService()
2222
*/
2323
public function testCouldBeGetFromContainerAsShortenAlias()
2424
{
25-
$producer = $this->container->get('enqueue.client.spool_producer');
26-
$aliasProducer = $this->container->get('enqueue.spool_producer');
25+
$producer = static::$container->get('enqueue.client.spool_producer');
26+
$aliasProducer = static::$container->get('enqueue.spool_producer');
2727

2828
$this->assertSame($producer, $aliasProducer);
2929
}

‎pkg/enqueue-bundle/Tests/Functional/ConsumeMessagesCommandTest.php‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,7 @@ class ConsumeMessagesCommandTest extends WebTestCase
1111
{
1212
public function testCouldBeGetFromContainerAsService()
1313
{
14-
$command = $this->container->get(ConsumeMessagesCommand::class);
14+
$command = static::$container->get(ConsumeMessagesCommand::class);
1515

1616
$this->assertInstanceOf(ConsumeMessagesCommand::class, $command);
1717
}

‎pkg/enqueue-bundle/Tests/Functional/ContextTest.php‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,7 @@ class ContextTest extends WebTestCase
1111
{
1212
public function testCouldBeGetFromContainerAsService()
1313
{
14-
$connection = $this->container->get('enqueue.transport.context');
14+
$connection = static::$container->get('enqueue.transport.context');
1515

1616
$this->assertInstanceOf(PsrContext::class, $connection);
1717
}

‎pkg/enqueue-bundle/Tests/Functional/Events/AsyncListenerTest.php‎

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -20,35 +20,35 @@ public function setUp()
2020
parent::setUp();
2121

2222
/** @var AsyncListener $asyncListener */
23-
$asyncListener = $this->container->get('enqueue.events.async_listener');
23+
$asyncListener = static::$container->get('enqueue.events.async_listener');
2424

2525
$asyncListener->resetSyncMode();
2626
}
2727

2828
public function testShouldNotCallRealListenerIfMarkedAsAsync()
2929
{
3030
/** @var EventDispatcherInterface $dispatcher */
31-
$dispatcher = $this->container->get('event_dispatcher');
31+
$dispatcher = static::$container->get('event_dispatcher');
3232

3333
$dispatcher->dispatch('test_async', new GenericEvent('aSubject'));
3434

3535
/** @var TestAsyncListener $listener */
36-
$listener = $this->container->get('test_async_listener');
36+
$listener = static::$container->get('test_async_listener');
3737

3838
$this->assertEmpty($listener->calls);
3939
}
4040

4141
public function testShouldSendMessageToExpectedCommandInsteadOfCallingRealListener()
4242
{
4343
/** @var EventDispatcherInterface $dispatcher */
44-
$dispatcher = $this->container->get('event_dispatcher');
44+
$dispatcher = static::$container->get('event_dispatcher');
4545

4646
$event = new GenericEvent('theSubject', ['fooArg' => 'fooVal']);
4747

4848
$dispatcher->dispatch('test_async', $event);
4949

5050
/** @var TraceableProducer $producer */
51-
$producer = $this->container->get('enqueue.producer');
51+
$producer = static::$container->get('enqueue.producer');
5252

5353
$traces = $producer->getCommandTraces('symfony_events');
5454

@@ -61,14 +61,14 @@ public function testShouldSendMessageToExpectedCommandInsteadOfCallingRealListen
6161
public function testShouldSendMessageForEveryDispatchCall()
6262
{
6363
/** @var EventDispatcherInterface $dispatcher */
64-
$dispatcher = $this->container->get('event_dispatcher');
64+
$dispatcher = static::$container->get('event_dispatcher');
6565

6666
$dispatcher->dispatch('test_async', new GenericEvent('theSubject', ['fooArg' => 'fooVal']));
6767
$dispatcher->dispatch('test_async', new GenericEvent('theSubject', ['fooArg' => 'fooVal']));
6868
$dispatcher->dispatch('test_async', new GenericEvent('theSubject', ['fooArg' => 'fooVal']));
6969

7070
/** @var TraceableProducer $producer */
71-
$producer = $this->container->get('enqueue.producer');
71+
$producer = static::$container->get('enqueue.producer');
7272

7373
$traces = $producer->getCommandTraces('symfony_events');
7474

@@ -78,7 +78,7 @@ public function testShouldSendMessageForEveryDispatchCall()
7878
public function testShouldSendMessageIfDispatchedFromInsideListener()
7979
{
8080
/** @var EventDispatcherInterface $dispatcher */
81-
$dispatcher = $this->container->get('event_dispatcher');
81+
$dispatcher = static::$container->get('event_dispatcher');
8282

8383
$dispatcher->addListener('foo', function (Event $event, $eventName, EventDispatcherInterface $dispatcher) {
8484
$dispatcher->dispatch('test_async', new GenericEvent('theSubject', ['fooArg' => 'fooVal']));
@@ -87,7 +87,7 @@ public function testShouldSendMessageIfDispatchedFromInsideListener()
8787
$dispatcher->dispatch('foo');
8888

8989
/** @var TraceableProducer $producer */
90-
$producer = $this->container->get('enqueue.producer');
90+
$producer = static::$container->get('enqueue.producer');
9191

9292
$traces = $producer->getCommandTraces('symfony_events');
9393

‎pkg/enqueue-bundle/Tests/Functional/Events/AsyncProcessorTest.php‎

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -23,23 +23,23 @@ public function setUp()
2323
parent::setUp();
2424

2525
/** @var AsyncListener $asyncListener */
26-
$asyncListener = $this->container->get('enqueue.events.async_listener');
26+
$asyncListener = static::$container->get('enqueue.events.async_listener');
2727

2828
$asyncListener->resetSyncMode();
2929
}
3030

3131
public function testCouldBeGetFromContainerAsService()
3232
{
3333
/** @var AsyncProcessor $processor */
34-
$processor = $this->container->get('enqueue.events.async_processor');
34+
$processor = static::$container->get('enqueue.events.async_processor');
3535

3636
$this->assertInstanceOf(AsyncProcessor::class, $processor);
3737
}
3838

3939
public function testShouldRejectIfMessageDoesNotContainEventNameProperty()
4040
{
4141
/** @var AsyncProcessor $processor */
42-
$processor = $this->container->get('enqueue.events.async_processor');
42+
$processor = static::$container->get('enqueue.events.async_processor');
4343

4444
$message = new NullMessage();
4545

@@ -49,7 +49,7 @@ public function testShouldRejectIfMessageDoesNotContainEventNameProperty()
4949
public function testShouldRejectIfMessageDoesNotContainTransformerNameProperty()
5050
{
5151
/** @var AsyncProcessor $processor */
52-
$processor = $this->container->get('enqueue.events.async_processor');
52+
$processor = static::$container->get('enqueue.events.async_processor');
5353

5454
$message = new NullMessage();
5555
$message->setProperty('event_name', 'anEventName');
@@ -60,7 +60,7 @@ public function testShouldRejectIfMessageDoesNotContainTransformerNameProperty()
6060
public function testShouldCallRealListener()
6161
{
6262
/** @var AsyncProcessor $processor */
63-
$processor = $this->container->get('enqueue.events.async_processor');
63+
$processor = static::$container->get('enqueue.events.async_processor');
6464

6565
$message = new NullMessage();
6666
$message->setProperty('event_name', 'test_async');
@@ -73,7 +73,7 @@ public function testShouldCallRealListener()
7373
$this->assertEquals(PsrProcessor::ACK, $processor->process($message, new NullContext()));
7474

7575
/** @var TestAsyncListener $listener */
76-
$listener = $this->container->get('test_async_listener');
76+
$listener = static::$container->get('test_async_listener');
7777

7878
$this->assertNotEmpty($listener->calls);
7979

@@ -83,15 +83,15 @@ public function testShouldCallRealListener()
8383
$this->assertEquals('test_async', $listener->calls[0][1]);
8484

8585
$this->assertSame(
86-
$this->container->get('enqueue.events.event_dispatcher'),
86+
static::$container->get('enqueue.events.event_dispatcher'),
8787
$listener->calls[0][2]
8888
);
8989
}
9090

9191
public function testShouldCallRealSubscriber()
9292
{
9393
/** @var AsyncProcessor $processor */
94-
$processor = $this->container->get('enqueue.events.async_processor');
94+
$processor = static::$container->get('enqueue.events.async_processor');
9595

9696
$message = new NullMessage();
9797
$message->setProperty('event_name', 'test_async_subscriber');
@@ -104,7 +104,7 @@ public function testShouldCallRealSubscriber()
104104
$this->assertEquals(PsrProcessor::ACK, $processor->process($message, new NullContext()));
105105

106106
/** @var TestAsyncSubscriber $subscriber */
107-
$subscriber = $this->container->get('test_async_subscriber');
107+
$subscriber = static::$container->get('test_async_subscriber');
108108

109109
$this->assertNotEmpty($subscriber->calls);
110110

@@ -114,7 +114,7 @@ public function testShouldCallRealSubscriber()
114114
$this->assertEquals('test_async_subscriber', $subscriber->calls[0][1]);
115115

116116
$this->assertSame(
117-
$this->container->get('enqueue.events.event_dispatcher'),
117+
static::$container->get('enqueue.events.event_dispatcher'),
118118
$subscriber->calls[0][2]
119119
);
120120
}

‎pkg/enqueue-bundle/Tests/Functional/Events/AsyncSubscriberTest.php‎

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -20,35 +20,35 @@ public function setUp()
2020
parent::setUp();
2121

2222
/** @var AsyncListener $asyncListener */
23-
$asyncListener = $this->container->get('enqueue.events.async_listener');
23+
$asyncListener = static::$container->get('enqueue.events.async_listener');
2424

2525
$asyncListener->resetSyncMode();
2626
}
2727

2828
public function testShouldNotCallRealSubscriberIfMarkedAsAsync()
2929
{
3030
/** @var EventDispatcherInterface $dispatcher */
31-
$dispatcher = $this->container->get('event_dispatcher');
31+
$dispatcher = static::$container->get('event_dispatcher');
3232

3333
$dispatcher->dispatch('test_async_subscriber', new GenericEvent('aSubject'));
3434

3535
/** @var TestAsyncListener $listener */
36-
$listener = $this->container->get('test_async_subscriber');
36+
$listener = static::$container->get('test_async_subscriber');
3737

3838
$this->assertEmpty($listener->calls);
3939
}
4040

4141
public function testShouldSendMessageToExpectedTopicInsteadOfCallingRealSubscriber()
4242
{
4343
/** @var EventDispatcherInterface $dispatcher */
44-
$dispatcher = $this->container->get('event_dispatcher');
44+
$dispatcher = static::$container->get('event_dispatcher');
4545

4646
$event = new GenericEvent('theSubject', ['fooArg' => 'fooVal']);
4747

4848
$dispatcher->dispatch('test_async_subscriber', $event);
4949

5050
/** @var TraceableProducer $producer */
51-
$producer = $this->container->get('enqueue.producer');
51+
$producer = static::$container->get('enqueue.producer');
5252

5353
$traces = $producer->getCommandTraces('symfony_events');
5454

@@ -61,14 +61,14 @@ public function testShouldSendMessageToExpectedTopicInsteadOfCallingRealSubscrib
6161
public function testShouldSendMessageForEveryDispatchCall()
6262
{
6363
/** @var EventDispatcherInterface $dispatcher */
64-
$dispatcher = $this->container->get('event_dispatcher');
64+
$dispatcher = static::$container->get('event_dispatcher');
6565

6666
$dispatcher->dispatch('test_async_subscriber', new GenericEvent('theSubject', ['fooArg' => 'fooVal']));
6767
$dispatcher->dispatch('test_async_subscriber', new GenericEvent('theSubject', ['fooArg' => 'fooVal']));
6868
$dispatcher->dispatch('test_async_subscriber', new GenericEvent('theSubject', ['fooArg' => 'fooVal']));
6969

7070
/** @var TraceableProducer $producer */
71-
$producer = $this->container->get('enqueue.producer');
71+
$producer = static::$container->get('enqueue.producer');
7272

7373
$traces = $producer->getCommandTraces('symfony_events');
7474

@@ -78,7 +78,7 @@ public function testShouldSendMessageForEveryDispatchCall()
7878
public function testShouldSendMessageIfDispatchedFromInsideListener()
7979
{
8080
/** @var EventDispatcherInterface $dispatcher */
81-
$dispatcher = $this->container->get('event_dispatcher');
81+
$dispatcher = static::$container->get('event_dispatcher');
8282

8383
$dispatcher->addListener('foo', function (Event $event, $eventName, EventDispatcherInterface $dispatcher) {
8484
$dispatcher->dispatch('test_async_subscriber', new GenericEvent('theSubject', ['fooArg' => 'fooVal']));
@@ -87,7 +87,7 @@ public function testShouldSendMessageIfDispatchedFromInsideListener()
8787
$dispatcher->dispatch('foo');
8888

8989
/** @var TraceableProducer $producer */
90-
$producer = $this->container->get('enqueue.producer');
90+
$producer = static::$container->get('enqueue.producer');
9191

9292
$traces = $producer->getCommandTraces('symfony_events');
9393

0 commit comments

Comments
 (0)