File tree Expand file tree Collapse file tree 1 file changed +5
-1
lines changed
Expand file tree Collapse file tree 1 file changed +5
-1
lines changed Original file line number Diff line number Diff line change @@ -57,6 +57,7 @@ public function push(
5757 ->dispatch ($ request , $ this ->createPushHandler ($ middlewareDefinitions ))
5858 ->getMessage ();
5959
60+ /** @var string $messageId */
6061 $ messageId = $ message ->getMetadata ()[IdEnvelope::MESSAGE_ID_KEY ] ?? 'null ' ;
6162 $ this ->logger ->info (
6263 'Pushed message with handler name "{handlerName}" to the queue. Assigned ID #{id}. ' ,
@@ -149,7 +150,7 @@ private function checkAdapter(): void
149150 }
150151 }
151152
152- private function createPushHandler (array $ middlewares ): MessageHandlerPushInterface
153+ private function createPushHandler (MiddlewarePushInterface | callable | array | string ... $ middlewares ): MessageHandlerPushInterface
153154 {
154155 return new class (
155156 $ this ->adapterPushHandler ,
@@ -159,6 +160,9 @@ private function createPushHandler(array $middlewares): MessageHandlerPushInterf
159160 public function __construct (
160161 private AdapterPushHandler $ adapterPushHandler ,
161162 private PushMiddlewareDispatcher $ dispatcher ,
163+ /**
164+ * @var array|array[]|callable[]|MiddlewarePushInterface[]|string[]
165+ */
162166 private array $ middlewares ,
163167 ) {
164168 }
You can’t perform that action at this time.
0 commit comments