diogo/symfony
Archived
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

[Messenger] Reset traceable buses

Browse Source
This commit is contained in:
Maxime Steinhausser 2018-05-01 14:54:27 +02:00
parent 4fb673677e
commit c68887e1e8
2 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/Symfony/Component/Messenger/DataCollector/MessengerDataCollector.php
View File

@ -67,6 +67,9 @@ class MessengerDataCollector extends DataCollector implements LateDataCollectorI
public function reset()
{
$this->data = array();
foreach ($this->traceableBuses as $traceableBus) {
$traceableBus->reset();
}
}
private function collectMessage(string $busName, array $tracedMessage)

5
src/Symfony/Component/Messenger/TraceableMessageBus.php
View File

@ -52,4 +52,9 @@ class TraceableMessageBus implements MessageBusInterface
{
return $this->dispatchedMessages;
}
public function reset()
{
$this->dispatchedMessages = array();
}
}