diff --git a/src/runtime2/connector.rs b/src/runtime2/connector.rs
index 58db4129573181cf62b53c3c60010562499da244..b8f2f1279ff496bfac0072bead3e49167c425c32 100644
--- a/src/runtime2/connector.rs
+++ b/src/runtime2/connector.rs
@@ -218,7 +218,7 @@ impl ConnectorPDL {
     pub fn handle_new_data_message(&mut self, ticket: MessageTicket, ctx: &mut ComponentCtx) {
         // Go through all branches that are awaiting new messages and see if
         // there is one that can receive this message.
-        if self.consensus.handle_new_data_message(ticket, ctx) {
+        if !self.consensus.handle_new_data_message(ticket, ctx) {
             // Message should not be handled now
             return;
         }
@@ -248,6 +248,7 @@ impl ConnectorPDL {
     }
 
     pub fn handle_new_sync_comp_message(&mut self, message: SyncCompMessage, ctx: &mut ComponentCtx) -> Option<ConnectorScheduling> {
+        println!("DEBUG: Actually really handling {:?}", message);
         if let Some(round_conclusion) = self.consensus.handle_new_sync_comp_message(message, ctx) {
             return Some(self.enter_non_sync_mode(round_conclusion, ctx));
         }