diff --git a/services/backup/rust_lib/src/lib.rs b/services/backup/rust_lib/src/lib.rs
index da9d3b81f..d9ce5c772 100644
--- a/services/backup/rust_lib/src/lib.rs
+++ b/services/backup/rust_lib/src/lib.rs
@@ -1,52 +1,68 @@
 #[cxx::bridge]
 mod ffi {
   extern "Rust" {
     fn rust_is_initialized_cxx() -> bool;
     fn rust_initialize_cxx() -> ();
     unsafe fn rust_process_cxx(_: *const c_char) -> ();
     fn rust_terminate_cxx() -> ();
   }
 }
 
-use lazy_static::lazy_static;
-use libc;
-use libc::c_char;
-use std::sync::{Arc, Mutex};
+mod constants;
+
+use constants::MPSC_CHANNEL_BUFFER_CAPACITY;
 use tokio::runtime::Runtime;
 use tokio::sync::mpsc;
 use tokio::task::JoinHandle;
+use lazy_static::lazy_static;
+use std::sync::{Arc, Mutex};
+use libc;
+use libc::c_char;
 
 pub struct Client {
   tx: Option<mpsc::Sender<String>>,
   handle: Option<JoinHandle<()>>,
 }
 
 lazy_static! {
   pub static ref CLIENT: Arc<Mutex<Client>> = Arc::new(Mutex::new(Client {
     tx: None,
     handle: None
   }));
   pub static ref RUNTIME: Runtime = Runtime::new().unwrap();
 }
 
 pub fn rust_is_initialized_cxx() -> bool {
   if CLIENT.lock().expect("access client").tx.is_none() {
     return false;
   }
   if CLIENT.lock().expect("access client").handle.is_none() {
     return false;
   }
   return true;
 }
 
 pub fn rust_initialize_cxx() -> () {
-  unimplemented!();
+  println!("[RUST] initializing");
+  assert!(!rust_is_initialized_cxx(), "client cannot be initialized twice");
+  let (tx, mut rx): (mpsc::Sender<String>, mpsc::Receiver<String>) =
+    mpsc::channel(MPSC_CHANNEL_BUFFER_CAPACITY);
+  let handle = RUNTIME.spawn(async move {
+    println!("[RUST] [receiver] begin");
+    while let Some(data) = rx.recv().await {
+      println!("[RUST] [receiver] data: {}", data);
+    }
+    println!("[RUST] [receiver] done");
+  });
+  CLIENT.lock().expect("access client").handle = Some(handle);
+  CLIENT.lock().expect("access client").tx = Some(tx);
+  println!("[RUST] initialized");
 }
 
 pub fn rust_process_cxx(_: *const c_char) -> () {
   unimplemented!();
 }
 
 pub fn rust_terminate_cxx() -> () {
   unimplemented!();
 }