Ssl support

Author: timhonders

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

@@ -69,7 +69,14 @@ public void initialize(ReadableMap config) {
         this.factory.setPort(this.config.getInt("port"));
         this.factory.setAutomaticRecoveryEnabled(true);
         this.factory.setRequestedHeartbeat(10);
-        
+
+        try {
+            if (this.config.getInt("port") == 5671) {
+                this.factory.useSslProtocol();
+            }
+        } catch(Exception e) {
+            Log.e("RabbitMqConnection", e);
+        }
 
     }
 
@@ -139,11 +146,11 @@ public void handleRecovery(Recoverable recoverable) {
                     this.channel.addConfirmListener(new ConfirmListener() {
 
                         public void handleNack(long deliveryTag, boolean multiple) throws IOException {
-                            Log.e("RabbitMqQueue", "Not ack received -------------------------------");
+                            Log.e("RabbitMqQueue", "Not ack received");
                         }
 
                         public void handleAck(long deliveryTag, boolean multiple) throws IOException {
-                            Log.e("RabbitMqQueue", "Ack received ------------------------------------");
+                            Log.e("RabbitMqQueue", "Ack received");
                         }
                     });
 

ios/RCTReactNativeRabbitMq/RabbitMqConnection.m

@@ -29,9 +29,12 @@ @implementation RabbitMqConnection
 {
 
     RabbitMqDelegateLogger *delegate = [[RabbitMqDelegateLogger alloc] initWithBridge:self.bridge];
-
-    NSString *uri = [NSString stringWithFormat:@"amqp://%@:%@@%@:%@/%@", self.config[@"username"], self.config[@"password"], self.config[@"host"], self.config[@"port"], self.config[@"virtualhost"]];
-    //self.connection = [[RMQConnection alloc] initWithUri:uri verifyPeer:true delegate:delegate];
+    
+    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"]];        
+    }
 
     self.connection = [[RMQConnection alloc] initWithUri:uri 
                                               channelMax:@65535