fix: stream sqs queue process output

Author: carlalexander

src/Lambda/Handler/Sqs/AbstractIlluminateQueueSqsHandler.php

@@ -71,7 +71,9 @@ final protected function processRecord(InvocationContext $context, SqsRecord $re
 
         $process = new Process($arguments);
         $process->setTimeout(null);
-        $process->run();
+        $process->run(function (string $type, string $output): void {
+            $this->writeProcessOutput($type, $output);
+        });
 
         if ($process->isSuccessful()) {
             return;
@@ -86,6 +88,14 @@ final protected function processRecord(InvocationContext $context, SqsRecord $re
         throw new SqsRecordProcessingException(sprintf('%s queue job failed', $this->getQueueName()), $output);
     }
 
+    /**
+     * Write the queue process output.
+     */
+    protected function writeProcessOutput(string $type, string $output): void
+    {
+        fwrite(Process::ERR === $type ? STDERR : STDOUT, $output);
+    }
+
     /**
      * Get queue process arguments.
      *