Как интегрировать клиентскую библиотеку rabbit mq

Question

Во время многих поисков по поводу Rabbit MQ я нашел объективную оболочку C для librabbitmq-c чья ссылка направлена ​​на librabbitmq-objc.

Для librabbitmq-c ссылка найдена https://github.com/alanxz/rabbitmq-c.

Я пытался интегрировать оба в моем приложении, много ошибок, как производятся

i)  <Cocoa/Cocoa.h> file not found
ii) <amqp.h> file not found
iii)Too few arguements passing to amqp_basic_consume() method in AMQPConsumer.m
iv) Use of undeclared identifier AMQ_PLATFORM in amqp_socket.c file.
v)  Use of undeclared identifier AMQP_EXCHANGE_TYPE_DIRECT in AMQPExchange.m
vi) ""---------""----- ""------- AMQP_EXCHANGE_TYPE_FANOUT in ""---""-------
vii)--""-----------""----------- AMQP_EXCHANGE_TYPE_TOPIC in ""----""-------

Я также попробовал последнюю версию librabbitmq-c по этой ссылке https://github.com/alanxz/rabbitmq-c/releases/download/v0.5.2/rabbitmq-c-0.5.2.tar.gz

Первая и вторая проблема решена путем замены <Cocoa/Cocoa.h> с <Foundation/Foundation.h>а также <amqp.h> с "amqp.h"

Но я не могу решить остальные из них

Моя реализация клиентской библиотеки приведена ниже:

NSString *workQueueName = @"MyQueue";

AMQPExchange *exchange;
AMQPConnection *connection = [[AMQPConnection alloc] init];

[connection connectToHost:@"localhost" onPort:5672];
[connection loginAsUser:@"guest" withPasswort:@"guest" onVHost:@"/"];

AMQPChannel *receiverChannel = [connection openChannel];

AMQPQueue *queue = [[AMQPQueue alloc] initWithName:workQueueName
                                          onChannel:receiverChannel
                                          isPassive:NO
                                        isExclusive:NO
                                          isDurable:NO 
                                    getsAutoDeleted:YES];

exchange = [[AMQPExchange alloc] initFanoutExchangeWithName:@"EXCHANGE_NAME" onChannel:receiverChannel isPassive:NO isDurable:NO getsAutoDeleted:NO];

[queue bindToExchange:exchange withKey:workQueueName];


AMQPConsumer *consumer = [[AMQPConsumer alloc] initForQueue:queue onChannel:receiverChannel useAcknowledgements:NO isExclusive:NO receiveLocalMessages:YES];

AMQPConsumerThread *wqThread = [[AMQPConsumerThread alloc] initWithConsumer:consumer];
wqThread.delegate = self;

[wqThread start];

Буду признателен за любую помощь в отношении Rabbit MQ, спасибо

Answer 1

После длительного периода времени я решил это.

Пожалуйста, обратитесь по этой ссылке для библиотеки

https://dl.dropboxusercontent.com/u/75870052/AMQPLib.zip

и обратитесь к следующей ссылке для деталей...

/questions/323266/klient-objective-c-rabbitmq-ne-publikuet-soobscheniya-v-ocheredi/323272#323272