fixed example

Signed-off-by: shubham <[email protected]>
numaproj · May 30, 2024 · 3ea9857 · 3ea9857
1 parent e0350fb
commit 3ea9857
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/examples/simple-source/src/main.rs b/examples/simple-source/src/main.rs
@@ -54,6 +54,7 @@ pub(crate) mod simple_source {
                 self.read_idx
                     .store(self.read_idx.load(Ordering::Relaxed) + 1, Ordering::Relaxed);
                 let offset = self.read_idx.load(Ordering::Relaxed);
+                let mut headers = HashMap::new();
                 headers.insert(String::from("x-txn-id"), String::from(Uuid::new_v4()));
                 let shared_headers = Arc::new(headers);
                 // send the message to the transmitter