File tree Expand file tree Collapse file tree 1 file changed +12
-2
lines changed
installer/resources/async_queue Expand file tree Collapse file tree 1 file changed +12
-2
lines changed Original file line number Diff line number Diff line change 1919use Hyperf \AsyncQueue \Event \RetryHandle ;
2020use Hyperf \Event \Annotation \Listener ;
2121use Hyperf \Event \Contract \ListenerInterface ;
22+ use Hyperf \ExceptionHandler \Formatter \FormatterInterface ;
2223use Hyperf \Logger \LoggerFactory ;
2324
2425/**
2526 * @Listener
2627 */
2728class QueueHandleListener implements ListenerInterface
2829{
30+ /**
31+ * @var \Psr\Log\LoggerInterface
32+ */
2933 protected $ logger ;
3034
31- public function __construct (LoggerFactory $ loggerFactory )
35+ /**
36+ * @var FormatterInterface
37+ */
38+ protected $ formatter ;
39+
40+ public function __construct (LoggerFactory $ loggerFactory , FormatterInterface $ formatter )
3241 {
3342 $ this ->logger = $ loggerFactory ->get ('queue ' );
43+ $ this ->formatter = $ formatter ;
3444 }
3545
3646 public function listen (): array
@@ -59,7 +69,7 @@ public function process(object $event)
5969 break ;
6070 case $ event instanceof FailedHandle:
6171 $ this ->logger ->error (sprintf ('[%s] Failed %s. ' , $ date , $ jobClass ));
62- $ this ->logger ->error (format_throwable ($ event ->getThrowable ()));
72+ $ this ->logger ->error ($ this -> formatter -> format ($ event ->getThrowable ()));
6373 break ;
6474 case $ event instanceof RetryHandle:
6575 $ this ->logger ->warning (sprintf ('[%s] Retried %s. ' , $ date , $ jobClass ));
You can’t perform that action at this time.
0 commit comments