@@ -69,7 +69,7 @@ static function($This) {
69
69
"PhpAmqpLib\Channel\AMQPChannel " ,
70
70
"basic_deliver " ,
71
71
[
72
- 'prehook ' => function (SpanData $ span , $ args ) use (&$ newTrace ) {
72
+ 'prehook ' => static function (SpanData $ span , $ args ) use (&$ newTrace ) {
73
73
/** @var AMQPMessage $message */
74
74
$ message = $ args [1 ];
75
75
if (AMQPIntegration::hasDistributedHeaders ($ message )) {
@@ -79,7 +79,7 @@ static function($This) {
79
79
$ newTrace ->links [] = $ span ->getLink ();
80
80
}
81
81
},
82
- 'posthook ' => function (SpanData $ span , $ args ) use (&$ newTrace ) {
82
+ 'posthook ' => static function (SpanData $ span , $ args ) use (&$ newTrace ) {
83
83
/** @var AMQPMessage $message */
84
84
$ message = $ args [1 ];
85
85
@@ -126,14 +126,14 @@ static function($This) {
126
126
"PhpAmqpLib\Channel\AMQPChannel " ,
127
127
"basic_publish " ,
128
128
[
129
- 'prehook ' => function (SpanData $ span , $ args ) {
129
+ 'prehook ' => static function (SpanData $ span , $ args ) {
130
130
/** @var AMQPMessage $message */
131
131
$ message = $ args [0 ];
132
132
if (!is_null ($ message )) {
133
133
AMQPIntegration::injectContext ($ message );
134
134
}
135
135
},
136
- 'posthook ' => function (SpanData $ span , $ args , $ exception ) {
136
+ 'posthook ' => static function (SpanData $ span , $ args , $ exception ) {
137
137
/** @var AMQPMessage $message */
138
138
$ message = $ args [0 ];
139
139
/** @var string $exchange */
@@ -168,14 +168,14 @@ static function($This) {
168
168
"PhpAmqpLib\Channel\AMQPChannel " ,
169
169
"batch_basic_publish " ,
170
170
[
171
- 'prehook ' => function (SpanData $ span , $ args ) {
171
+ 'prehook ' => static function (SpanData $ span , $ args ) {
172
172
/** @var AMQPMessage $message */
173
173
$ message = $ args [0 ];
174
174
if (!is_null ($ message )) {
175
175
AMQPIntegration::injectContext ($ message );
176
176
}
177
177
},
178
- 'posthook ' => function (SpanData $ span , $ args , $ exception ) {
178
+ 'posthook ' => static function (SpanData $ span , $ args , $ exception ) {
179
179
/** @var AMQPMessage $message */
180
180
$ message = $ args [0 ];
181
181
/** @var string $exchange */
@@ -208,7 +208,7 @@ static function($This) {
208
208
trace_method (
209
209
"PhpAmqpLib\Channel\AMQPChannel " ,
210
210
"publish_batch " ,
211
- function (SpanData $ span , $ args , $ exception ) {
211
+ static function (SpanData $ span , $ args , $ exception ) {
212
212
AMQPIntegration::setGenericTags (
213
213
$ span ,
214
214
'publish_batch ' ,
@@ -223,7 +223,7 @@ function (SpanData $span, $args, $exception) {
223
223
trace_method (
224
224
"PhpAmqpLib\Channel\AMQPChannel " ,
225
225
"basic_consume " ,
226
- function (SpanData $ span , $ args , $ retval , $ exception ) {
226
+ static function (SpanData $ span , $ args , $ retval , $ exception ) {
227
227
/** @var string $queue */
228
228
$ queue = $ args [0 ];
229
229
/** @var string $consumer_tag */
@@ -247,7 +247,7 @@ function (SpanData $span, $args, $retval, $exception) {
247
247
trace_method (
248
248
'PhpAmqpLib\Channel\AMQPChannel ' ,
249
249
'exchange_declare ' ,
250
- function (SpanData $ span , $ args , $ retval , $ exception ) {
250
+ static function (SpanData $ span , $ args , $ retval , $ exception ) {
251
251
/** @var string $exchange */
252
252
$ exchange = $ args [0 ];
253
253
@@ -267,7 +267,7 @@ function (SpanData $span, $args, $retval, $exception) {
267
267
trace_method (
268
268
'PhpAmqpLib\Channel\AMQPChannel ' ,
269
269
'queue_declare ' ,
270
- function (SpanData $ span , $ args , $ retval , $ exception ) {
270
+ static function (SpanData $ span , $ args , $ retval , $ exception ) {
271
271
/** @var string $queue */
272
272
$ queue = $ args [0 ];
273
273
if (empty ($ queue ) && is_array ($ retval )) {
@@ -290,7 +290,7 @@ function (SpanData $span, $args, $retval, $exception) {
290
290
trace_method (
291
291
'PhpAmqpLib\Channel\AMQPChannel ' ,
292
292
'queue_bind ' ,
293
- function (SpanData $ span , $ args , $ retval , $ exception ) {
293
+ static function (SpanData $ span , $ args , $ retval , $ exception ) {
294
294
295
295
/** @var string $queue */
296
296
$ queue = $ args [0 ];
@@ -320,7 +320,7 @@ function (SpanData $span, $args, $retval, $exception) {
320
320
trace_method (
321
321
'PhpAmqpLib\Channel\AMQPChannel ' ,
322
322
'basic_consume_ok ' ,
323
- function (SpanData $ span ) {
323
+ static function (SpanData $ span ) {
324
324
AMQPIntegration::setGenericTags ($ span , 'basic.consume_ok ' , 'server ' );
325
325
326
326
$ span ->meta [Tag::MQ_OPERATION ] = 'process ' ;
@@ -330,7 +330,7 @@ function (SpanData $span) {
330
330
trace_method (
331
331
'PhpAmqpLib\Channel\AMQPChannel ' ,
332
332
'basic_cancel ' ,
333
- function (SpanData $ span , $ args , $ retval , $ exception ) {
333
+ static function (SpanData $ span , $ args , $ retval , $ exception ) {
334
334
/** @var string $consumerTag */
335
335
$ consumerTag = $ args [0 ];
336
336
@@ -348,31 +348,31 @@ function (SpanData $span, $args, $retval, $exception) {
348
348
trace_method (
349
349
'PhpAmqpLib\Channel\AMQPChannel ' ,
350
350
'basic_cancel_ok ' ,
351
- function (SpanData $ span , $ args , $ retval , $ exception ) {
351
+ static function (SpanData $ span , $ args , $ retval , $ exception ) {
352
352
AMQPIntegration::setGenericTags ($ span , 'basic.cancel_ok ' , 'server ' , null , $ exception );
353
353
}
354
354
);
355
355
356
356
trace_method (
357
357
'PhpAmqpLib\Connection\AbstractConnection ' ,
358
358
'connect ' ,
359
- function (SpanData $ span , $ args , $ retval , $ exception ) {
359
+ static function (SpanData $ span , $ args , $ retval , $ exception ) {
360
360
AMQPIntegration::setGenericTags ($ span , 'connect ' , 'client ' , null , $ exception );
361
361
}
362
362
);
363
363
364
364
trace_method (
365
365
'PhpAmqpLib\Connection\AbstractConnection ' ,
366
366
'reconnect ' ,
367
- function (SpanData $ span , $ args , $ retval , $ exception ) {
367
+ static function (SpanData $ span , $ args , $ retval , $ exception ) {
368
368
AMQPIntegration::setGenericTags ($ span , 'reconnect ' , 'client ' , null , $ exception );
369
369
}
370
370
);
371
371
372
372
trace_method (
373
373
'PhpAmqpLib\Channel\AMQPChannel ' ,
374
374
'basic_ack ' ,
375
- function (SpanData $ span , $ args , $ retval , $ exception ) {
375
+ static function (SpanData $ span , $ args , $ retval , $ exception ) {
376
376
/** @var int $deliveryTag */
377
377
$ deliveryTag = $ args [0 ];
378
378
@@ -383,7 +383,7 @@ function (SpanData $span, $args, $retval, $exception) {
383
383
trace_method (
384
384
'PhpAmqpLib\Channel\AMQPChannel ' ,
385
385
'basic_nack ' ,
386
- function (SpanData $ span , $ args , $ retval , $ exception ) {
386
+ static function (SpanData $ span , $ args , $ retval , $ exception ) {
387
387
/** @var int $deliveryTag */
388
388
$ deliveryTag = $ args [0 ];
389
389
@@ -394,7 +394,7 @@ function (SpanData $span, $args, $retval, $exception) {
394
394
trace_method (
395
395
'PhpAmqpLib\Channel\AMQPChannel ' ,
396
396
'basic_get ' ,
397
- function (SpanData $ span , $ args , $ message , $ exception ) {
397
+ static function (SpanData $ span , $ args , $ message , $ exception ) {
398
398
/** @var string $queue */
399
399
$ queue = $ args [0 ];
400
400
0 commit comments