Skip to content

Commit

Permalink
Browse files Browse the repository at this point in the history
  • Loading branch information
Christoph Krey committed Mar 2, 2016
2 parents 738769c + 5dca64a commit 049692e
Showing 1 changed file with 4 additions and 3 deletions.
7 changes: 4 additions & 3 deletions MQTTClient/MQTTClient/MQTTSessionManager.m
Original file line number Diff line number Diff line change
Expand Up @@ -383,12 +383,13 @@ - (void)newMessage:(MQTTSession *)session data:(NSData *)data onTopic:(NSString

- (void)connected:(MQTTSession *)session sessionPresent:(BOOL)sessionPresent {
if (self.clean || !self.reconnectFlag || !sessionPresent) {
if (self.subscriptions && [self.subscriptions count]) {
NSDictionary *subscriptions = [self.subscriptions copy];
if (subscriptions.count) {
[self.effectiveSubscriptions removeAllObjects];
self.effectiveSubscriptions = self.effectiveSubscriptions;
[self.session subscribeToTopics:self.subscriptions subscribeHandler:^(NSError *error, NSArray<NSNumber *> *gQoss) {
[self.session subscribeToTopics:subscriptions subscribeHandler:^(NSError *error, NSArray<NSNumber *> *gQoss) {
if (!error) {
NSArray<NSString *> *allTopics = self.subscriptions.allKeys;
NSArray<NSString *> *allTopics = subscriptions.allKeys;
for (int i = 0; i < allTopics.count; i++) {
NSString *topic = allTopics[i];
NSNumber *gQos = gQoss[i];
Expand Down

0 comments on commit 049692e

Please sign in to comment.