Merge pull request #451 from SylvainCorlay/backport-447

Backport 5.x PR #477: Exposes control channel in public API

Author: SylvainCorlay

jupyter_client/ioloop/manager.py

@@ -56,6 +56,7 @@ def stop_restarter(self):
                 self._restarter.stop()
 
     connect_shell = as_zmqstream(KernelManager.connect_shell)
+    connect_control = as_zmqstream(KernelManager.connect_control)
     connect_iopub = as_zmqstream(KernelManager.connect_iopub)
     connect_stdin = as_zmqstream(KernelManager.connect_stdin)
     connect_hb = as_zmqstream(KernelManager.connect_hb)

jupyter_client/multikernelmanager.py

@@ -284,6 +284,22 @@ def connect_shell(self, kernel_id, identity=None):
         stream : zmq Socket or ZMQStream
         """
 
+    @kernel_method
+    def connect_control(self, kernel_id, identity=None):
+        """Return a zmq Socket connected to the control channel.
+
+        Parameters
+        ==========
+        kernel_id : uuid
+            The id of the kernel
+        identity : bytes (optional)
+            The zmq identity of the socket
+
+        Returns
+        =======
+        stream : zmq Socket or ZMQStream
+        """
+
     @kernel_method
     def connect_stdin(self, kernel_id, identity=None):
         """Return a zmq Socket connected to the stdin channel.