Better ssl checking

Author: timhonders

android/src/main/java/nl/kega/reactnativerabbitmq/RabbitMqConnection.java

@@ -71,7 +71,7 @@ public void initialize(ReadableMap config) {
         this.factory.setRequestedHeartbeat(10);
 
         try {
-            if (this.config.getInt("port") == 5671) {
+            if (this.config.getBoolean("ssl")) {
                 this.factory.useSslProtocol();
             }
         } catch(Exception e) {

ios/RCTReactNativeRabbitMq/RabbitMqConnection.m

@@ -29,13 +29,17 @@ @implementation RabbitMqConnection
 {
 
     RabbitMqDelegateLogger *delegate = [[RabbitMqDelegateLogger alloc] initWithBridge:self.bridge];
-    
-    if(self.config[@"port"] == 5671) {
-        NSString *uri = [NSString stringWithFormat:@"amqps://%@:%@@%@:%@/%@", self.config[@"username"], self.config[@"password"], self.config[@"host"], self.config[@"port"], self.config[@"virtualhost"]];
-    } else {
-        NSString *uri = [NSString stringWithFormat:@"amqp://%@:%@@%@:%@/%@", self.config[@"username"], self.config[@"password"], self.config[@"host"], self.config[@"port"], self.config[@"virtualhost"]];        
+
+    NSString *protocol = @"amqp";
+
+    Boolean ssl = self.config[@"ssl"];
+    if (ssl) {
+        protocol = @"amqps";
     }
 
+    NSString *uri = [NSString stringWithFormat:@"%@://%@:%@@%@:%@/%@", protocol, self.config[@"username"], self.config[@"password"], self.config[@"host"], self.config[@"port"], self.config[@"virtualhost"]];        
+    
+  
     self.connection = [[RMQConnection alloc] initWithUri:uri 
                                               channelMax:@65535 
                                                 frameMax:@(RMQFrameMax)