diff --git a/examples/tokio-example/src/main.rs b/examples/tokio-example/src/main.rs
index 53a388a..03cb1ce 100644
--- a/examples/tokio-example/src/main.rs
+++ b/examples/tokio-example/src/main.rs
@@ -40,7 +40,7 @@ async fn main() -> Result<(), Error> {
     let queue_handle = WorkerConfig::new(storage, |_| MyState::new("My App"))
         .register::<MyJob>()
         .set_worker_count(DEFAULT_QUEUE, 16)
-        .start();
+        .start()?;
 
     // Queue our jobs
     queue_handle.queue(MyJob::new(1, 2)).await?;
@@ -55,6 +55,8 @@ async fn main() -> Result<(), Error> {
     // Block on Tokio
     tokio::signal::ctrl_c().await?;
 
+    drop(queue_handle);
+
     Ok(())
 }