diff --git a/daemon/src/maker_cfd.rs b/daemon/src/maker_cfd.rs
index cbb175d..1216b25 100644
--- a/daemon/src/maker_cfd.rs
+++ b/daemon/src/maker_cfd.rs
@@ -622,8 +622,9 @@ where
         tokio::spawn(async move {
             let dlc = contract_future.await;
 
-            this.do_send_async(CfdSetupCompleted { order_id, dlc })
+            this.send(CfdSetupCompleted { order_id, dlc })
                 .await
+                .expect("always connected to ourselves");
         });
 
         // 6. Record that we are in an active contract setup
@@ -789,8 +790,9 @@ where
         tokio::spawn(async move {
             let dlc = contract_future.await;
 
-            this.do_send_async(CfdRollOverCompleted { order_id, dlc })
+            this.send(CfdRollOverCompleted { order_id, dlc })
                 .await
+                .expect("always connected to ourselves")
         });
 
         self.remove_pending_proposal(&order_id)
diff --git a/daemon/src/taker_cfd.rs b/daemon/src/taker_cfd.rs
index 3242dd8..dd1219c 100644
--- a/daemon/src/taker_cfd.rs
+++ b/daemon/src/taker_cfd.rs
@@ -518,8 +518,9 @@ where
         tokio::spawn(async move {
             let dlc = contract_future.await;
 
-            this.do_send_async(CfdSetupCompleted { order_id, dlc })
+            this.send(CfdSetupCompleted { order_id, dlc })
                 .await
+                .expect("always connected to ourselves")
         });
 
         self.setup_state = SetupState::Active { sender };
@@ -582,8 +583,9 @@ where
         tokio::spawn(async move {
             let dlc = contract_future.await;
 
-            this.do_send_async(CfdRollOverCompleted { order_id, dlc })
+            this.send(CfdRollOverCompleted { order_id, dlc })
                 .await
+                .expect("always connected to ourselves")
         });
 
         self.remove_pending_proposal(&order_id)