@@ -37,6 +37,10 @@ class TaskHandler
3737 * @var RetryConfig
3838 */
3939 private $ retryConfig = null ;
40+ /**
41+ * @var string
42+ */
43+ private $ taskName ;
4044
4145 public function __construct (CloudTasksClient $ client )
4246 {
@@ -83,10 +87,11 @@ private function captureTask($task): array
8387// $nameHeader = config('queue.connections.cloudtasks.app_engine')
8488// ? 'X-AppEngine-TaskName'
8589// : 'X-CloudTasks-TaskName';
90+ $ taskName = request ()->header ('X-CloudTasks-TaskName ' ) ?? request ()->header ('X-AppEngine-TaskName ' );
8691 $ validator = validator ([
8792 'json ' => $ task ,
8893 'task ' => $ array ,
89- 'name_header ' => request ()-> header ( ' X-CloudTasks-TaskName ' ) ?? request ()-> header ( ' X-AppEngine-TaskName ' ) ,
94+ 'name_header ' => $ taskName ,
9095 ], [
9196 'json ' => 'required|json ' ,
9297 'task ' => 'required|array ' ,
@@ -96,6 +101,7 @@ private function captureTask($task): array
96101
97102 try {
98103 $ validator ->validate ();
104+ $ this ->taskName = $ taskName ;
99105 } catch (ValidationException $ e ) {
100106 if (config ('app.debug ' )) {
101107 throw $ e ;
@@ -131,12 +137,11 @@ private function handleTask(array $task): void
131137
132138 $ this ->loadQueueRetryConfig ($ job );
133139
134- $ taskName = request ()->header ('X-Cloudtasks-Taskname ' );
135140 $ fullTaskName = $ this ->client ->taskName (
136141 $ this ->config ['project ' ],
137142 $ this ->config ['location ' ],
138143 $ job ->getQueue () ?: $ this ->config ['queue ' ],
139- $ taskName ,
144+ $ this -> taskName ,
140145 );
141146
142147 try {
0 commit comments