@@ -26,7 +26,7 @@ - (void)newTask:(NSString *)msg {
2626
2727 RMQQueue *q = [ch queue: @" task_queue" options: RMQQueueDeclareDurable];
2828
29-  [ch.defaultExchange publish: msg routingKey: q.name];
29+  [ch.defaultExchange publish: msg routingKey: q.name  persistent: YES ];
3030 NSLog (@" Sent %@ " 
3131
3232 [conn close ];
@@ -43,26 +43,6 @@ - (void)workerNamed:(NSString *)name {
4343 [ch basicQos: @1  global: NO ];
4444 NSLog (@" %@ : Waiting for messages" 
4545
46-  [q subscribe: ^(id <RMQMessage> _Nonnull message) {
47-  NSLog (@" %@ : Received %@ " content );
48-  //  imitate some work
49-  unsigned  int  sleepTime = (unsigned  int )[message.content componentsSeparatedByString: @" ." count  - 1 ;
50-  NSLog (@" %@ : Sleeping for %u  seconds" 
51-  sleep (sleepTime);
52-  }];
53- }
54- 
55- - (void )workerWithManualAckNamed : (NSString  *)name  {
56-  RMQConnection *conn = [[RMQConnection alloc ] initWithDelegate: [RMQConnectionDelegateLogger new ]];
57-  [conn start ];
58- 
59-  id <RMQChannel> ch = [conn createChannel ];
60- 
61-  RMQQueue *q = [ch queue: @" task_queue" options: RMQQueueDeclareDurable];
62- 
63-  [ch basicQos: @1  global: NO ];
64-  NSLog (@" %@ : Waiting for messages" 
65- 
6646 RMQBasicConsumeOptions manualAck = RMQBasicConsumeNoOptions;
6747 [q subscribe: manualAck handler: ^(id <RMQMessage> _Nonnull message) {
6848 NSLog (@" %@ : Received %@ " content );
0 commit comments