code: def pub_connect(self):
          '''
          Create and connect this thread's zmq socket. If a publisher socket
          already exists "pub_close" is called before creating and connecting a
          new socket.
          '''
          if self.pub_sock:
              self.pub_close()
          ctx = zmq.Context.instance()
          self._sock_data.sock = ctx.socket(zmq.PUSH)
          self.pub_sock.setsockopt(zmq.LINGER, -1)
          if self.opts.get('ipc_mode', '') == 'tcp':
              pull_uri = 'tcp://127.0.0.1:{0}'.format(
                  self.opts.get('tcp_master_publish_pull', 4514)
                  )
          else:
              pull_uri = 'ipc://{0}'.format(
                  os.path.join(self.opts['sock_dir'], 'publish_pull.ipc')
                  )
          log.debug("Connecting to pub server: %s", pull_uri)
          self.pub_sock.connect(pull_uri)
          return self._sock_data.socf pub_connect(self):
          '''
          Create and connect this thread's zmq socket. If a publisher socket
          already exists "pub_close" is called before creating and connecting a
          new socket.
          '''
          if self.pub_sock:
              self.pub_close()
          ctx = zmq.Context.instance()
          self._sock_data.sock = ctx.socket(zmq.PUSH)
          self.pub_sock.setsockopt(zmq.LINGER, -1)
          if self.opts.get('ipc_mode', '') == 'tcp':
              pull_uri = 'tcp://127.0.0.1:{0}'.format(
                  self.opts.get('tcp_master_publish_pull', 4514)
                  )
          else:
              pull_uri = 'ipc://{0}'.format(
                  os.path.join(self.opts['sock_dir'], 'publish_pull.ipc')
                  )
          log.debug("Connecting to pub server: %s", pull_uri)
          self.pub_sock.connect(pull_uri)
          return self._sock_data.sock
docs: Create and connect this thread's zmq socket. If a publisher socket
          already exists "pub_close" is called before creating and connecting a
          new socket.