@@ -37,6 +37,10 @@ class TaskHandler
37
37
* @var RetryConfig
38
38
*/
39
39
private $ retryConfig = null ;
40
+ /**
41
+ * @var string
42
+ */
43
+ private $ taskName ;
40
44
41
45
public function __construct (CloudTasksClient $ client )
42
46
{
@@ -83,10 +87,11 @@ private function captureTask($task): array
83
87
// $nameHeader = config('queue.connections.cloudtasks.app_engine')
84
88
// ? 'X-AppEngine-TaskName'
85
89
// : 'X-CloudTasks-TaskName';
90
+ $ taskName = request ()->header ('X-CloudTasks-TaskName ' ) ?? request ()->header ('X-AppEngine-TaskName ' );
86
91
$ validator = validator ([
87
92
'json ' => $ task ,
88
93
'task ' => $ array ,
89
- 'name_header ' => request ()-> header ( ' X-CloudTasks-TaskName ' ) ?? request ()-> header ( ' X-AppEngine-TaskName ' ) ,
94
+ 'name_header ' => $ taskName ,
90
95
], [
91
96
'json ' => 'required|json ' ,
92
97
'task ' => 'required|array ' ,
@@ -96,6 +101,7 @@ private function captureTask($task): array
96
101
97
102
try {
98
103
$ validator ->validate ();
104
+ $ this ->taskName = $ taskName ;
99
105
} catch (ValidationException $ e ) {
100
106
if (config ('app.debug ' )) {
101
107
throw $ e ;
@@ -131,12 +137,11 @@ private function handleTask(array $task): void
131
137
132
138
$ this ->loadQueueRetryConfig ($ job );
133
139
134
- $ taskName = request ()->header ('X-Cloudtasks-Taskname ' );
135
140
$ fullTaskName = $ this ->client ->taskName (
136
141
$ this ->config ['project ' ],
137
142
$ this ->config ['location ' ],
138
143
$ job ->getQueue () ?: $ this ->config ['queue ' ],
139
- $ taskName ,
144
+ $ this -> taskName ,
140
145
);
141
146
142
147
try {
0 commit comments