echo/rabbitmq-tutorials
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Update objc tutorial1 for subscription errors

Browse Source 
Also, log before connecting for receive.

[#116521563]
This commit is contained in:
Andrew Bruce 2016-04-07 21:17:24 +01:00
parent 8048f89de7
commit 5b47ac5e42
2 changed files with 10 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
objective-c/tutorial1/Cartfile.resolved
View File

@ -1,3 +1,3 @@
github "robbiehanson/CocoaAsyncSocket" "562bae6af6dbd7e1891293dae20b9f79a2fd7228" github "robbiehanson/CocoaAsyncSocket" "562bae6af6dbd7e1891293dae20b9f79a2fd7228"
github "Mantle/Mantle" "cdb82df5dd3a7e4cfab6dfbc48df20dcc80b4e13" github "Mantle/Mantle" "cdb82df5dd3a7e4cfab6dfbc48df20dcc80b4e13"
github "rabbitmq/rabbitmq-objc-client" "7871c3ab0e731b6cc8b9bb1ac0ef5a410bc035ce" github "rabbitmq/rabbitmq-objc-client" "3e36e6db95769016ea38765ff6255e932867c89d"

16
objective-c/tutorial1/tutorial1/ViewController.m
View File

@ -13,10 +13,8 @@
} }
- (void)send { - (void)send {
RMQConnection *conn = [RMQConnection new];
NSLog(@"Attempting to connect to local RabbitMQ broker"); NSLog(@"Attempting to connect to local RabbitMQ broker");
RMQConnection *conn = [RMQConnection new];
NSError *error = NULL; NSError *error = NULL;
[conn startWithError:&error]; [conn startWithError:&error];
if (error) { if (error) {
@ -38,6 +36,7 @@
} }
- (void)receive { - (void)receive {
NSLog(@"Attempting to connect to local RabbitMQ broker");
RMQConnection *conn = [RMQConnection new]; RMQConnection *conn = [RMQConnection new];
NSError *error = NULL; NSError *error = NULL;
[conn startWithError:&error]; [conn startWithError:&error];
@ -55,11 +54,14 @@
RMQQueue *q = [ch queue:@"hello"]; RMQQueue *q = [ch queue:@"hello"];
NSLog(@"Waiting for messages."); NSLog(@"Waiting for messages.");
[q subscribe:^(id<RMQMessage> _Nonnull m) { [q subscribeWithError:&error handler:^(id<RMQMessage> _Nonnull message) {
NSLog(@"Received %@", m.content); NSLog(@"Received %@", message.content);
[conn close];
exit(0);
}]; }];
if (error) {
NSLog(@"Error subscribing: %@", error);
[conn close];
exit(1);
}
} }
@end @end