-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathexample.php
More file actions
39 lines (30 loc) · 944 Bytes
/
Copy pathexample.php
File metadata and controls
39 lines (30 loc) · 944 Bytes
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
<?php
namespace App\Bundle\JobsBundle;
use App\Bundle\CoreBundle\Service\Geocoder\GeocoderInterface;
use App\Bundle\JobsBundle\Entity\Job;
use Ramsey\Uuid\Uuid;
$job = Job::initNew(
Uuid::uuid4()->toString(),
ExampleReverseGeocodeCommand::fromLonLat(0.5, 0.5),
new \DateTimeImmutable()
);
$jobManager = new JobManager();
$jobManager->enqueueJob($job);
/*
routing:
# async is whatever name you gave your transport above
'ReverseGeocodeAddress': async
*/
class ReverseGeocodeAddressHandler
{
private GeocoderInterface $geocoder;
public function __construct(GeocoderInterface $geocoder)
{
$this->geocoder = $geocoder;
}
public function __invoke(ExampleReverseGeocodeCommand $job): void
{
// вот тут хочется иметь $jobId, его надо как то достать из envelope?
// наверно логично его хранить в stamp
}
}