// Closure to handle TCPListener until done channel is closed.
	handleListener := func(idx int, tcpListener *net.TCPListener) {
		for {
			tcpConn, err := tcpListener.AcceptTCP()
			if tcpConn != nil {
				tcpConn.SetKeepAlive(true)
			}
			send(acceptResult{tcpConn, err, idx})
		}
	}

	// Start separate goroutine for each TCP listener to handle connection.
	for idx, tcpListener := range listener.tcpListeners {

  }

  @Throws(SocketException::class)
  override fun getTcpNoDelay(): Boolean {
    return delegate!!.tcpNoDelay
  }

  @Throws(SocketException::class)
  override fun setKeepAlive(keepAlive: Boolean) {
    delegate!!.keepAlive = keepAlive
  }

  @Throws(SocketException::class)
  override fun setSendBufferSize(size: Int) {
    delegate!!.sendBufferSize = size
  }

	options := mqtt.NewClientOptions().
		SetClientID(clientID).
		SetCleanSession(true).
		SetUsername(args.User).
		SetPassword(args.Password).
		SetMaxReconnectInterval(args.MaxReconnectInterval).
		SetKeepAlive(args.KeepAlive).
		SetTLSConfig(&tls.Config{RootCAs: args.RootCAs}).
		AddBroker(args.Broker.String())

	target.client = mqtt.NewClient(options)

	token := target.client.Connect()

pkg net, method (*TCPConn) ReadFrom(io.Reader) (int64, error)
pkg net, method (*TCPConn) RemoteAddr() Addr
pkg net, method (*TCPConn) SetDeadline(time.Time) error
pkg net, method (*TCPConn) SetKeepAlive(bool) error
pkg net, method (*TCPConn) SetLinger(int) error
pkg net, method (*TCPConn) SetNoDelay(bool) error
pkg net, method (*TCPConn) SetReadBuffer(int) error