diff --git a/confluent_server/confluent/collective/manager.py b/confluent_server/confluent/collective/manager.py
index 807259d0..15d69d63 100644
--- a/confluent_server/confluent/collective/manager.py
+++ b/confluent_server/confluent/collective/manager.py
@@ -48,7 +48,8 @@ def connect_to_leader(cert=None, name=None):
         raise Exception("Certificate mismatch in the collective")
     tlvdata.recv(remote)  # the banner
     tlvdata.recv(remote)  # authpassed... 0..
-    tlvdata.send(remote, {'collective': {'operation': 'connect', 'name': name}})
+    tlvdata.send(remote, {'collective': {'operation': 'connect',
+                                         'name': name}})
     keydata = tlvdata.recv(remote)
     colldata = tlvdata.recv(remote)
     globaldata = tlvdata.recv(remote)
diff --git a/confluent_server/confluent/config/configmanager.py b/confluent_server/confluent/config/configmanager.py
index c8cf99ed..8f0db2b9 100644
--- a/confluent_server/confluent/config/configmanager.py
+++ b/confluent_server/confluent/config/configmanager.py
@@ -416,8 +416,7 @@ def follow_channel(channel):
             _txcount = rpc['txcount']
             if 'xid' in rpc:
                 _pendingchangesets[rpc['xid']].send()
-
-
+        msg = channel.recv(8)
 
 def add_collective_member(name, address, fingerprint):
     try: