diff --git a/src/runtime2/component/consensus.rs b/src/runtime2/component/consensus.rs
index dc11dd2c27b065ab112be629ac1ce3d31144a575..05856ffc3820837f251057c98e963c98eb51ddf4 100644
--- a/src/runtime2/component/consensus.rs
+++ b/src/runtime2/component/consensus.rs
@@ -355,7 +355,7 @@ impl Consensus {
         self.solution.clear();
     }
 
-    pub(crate) fn notify_received_port(&mut self, _expected_index: usize, port_handle: LocalPortHandle, comp_ctx: &CompCtx) {
+    pub(crate) fn notify_of_new_port(&mut self, _expected_index: usize, port_handle: LocalPortHandle, comp_ctx: &CompCtx) {
         debug_assert_eq!(_expected_index, self.ports.len());
         let port_info = comp_ctx.get_port(port_handle);
         self.ports.push(PortAnnotation{