DVDatabaseQueueAdapter class
Queue storage backed by a DVDatabaseAdapter, so dispatched jobs survive a process restart. With SQLite this is the durable local queue the spec calls for, sharing one database file with the application and cache.
Payload types must be registered with DVJobPayloadCodecs first.
- Implemented types
Constructors
- DVDatabaseQueueAdapter(DVDatabaseAdapter database, {String tableName = 'dartvel_jobs'})
Properties
- database → DVDatabaseAdapter
-
final
- hashCode → int
-
The hash code for this object.
no setterinherited
- runtimeType → Type
-
A representation of the runtime type of the object.
no setterinherited
- tableName → String
-
final
Methods
-
complete(
String id) → Future< void> -
override
-
deadLetters(
String queue) → Future< List< DVJobEnvelope< >DVJobPayload> > -
override
-
discard(
String id) → Future< bool> -
Drops one dead-lettered job. Flushing a queue to be rid of a single
poison message would take every other job with it.
override
-
enqueue<
TPayload> (String queue, TPayload payload, {int priority = 0, int maxAttempts = 3, Duration backoff = const Duration(seconds: 30)}) → Future< DVJobEnvelope< TPayload> > -
override
-
fail(
String id, String error, StackTrace stackTrace) → Future< void> -
override
-
flush(
String queue) → Future< int> -
override
-
initialize(
) → Future< void> -
noSuchMethod(
Invocation invocation) → dynamic -
Invoked when a nonexistent method or property is accessed.
inherited
-
pending(
String queue) → Future< List< DVJobEnvelope< >DVJobPayload> > -
override
-
reserve(
String queue) → Future< DVJobEnvelope< DVJobPayload> ?> -
override
-
retry(
String id) → Future< bool> -
override
-
toString(
) → String -
A string representation of this object.
inherited
Operators
-
operator ==(
Object other) → bool -
The equality operator.
inherited