code: @RobotKeyword("Connect to MQTT Broker")
      @ArgumentNames({ "broker", "clientId" })
      public void connectToMQTTBroker(String broker, String clientId)
              throws MqttException {
          client = new MqttClient(broker, clientId);
          System.out.println("*INFO:" + System.currentTimeMillis()
                  + "* connecting to broker");
          client.connect();
          System.out.println("*INFO:" + System.currentTimeMillis()
                  + "* connected");
      }
docs: Connect to an MQTT broker.
  
  @param broker
  Uri of the broker to connect to
  @param clientId
  Client Id
  @throws MqttException
  if there is an issue connecting to the broker