[Messenger] Reset traceable buses
This commit is contained in:
parent
4fb673677e
commit
c68887e1e8
@ -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)
|
||||
|
@ -52,4 +52,9 @@ class TraceableMessageBus implements MessageBusInterface
|
||||
{
|
||||
return $this->dispatchedMessages;
|
||||
}
|
||||
|
||||
public function reset()
|
||||
{
|
||||
$this->dispatchedMessages = array();
|
||||
}
|
||||
}
|
||||
|
Reference in New Issue
Block a user