diff --git a/src/runtime2/consensus.rs b/src/runtime2/consensus.rs
index d767ac3b32f5ba86419cf6db6ed055335bd16ca1..110d934e910921dd947b8b2fd8a6e042dc285ace 100644
--- a/src/runtime2/consensus.rs
+++ b/src/runtime2/consensus.rs
@@ -165,6 +165,7 @@ impl Consensus {
         let port_info = ctx.get_port_by_id(source_port_id).unwrap();
         let data_header = DataHeader{
             expected_mapping: branch.port_mapping.clone(),
+            sending_port: port_info.peer_id,
             target_port: port_info.peer_id,
             new_mapping: branch_id
         };