enqueueJson<T extends Object> method

Future<String> enqueueJson<T extends Object>(
  1. String name,
  2. T argsJson, {
  3. Map<String, String> headers = const {},
  4. TaskOptions options = const TaskOptions(),
  5. DateTime? notBefore,
  6. Map<String, Object?> meta = const {},
  7. TaskEnqueueOptions? enqueueOptions,
  8. String? typeName,
})

Enqueues a name-based task from a DTO that already exposes toJson().

Implementation

Future<String> enqueueJson<T extends Object>(
  String name,
  T argsJson, {
  Map<String, String> headers = const {},
  TaskOptions options = const TaskOptions(),
  DateTime? notBefore,
  Map<String, Object?> meta = const {},
  TaskEnqueueOptions? enqueueOptions,
  String? typeName,
}) {
  return enqueue(
    name,
    args: Map<String, Object?>.from(
      PayloadCodec.encodeJsonMap(
        argsJson,
        typeName: typeName ?? '$T',
      ),
    ),
    headers: headers,
    options: options,
    notBefore: notBefore,
    meta: meta,
    enqueueOptions: enqueueOptions,
  );
}