Tutorial 3 controller for Objective-C

camelpunch · camelpunch · commit cc1581c2ab40 · 2016-04-25T22:00:35.000+01:00
[#117056895]
diff --git a/objective-c/tutorial3/Cartfile.resolved b/objective-c/tutorial3/Cartfile.resolved
@@ -1,3 +1,3 @@
 github "robbiehanson/CocoaAsyncSocket" "562bae6af6dbd7e1891293dae20b9f79a2fd7228"
 github "Mantle/Mantle" "a16d18f635b3ba1ffb01d27d4393ee97cadf4f34"
-github "rabbitmq/rabbitmq-objc-client" "ea25de2d8d43152f8040d0994a9a3a4239d9442f"
+github "rabbitmq/rabbitmq-objc-client" "de0f201af7d3fd94f62ef29568c83ab88b2b35fb"
diff --git a/objective-c/tutorial3/tutorial3/ViewController.m b/objective-c/tutorial3/tutorial3/ViewController.m
@@ -1,11 +1,3 @@
-//
-//  ViewController.m
-//  tutorial3
-//
-//  Created by Pivotal on 25/04/2016.
-//  Copyright © 2016 RabbitMQ. All rights reserved.
-//
-
 #import "ViewController.h"
 @import RMQClient;
 
@@ -17,12 +9,42 @@ @implementation ViewController
 
 - (void)viewDidLoad {
     [super viewDidLoad];
-    // Do any additional setup after loading the view, typically from a nib.
+    [self receiveLogs];
+    [self receiveLogs];
+    sleep(1);
+    [self emitLog];
 }
 
-- (void)didReceiveMemoryWarning {
-    [super didReceiveMemoryWarning];
-    // Dispose of any resources that can be recreated.
+- (void)emitLog {
+    RMQConnection *conn = [[RMQConnection alloc] initWithDelegate:[RMQConnectionDelegateLogger new]];
+    [conn start];
+
+    id<RMQChannel> ch = [conn createChannel];
+    RMQExchange *x = [ch fanout:@"logs" options:RMQExchangeDeclareNoOptions];
+
+    NSString *msg = @"Hello World!";
+
+    [x publish:msg];
+    NSLog(@"Sent %@", msg);
+
+    [conn close];
+}
+
+- (void)receiveLogs {
+    RMQConnection *conn = [[RMQConnection alloc] initWithDelegate:[RMQConnectionDelegateLogger new]];
+    [conn start];
+
+    id<RMQChannel> ch = [conn createChannel];
+    RMQExchange *x = [ch fanout:@"logs" options:RMQExchangeDeclareNoOptions];
+    RMQQueue *q = [ch queue:@"" options:RMQQueueDeclareExclusive];
+
+    [q bind:x];
+
+    NSLog(@"Waiting for logs.");
+
+    [q subscribe:^(RMQMessage * _Nonnull message) {
+        NSLog(@"Received %@", message);
+    }];
 }
 
 @end
