diff options
Diffstat (limited to 'ext/kv/sqlite.rs')
| -rw-r--r-- | ext/kv/sqlite.rs | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/ext/kv/sqlite.rs b/ext/kv/sqlite.rs index 6cff3145d..808bf9b4f 100644 --- a/ext/kv/sqlite.rs +++ b/ext/kv/sqlite.rs @@ -325,7 +325,7 @@ impl SqliteQueue { // Oneshot requeue of all inflight messages. Self::requeue_inflight_messages(conn.clone()).await.unwrap(); - // Continous dequeue loop. + // Continuous dequeue loop. Self::dequeue_loop(conn.clone(), dequeue_tx, shutdown_rx, waker_rx) .await .unwrap(); @@ -716,12 +716,12 @@ impl Database for SqliteDb { } tx.commit()?; - let new_vesionstamp = version_to_versionstamp(version); + let new_versionstamp = version_to_versionstamp(version); Ok(( has_enqueues, Some(CommitResult { - versionstamp: new_vesionstamp, + versionstamp: new_versionstamp, }), )) }) |