@@ -23,9 +23,9 @@ discard block |
||
23 | 23 | private readonly bool $isLegacy; |
24 | 24 | |
25 | 25 | public function __construct( |
26 | - private readonly HandlerInterface|CoreInterface $core, |
|
26 | + private readonly HandlerInterface | CoreInterface $core, |
|
27 | 27 | ?TracerFactoryInterface $tracerFactory = null, |
28 | - ) { |
|
28 | + ){ |
|
29 | 29 | $this->tracerFactory = $tracerFactory ?? new NullTracerFactory(new Container()); |
30 | 30 | $this->isLegacy = !$core instanceof HandlerInterface; |
31 | 31 | } |
@@ -51,17 +51,17 @@ discard block |
||
51 | 51 | return $tracer->trace( |
52 | 52 | name: \sprintf('Job handling [%s]', $name), |
53 | 53 | callback: $this->isLegacy |
54 | - ? fn(): mixed => $this->core->callAction($name, 'handle', $arguments) |
|
55 | - : fn(): mixed => $this->core->handle(new CallContext(Target::fromPair($name, 'handle'), $arguments)), |
|
56 | - attributes: [ |
|
54 | + ? fn() : mixed => $this->core->callAction($name, 'handle', $arguments) |
|
55 | + : fn() : mixed => $this->core->handle(new CallContext(Target::fromPair($name, 'handle'), $arguments)), |
|
56 | + attributes : [ |
|
57 | 57 | 'queue.driver' => $driver, |
58 | 58 | 'queue.name' => $queue, |
59 | 59 | 'queue.job.name' => $name, |
60 | 60 | 'queue.job.id' => $id, |
61 | 61 | 'queue.headers' => $headers, |
62 | 62 | ], |
63 | - scoped: true, |
|
64 | - traceKind: TraceKind::CONSUMER, |
|
63 | + scoped : true, |
|
64 | + traceKind : TraceKind::CONSUMER, |
|
65 | 65 | ); |
66 | 66 | } |
67 | 67 | } |