queue redis 的 onConsumeFailure捕获不到异常信息

queue redis 的 onConsumeFailure捕获不到异常信息，不多说上代码；

<?php

namespace app\queue\redis;

use app\exceptor\custom\ParamException;
use GuzzleHttp\Exception\ServerException;
use support\Container;
use support\Log;
use Webman\RedisQueue\Consumer;

class Statistics implements Consumer
{

    // 要消费的队列名
    public $queue = 'statistics';
    // 连接名，对应 plugin/webman/redis-queue/redis.php 里的连接`
    public $connection = 'default';

    /**
     * @throws ParamException
     */
    public function consume($data)
    {
        echo "统计队列消费内容\n";
        print_r($data);
        return callStatistics($data);

       /* try {
            return callStatistics($data);
        }
        catch ( \Exception $e ) {
            Log::error('statistics 统计队列消费捕获异常',[$e->getMessage(),[$e]]);
            return $e->getMessage();
        }*/

    }

    public function onConsumeFailure(\Throwable $e, $package)
    {

        echo "统计队列消费捕获异常\n";
        echo $e->getMessage();

        // 将接收的数据写入日志文件
        $path = runtime_path().'/logs/redisQueue/' . date('Ym');

        if (!is_dir($path)) {
            mkdir($path, 0777, true);
        }
        $path .= '/' . date('Ymd') . '.txt';

        file_put_contents($path, date('Y-m-d H:i:s')."-$this->queue" . "\n Message:".$e->getMessage() . "\n Content:" . json_encode($package,JSON_UNESCAPED_UNICODE ) . "\n\n", FILE_APPEND);

    }
}

执行到 callStatistics 方法 ，我直接 抛出了异常， throw new ParamException('数据类型有误');
在命令面板有抛出异常，但是我在 onConsumeFailure 下面获取不到异常，命令面板也没有执行我echo 的提示 。

那位大佬遇到过这种问题，或者帮忙看看，需要怎么解决。
非常感谢。