ViewController.m

#import "ViewController.h"
@import RMQClient;

@interface ViewController ()
@end

@implementation ViewController


- (void)viewDidLoad {



    [super viewDidLoad];




    // running /usr/local/sbin/rabbitmq-server from terminal



    [self send];

    [self receive];

}




- (void)send {



    NSLog(@"Attempting to connect to local RabbitMQ broker");

    RMQConnection *conn = [[RMQConnection alloc] initWithUri:@"amqp://guest:guest@localhost" delegate:[RMQConnectionDelegateLogger new]];

    [conn start];



    id<RMQChannel> ch = [conn createChannel];



    RMQQueue *q = [ch queue:@"hello"];



    [ch.defaultExchange publish:[@"Hello World!" dataUsingEncoding:NSUTF8StringEncoding] routingKey:q.name];

    NSLog(@"Sent 'Hello World!'");



    [conn close];



}




- (void)receive {



    NSLog(@"Attempting to connect to local RabbitMQ broker");

    RMQConnection *conn = [[RMQConnection alloc] initWithUri:@"amqp://guest:guest@localhost" delegate:[RMQConnectionDelegateLogger new]];

    [conn start];



    id<RMQChannel> ch = [conn createChannel];



    RMQQueue *q = [ch queue:@"hello"];

    NSLog(@"Waiting for messages.");

    [q subscribe:^(RMQMessage * _Nonnull message) {

        NSLog(@"Received %@", [[NSString alloc] initWithData:message.body encoding:NSUTF8StringEncoding]);
        
    }];
    
    NSLog(@"end of receiving");
}

@end