handle method

  1. @override
Future<void> handle(
  1. QueueJobContext context,
  2. Next next
)
override

Handle the job context Call next() to continue to the next middleware or job execution

Implementation

@override
Future<void> handle(QueueJobContext context, Next next) async {
  await next().timeout(
    timeout,
    onTimeout: () {
      throw TimeoutException(
        'Job execution exceeded timeout of $timeout',
      );
    },
  );
}