Skip to content
This repository has been archived by the owner on Sep 21, 2021. It is now read-only.

Commit

Permalink
fix(mqtt): rewords variables
Browse files Browse the repository at this point in the history
Signed-off-by: Rafa Hernandez <rhernandez@teclib.com>
  • Loading branch information
rafaelje authored and Ivan Del Pino committed Dec 5, 2018
1 parent a7d9267 commit b2f6f7c
Showing 1 changed file with 7 additions and 7 deletions.
14 changes: 7 additions & 7 deletions app/src/main/java/org/flyve/mdm/agent/core/mqtt/MqttModel.java
Original file line number Diff line number Diff line change
Expand Up @@ -201,18 +201,18 @@ public void connect(final Context context, final MqttCallback callback) {

// If TLS is active needs ssl connection option
if (mTLS.equals("1")) {
TrustManagerFactory tmf = TrustManagerFactory.getInstance(TrustManagerFactory.getDefaultAlgorithm());
TrustManagerFactory trustManagerFactory = TrustManagerFactory.getInstance(TrustManagerFactory.getDefaultAlgorithm());

KeyStore caKeyStore = KeyStore.getInstance(KeyStore.getDefaultType());
caKeyStore.load(null, null);

CertificateFactory caCF = CertificateFactory.getInstance("X.509");
X509Certificate ca = (X509Certificate) caCF.generateCertificate(context.getResources().openRawResource(R.raw.flyve_org));
CertificateFactory certificationFactory = CertificateFactory.getInstance("X.509");
X509Certificate ca = (X509Certificate) certificationFactory.generateCertificate(context.getResources().openRawResource(R.raw.flyve_org));
String alias = ca.getSubjectX500Principal().getName();

// Set propper alias name
caKeyStore.setCertificateEntry(alias, ca);
tmf.init(caKeyStore);
trustManagerFactory.init(caKeyStore);

FlyveLog.v("Certificate Owner: %s", ca.getSubjectDN().toString());
FlyveLog.v("Certificate Issuer: %s", ca.getIssuerDN().toString());
Expand All @@ -226,12 +226,12 @@ public void connect(final Context context, final MqttCallback callback) {
FlyveLog.v("Alias: %s isKeyEntry:%s isCertificateEntry:%s", o, caKeyStore.isKeyEntry(o), caKeyStore.isCertificateEntry(o));
}

KeyManagerFactory kmf = KeyManagerFactory.getInstance("X509");
kmf.init(null,null);
KeyManagerFactory keyManagerFactory = KeyManagerFactory.getInstance("X509");
keyManagerFactory.init(null,null);

// SSL
SSLContext sslContext = SSLContext.getInstance("TLSv1.2");
sslContext.init(kmf.getKeyManagers(), tmf.getTrustManagers(), null);
sslContext.init(keyManagerFactory.getKeyManagers(), trustManagerFactory.getTrustManagers(), null);
options.setSocketFactory(sslContext.getSocketFactory());
}
} catch (Exception ex) {
Expand Down

0 comments on commit b2f6f7c

Please sign in to comment.