From a28a2fc59549ec8f3926a3d061ed906d061160f6 Mon Sep 17 00:00:00 2001 From: Gus Class Date: Thu, 6 Jul 2017 10:22:26 -0700 Subject: [PATCH] Fixes RSA algo and uses .equals for string comparisons --- .../java/com/google/cloud/iot/examples/MqttExample.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/iot/api-client/mqtt_example/src/main/java/com/google/cloud/iot/examples/MqttExample.java b/iot/api-client/mqtt_example/src/main/java/com/google/cloud/iot/examples/MqttExample.java index 8eb34750586..91e8c2246cc 100644 --- a/iot/api-client/mqtt_example/src/main/java/com/google/cloud/iot/examples/MqttExample.java +++ b/iot/api-client/mqtt_example/src/main/java/com/google/cloud/iot/examples/MqttExample.java @@ -53,7 +53,7 @@ private static String createJwtRsa(String projectId, String privateKeyFile) thro byte[] keyBytes = Files.readAllBytes(Paths.get(privateKeyFile)); PKCS8EncodedKeySpec spec = new PKCS8EncodedKeySpec(keyBytes); - KeyFactory kf = KeyFactory.getInstance("RSA256"); + KeyFactory kf = KeyFactory.getInstance("RSA"); return jwtBuilder.signWith(SignatureAlgorithm.RS256, kf.generatePrivate(spec)).compact(); } @@ -107,10 +107,11 @@ public static void main(String[] args) throws Exception { // to authorize the device. connectOptions.setUserName("unused"); - if (options.algorithm == "RSA256") { + System.out.println(options.algorithm); + if (options.algorithm.equals("RS256")) { connectOptions.setPassword( createJwtRsa(options.projectId, options.privateKeyFile).toCharArray()); - } else if (options.algorithm == "ES256") { + } else if (options.algorithm.equals("ES256")) { connectOptions.setPassword( createJwtEs(options.projectId, options.privateKeyFile).toCharArray()); } else {