| Caller |
In
Worker.php
line
try {
$e = null;
$envelope = $this->bus->dispatch($envelope->with(new ReceivedStamp($transportName), new ConsumedByWorkerStamp(), new AckStamp($ack)));
} catch (\Throwable $e) {
}
|
| Bus |
messenger.bus.default |
| Message |
EffectConnect\Marketplaces\ScheduledTask\OfferQueueTask {#2132
#taskId: "019096ec2188710e84c2bd60ae42aaa1"
} |
| Envelope stamps when dispatching |
Symfony\Component\Messenger\Stamp\BusNameStamp {#1815
-busName: "messenger.bus.default"
}
Symfony\Component\Messenger\Stamp\SerializedMessageStamp {#2061
-serializedMessage: "{"taskId":"019096ec2188710e84c2bd60ae42aaa1"}"
}
Symfony\Component\Messenger\Bridge\Doctrine\Transport\DoctrineReceivedStamp {#4697
-id: "591735"
}
Symfony\Component\Messenger\Stamp\TransportMessageIdStamp {#4957
-id: "591735"
}
Symfony\Component\Messenger\Stamp\ReceivedStamp {#5493
-transportName: "v65"
}
Symfony\Component\Messenger\Stamp\ConsumedByWorkerStamp {#4792}
Symfony\Component\Messenger\Stamp\AckStamp {#4656
-ack: Closure(Envelope $envelope, ?Throwable $e = null) {#3159
class: "Symfony\Component\Messenger\Worker"
this: Symfony\Component\Messenger\Worker {#1807 …}
use: {
$transportName: "v65"
$acked: false
}
}
}
|
| Envelope stamps after dispatch |
Symfony\Component\Messenger\Stamp\BusNameStamp {#1815
-busName: "messenger.bus.default"
}
Symfony\Component\Messenger\Stamp\SerializedMessageStamp {#2061
-serializedMessage: "{"taskId":"019096ec2188710e84c2bd60ae42aaa1"}"
}
Symfony\Component\Messenger\Bridge\Doctrine\Transport\DoctrineReceivedStamp {#4697
-id: "591735"
}
Symfony\Component\Messenger\Stamp\TransportMessageIdStamp {#4957
-id: "591735"
}
Symfony\Component\Messenger\Stamp\ReceivedStamp {#5493
-transportName: "v65"
}
Symfony\Component\Messenger\Stamp\ConsumedByWorkerStamp {#4792}
Symfony\Component\Messenger\Stamp\AckStamp {#4656
-ack: Closure(Envelope $envelope, ?Throwable $e = null) {#3159
class: "Symfony\Component\Messenger\Worker"
this: Symfony\Component\Messenger\Worker {#1807 …}
use: {
$transportName: "v65"
$acked: false
}
}
}
Symfony\Component\Messenger\Stamp\HandledStamp {#5566
-result: null
-handlerName: "EffectConnect\Marketplaces\ScheduledTask\Handler\OfferQueueTaskHandler::__invoke"
}
|