diff --git a/src/runtime2/consensus.rs b/src/runtime2/consensus.rs
index c965d64b803233458efe6ae822988749577f809f..f69f1392977a41b4413618fefe4e1b13441230ea 100644
--- a/src/runtime2/consensus.rs
+++ b/src/runtime2/consensus.rs
@@ -1,6 +1,7 @@
 use crate::collections::VecSet;
 
 use crate::protocol::eval::ValueGroup;
+use crate::runtime2::branch::BranchQueueIter;
 
 use super::branch::{BranchId, ExecTree, QueueKind};
 use super::ConnectorId;
@@ -331,7 +332,7 @@ impl Consensus {
     ///     `branch_can_receive` function.
     /// 2. We return the branches that *can* receive the message, you still
     ///     have to explicitly call `notify_of_received_message`.
-    pub fn handle_new_data_message(&mut self, exec_tree: &ExecTree, message: &DataMessage, ctx: &mut ComponentCtx, target_ids: &mut Vec<BranchId>) -> bool {
+    pub fn handle_new_data_message(&mut self, potential_receivers: BranchQueueIter<'_, >, message: &DataMessage, ctx: &mut ComponentCtx, target_ids: &mut Vec<BranchId>) -> bool {
         self.handle_received_data_header(exec_tree, &message.sync_header, &message.data_header, &message.content, target_ids);
         return self.handle_received_sync_header(&message.sync_header, ctx)
     }