pop method

@override Future<Job?> pop(String queue)

Pop a job from the queue

Implementation

@override
Future<Job?> pop(String queue) async {
  // Pop job ID from queue
  final jobId = await _redis.client.send_object(['RPOP', _getQueueKey(queue)]);

  if (jobId == null) return null;

  // Get job data
  final jobData = await _redis.get(_getJobKey(jobId as String));
  if (jobData == null) return null;

  return Job.fromJson(jsonDecode(jobData));
}