diff --git a/rust/cubestore/cubestore/src/cluster/worker_services.rs b/rust/cubestore/cubestore/src/cluster/worker_services.rs
index 2544f490f198f..c703afcc05360 100644
--- a/rust/cubestore/cubestore/src/cluster/worker_services.rs
+++ b/rust/cubestore/cubestore/src/cluster/worker_services.rs
@@ -246,13 +246,13 @@ impl<P: Callable> ServicesClientImpl<P> {
                     payload: message,
                 };
 
+                let mut broadcast_rx = message_broadcast_tx.subscribe();
+
                 if let Err(e) = sender.send(ipc_message) {
                     log::error!("Error while sending ipc service request: {:?}", e);
                     break;
                 }
 
-                let mut broadcast_rx = message_broadcast_tx.subscribe();
-
                 cube_ext::spawn(async move {
                     loop {
                         let broadcast_message = tokio::select! {