diff --git a/src/runtime2/native.rs b/src/runtime2/native.rs
index 5eab60d0def9ecf32d6275a1a1c52568d19bf5cf..f8779bcb9fd6fa1dbea81a7fd38cac5bb8078811 100644
--- a/src/runtime2/native.rs
+++ b/src/runtime2/native.rs
@@ -21,7 +21,7 @@ pub(crate) trait Connector {
     fn handle_message(&mut self, message: Message, ctx: &ConnectorCtx, delta_state: &mut RunDeltaState);
 
     /// Should run the connector's behaviour up until the next blocking point.
-    fn run(&mut self, sched_ctx: &SchedulerCtx, conn_ctx: &ConnectorCtx, delta_state: &mut RunDeltaState) -> ConnectorScheduling;
+    fn run(&mut self, sched_ctx: SchedulerCtx, conn_ctx: &ConnectorCtx, delta_state: &mut RunDeltaState) -> ConnectorScheduling;
 }
 
 type SyncDone = Arc<(Mutex<bool>, Condvar)>;
@@ -66,7 +66,7 @@ impl Connector for ConnectorApplication {
         }
     }
 
-    fn run(&mut self, _sched_ctx: &SchedulerCtx, _conn_ctx: &ConnectorCtx, delta_state: &mut RunDeltaState) -> ConnectorScheduling {
+    fn run(&mut self, _sched_ctx: SchedulerCtx, _conn_ctx: &ConnectorCtx, delta_state: &mut RunDeltaState) -> ConnectorScheduling {
         let mut queue = self.job_queue.lock().unwrap();
         while let Some(job) = queue.pop_front() {
             match job {
@@ -112,7 +112,7 @@ impl ApplicationInterface {
 
     /// Creates a new channel.
     pub fn create_channel(&mut self) -> Channel {
-        let (getter_port, putter_port) = self.runtime.create_channel();
+        let (getter_port, putter_port) = self.runtime.create_channel(self.connector_id);
         debug_assert_eq!(getter_port.kind, PortKind::Getter);
         let getter_id = getter_port.self_id;
         let putter_id = putter_port.self_id;