feature: added management api for redis

Author: densumesh

.vscode/settings.json

@@ -1,9 +1,4 @@
 {
-  "rust-analyzer.showUnlinkedFileNotification": false,
-  "rust-analyzer.cargo.features": [
-    "redis",
-    "rabbitmq",
-    "test-fairness",
-    "management"
-  ]
+  "rust-analyzer.showUnlinkedFileNotification": true,
+  "rust-analyzer.cargo.features": "all"
 }

Cargo.lock

@@ -32,6 +32,7 @@ redis = { version = "0.27.5", features = [
     "aio",
 ], optional = true }
 dashmap = "6.1.0"
+derive_more = { version = "2.0.1", features = ["display"], optional = true }
 
 [dev-dependencies]
 chrono = { version = "0.4.39", features = ["serde"] }
@@ -52,7 +53,7 @@ rabbitmq = ["dep:lapin", "dep:deadpool", "dep:deadpool-lapin"]
 test-fairness = []
 
 # Allows for access to the management API for the queue.
-management = []
+management = ["dep:derive_more"]
 
 [[bench]]
 name = "queue_benchmark"

broccoli-queue/Cargo.toml

@@ -23,7 +23,7 @@ async fn process_job(job: JobPayload) -> Result<(), BroccoliError> {
     // Simulate some work
     tokio::time::sleep(Duration::from_secs(1)).await;
 
-    Ok(())
+    Err(BroccoliError::Consume("Failed to process job".into()))
 }
 
 async fn success_handler(msg: JobPayload) -> Result<(), BroccoliError> {